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)

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']

template_ext = []

execute(self, context)