airflow.providers.amazon.aws.notifications.sns¶

属性¶

send_sns_notification

类¶

SnsNotifier

Amazon SNS（简单通知服务）通知器。

模块内容¶

class airflow.providers.amazon.aws.notifications.sns.SnsNotifier(*, aws_conn_id=SnsHook.default_conn_name, target_arn, message, subject=None, message_attributes=None, region_name=None)[源]¶

基类: airflow.providers.common.compat.notifier.BaseNotifier

Amazon SNS（简单通知服务）通知器。

另请参阅

有关如何使用此通知器的更多信息，请参阅指南： Amazon 简单通知服务 (Amazon SNS) 通知操作指南

参数:

aws_conn_id (str | None) – 用于 AWS 凭据的 Amazon Web Services 连接 ID。如果为 None 或为空，则使用默认的 boto3 行为。
target_arn (str) – TopicArn 或 EndpointArn。
message (str) – 您要发送的消息。
subject (str | None) – 您要发送的消息主题。
message_attributes (dict | None) – 您要发送的消息属性，作为扁平字典（数据类型将自动确定）。
region_name (str | None) – AWS 区域名称。如果未指定，则使用默认的 boto3 行为。

template_fields: collections.abc.Sequence[str] = ('target_arn', 'message', 'subject', 'message_attributes', 'aws_conn_id', 'region_name')[源]¶

aws_conn_id = 'aws_default'[源]¶

region_name = None[源]¶

target_arn[源]¶

message[源]¶

subject = None[源]¶

message_attributes = None[源]¶

属性 hook: airflow.providers.amazon.aws.hooks.sns.SnsHook[源]¶

Amazon SNS Hook (缓存的)。

notify(context)[源]¶: 将通知消息发布到 Amazon SNS。

airflow.providers.amazon.aws.notifications.sns.send_sns_notification[源]¶