airflow.contrib.operators.sns_publish_operator

Module Contents

class airflow.contrib.operators.sns_publish_operator.SnsPublishOperator(target_arn, message, aws_conn_id='aws_default', *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)

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

Was this entry helpful?