Amazon Simple Notification Service (SNS)

Amazon Simple Notification Service (Amazon SNS) is a managed service that provides message delivery from publishers to subscribers (also known as producers and consumers). Publishers communicate asynchronously with subscribers by sending messages to a topic, which is a logical access point and communication channel. Clients can subscribe to the SNS topic and receive published messages using a supported endpoint type, such as Amazon Kinesis Data Firehose, Amazon SQS, AWS Lambda, HTTP, email, mobile push notifications, and mobile text messages (SMS).

Prerequisite Tasks

To use these operators, you must do a few things:

Operators

Publish a message to an existing SNS topic

To publish a message to an Amazon SNS Topic you can use SnsPublishOperator.

airflow/providers/amazon/aws/example_dags/example_sns.py[source]

publish = SnsPublishOperator(
    task_id='publish_message',
    target_arn=SNS_TOPIC_ARN,
    message='This is a sample message sent to SNS via an Apache Airflow DAG task.',
)

Was this entry helpful?