in boto3_sample/s3_event_notifications_crawler_setup.py [0:0]
def subscribe_to_sns_topic(topic_arn, client, protocol, endpoint):
try:
response = client.subscribe(
TopicArn=topic_arn,
Protocol=protocol,
Endpoint=endpoint
)
return response['SubscriptionArn']
except botocore.exceptions.ClientError as e:
print_error(e)
return None