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)

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

Was this entry helpful?