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[源]¶