Amazon Simple Notification Service (SNS)¶
Amazon Simple Notification Service (Amazon SNS) 是一项托管服务,提供从发布者到订阅者(也称为生产者和消费者)的消息传递。发布者通过将消息发送到主题(一个逻辑访问点和通信通道)与订阅者异步通信。客户端可以订阅 SNS 主题并使用支持的端点类型接收发布的消息,例如 Amazon Kinesis Data Firehose、Amazon SQS、AWS Lambda、HTTP、电子邮件、移动推送通知和手机短信 (SMS)。
先决条件任务¶
要使用这些运算符,您必须执行以下几项操作
使用 AWS Console 或 AWS CLI 创建必要的资源。
通过 pip 安装 API 库。
pip install 'apache-airflow[amazon]'详细信息请参阅 安装 Airflow®
设置连接.
通用参数¶
- aws_conn_id
引用 Amazon Web Services Connection ID。如果此参数设置为
None
,则使用默认的 boto3 行为,不进行连接查找。否则,使用 Connection 中存储的凭据。默认值:aws_default
- region_name
AWS 区域名称。如果此参数设置为
None
或省略,则使用 AWS Connection 额外参数中的 region_name。否则,使用指定的值而非连接中的值。默认值:None
- verify
是否验证 SSL 证书。
False
- 不验证 SSL 证书。path/to/cert/bundle.pem - 要使用的 CA 证书捆绑包文件名。如果您想使用与 botocore 使用的不同 CA 证书捆绑包,可以指定此参数。
如果此参数设置为
None
或省略,则使用 AWS Connection 额外参数中的 verify。否则,使用指定的值而非连接中的值。默认值:None
- botocore_config
提供的字典用于构建 botocore.config.Config。此配置可用于配置 避免节流异常、超时等。
例如,有关参数的更多详细信息,请参阅 botocore.config.Config¶{ "signature_version": "unsigned", "s3": { "us_east_1_regional_endpoint": True, }, "retries": { "mode": "standard", "max_attempts": 10, }, "connect_timeout": 300, "read_timeout": 300, "tcp_keepalive": True, }
如果此参数设置为
None
或省略,则使用 AWS Connection 额外参数中的 config_kwargs。否则,使用指定的值而非连接中的值。默认值:None
注意
指定空字典
{}
将覆盖 botocore.config.Config 的连接配置。
运算符¶
发布消息到现有 SNS 主题¶
要发布消息到 Amazon SNS 主题,您可以使用 SnsPublishOperator
。
tests/system/amazon/aws/example_sns.py
publish_message = SnsPublishOperator(
task_id="publish_message",
target_arn=create_sns_topic,
message="This is a sample message sent to SNS via an Apache Airflow DAG task.",
)