airflow.contrib.operators.sns_publish_operator
¶
Module Contents¶
-
class
airflow.contrib.operators.sns_publish_operator.
SnsPublishOperator
(target_arn, message, aws_conn_id='aws_default', subject=None, message_attributes=None, *args, **kwargs)[source]¶ Bases:
airflow.models.BaseOperator
Publish a message to Amazon SNS.
- Parameters
aws_conn_id (str) – aws connection to use
target_arn (str) – either a TopicArn or an EndpointArn
message (str) – the default message you want to send (templated)
subject (str) – the message subject you want to send (templated)
message_attributes (dict) – the message attributes you want to send as a flat dict (data type will be determined automatically)