sns.py

import boto3

sns = boto3.client("sns", region_name="eu-central-1")

# CREATE TOPIC
topic_name = "ge_timeseries_data_test"
create_response = sns.create_topic(Name=topic_name)
topic_arn = create_response.get("TopicArn")
print("Create topic response: %s", create_response)

# CREATE SUBSCRIPTIONS
email_sub = sns.subscribe(
    TopicArn=topic_arn, Protocol="email", Endpoint="[email protected]"
)