:mod:`airflow.contrib.operators.sns_publish_operator` ===================================================== .. py:module:: airflow.contrib.operators.sns_publish_operator Module Contents --------------- .. py:class:: SnsPublishOperator(target_arn, message, aws_conn_id='aws_default', *args, **kwargs) Bases: :class:`airflow.models.BaseOperator` Publish a message to Amazon SNS. :param aws_conn_id: aws connection to use :type aws_conn_id: str :param target_arn: either a TopicArn or an EndpointArn :type target_arn: str :param message: the default message you want to send (templated) :type message: str .. attribute:: template_fields :annotation: = ['message'] .. attribute:: template_ext :annotation: = [] .. method:: execute(self, context)