airflow.providers.amazon.aws.operators.sns

Publish message to SNS queue

Module Contents

class airflow.providers.amazon.aws.operators.sns.SnsPublishOperator(*, target_arn: str, message: str, aws_conn_id: str = 'aws_default', subject: Optional[str] = None, message_attributes: Optional[dict] = None, **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)

template_fields = ['message', 'subject', 'message_attributes'][source]
template_ext = [][source]
execute(self, context)[source]

Was this entry helpful?