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

模块内容¶

类¶

SnsNotifier

Amazon SNS (简单通知服务) 通知器。

属性¶

send_sns_notification

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.notifications.basenotifier.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 region_name。如果未指定，则使用默认的 boto3 行为。

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

hook()[源代码]¶

Amazon SNS Hook (已缓存)。

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

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

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

模块内容¶

类¶

属性¶

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