airflow.providers.amazon.aws.hooks.sns¶

此模块包含 AWS SNS hook。

类¶

与 Amazon Simple Notification Service 交互。

模块内容¶

class airflow.providers.amazon.aws.hooks.sns.SnsHook(*args, **kwargs)[source]¶

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

与 Amazon Simple Notification Service 交互。

提供对 boto3.client("sns") 的轻量级封装。

可以指定额外参数（例如 aws_conn_id），这些参数会传递到底层的 AwsBaseHook。

另请参阅

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

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

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

另请参阅

SNS.Client.publish()

参数:

target_arn (str) – TopicArn 或 EndpointArn 之一
message (str) – 要发送的默认消息
subject (str | None) – 消息主题
message_attributes (dict | None) –
用于消息过滤的附加属性。这应该是一个扁平字典；发送的数据类型取决于值的类型
- bytes = Binary
- str = String
- int, float = Number
- iterable = String.Array

此条目是否有帮助？