airflow.providers.amazon.aws.hooks.sns

This module contains AWS SNS hook.

Module Contents

Classes

SnsHook

Interact with Amazon Simple Notification Service.
class airflow.providers.amazon.aws.hooks.sns.SnsHook(*args, **kwargs)[source]

Bases: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

Interact with Amazon Simple Notification Service.

Provide thin wrapper around boto3.client("sns").

Additional arguments (such as aws_conn_id) may be specified and are passed down to the underlying AwsBaseHook.

See also

publish_to_target(target_arn, message, subject=None, message_attributes=None)[source]

Publish a message to a SNS topic or an endpoint.

See also

Parameters

  • target_arn (str) – either a TopicArn or an EndpointArn

  • message (str) – the default message you want to send

  • subject (str | None) – subject of message

  • message_attributes (dict | None) –

    additional attributes to publish for message filtering. This should be a flat dict; the DataType to be sent depends on the type of the value:

    • bytes = Binary

    • str = String

    • int, float = Number

    • iterable = String.Array

Was this entry helpful?