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

将消息发布到 SNS 队列。

模块内容¶

类¶

SnsPublishOperator

将消息发布到 Amazon SNS。

class airflow.providers.amazon.aws.operators.sns.SnsPublishOperator(*, target_arn, message, subject=None, message_attributes=None, **kwargs)[源代码]¶

基类: airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator[airflow.providers.amazon.aws.hooks.sns.SnsHook]

将消息发布到 Amazon SNS。

另请参阅

有关如何使用此操作符的更多信息，请查看指南：将消息发布到现有的 SNS 主题

参数

target_arn (str) – TopicArn 或 EndpointArn
message (str) – 您要发送的默认消息 (可使用 Jinja 模板)
subject (str | None) – 您要发送的消息主题 (可使用 Jinja 模板)
message_attributes (dict | None) – 您要发送的消息属性，以扁平字典的形式 (数据类型将自动确定)
aws_conn_id – 用于 AWS 凭证的 Airflow 连接。如果此值为 None 或为空，则使用默认的 boto3 行为。如果在分布式方式下运行 Airflow，并且 aws_conn_id 为 None 或为空，则将使用默认的 boto3 配置（并且必须在每个工作节点上维护）。
region_name – AWS 区域名称。如果未指定，则使用默认的 boto3 行为。
verify – 是否验证 SSL 证书。请参阅： https://boto3.amazonaws.com/v1/documentation/api/latest/reference/core/session.html
botocore_config – botocore 客户端的配置字典 (键值对)。请参阅： https://botocore.amazonaws.com/v1/documentation/api/latest/reference/config.html

aws_hook_class[源代码]¶

template_fields: collections.abc.Sequence[str][源代码]¶

template_fields_renderers[源代码]¶

execute(context)[源代码]¶

在创建操作符时派生。

上下文与渲染 Jinja 模板时使用的字典相同。

有关更多上下文，请参阅 get_template_context。

airflow.providers.amazon.aws.operators.sns¶

模块内容¶

类¶

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