airflow.providers.amazon.aws.hooks.sns

此模块包含 AWS SNS 钩子。

模块内容

类

SnsHook

与 Amazon Simple Notification Service 交互。
class airflow.providers.amazon.aws.hooks.sns.SnsHook(*args, **kwargs)[源代码]

基类: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

与 Amazon Simple Notification Service 交互。

提供 boto3.client("sns") 的轻薄封装。

可以指定其他参数（例如 aws_conn_id），并且会传递到底层的 AwsBaseHook。

另请参阅

publish_to_target(target_arn, message, subject=None, message_attributes=None)[源代码]

将消息发布到 SNS 主题或端点。

另请参阅

参数

  • target_arn (str) – TopicArn 或 EndpointArn

  • message (str) – 要发送的默认消息

  • subject (str | None) – 消息主题

  • message_attributes (dict | None) –

    发布消息过滤的附加属性。 这应该是一个扁平字典；要发送的 DataType 取决于值的类型

    • bytes = 二进制

    • str = 字符串

    • int, float = 数字

    • iterable = 字符串数组

此条目是否有帮助？