airflow.providers.amazon.aws.operators.sqs¶

向 SQS 队列发布消息。

类¶

SqsPublishOperator

向 Amazon SQS 队列发布消息。

模块内容¶

class airflow.providers.amazon.aws.operators.sqs.SqsPublishOperator(*, sqs_queue, message_content, message_attributes=None, delay_seconds=0, message_group_id=None, message_deduplication_id=None, **kwargs)[source]¶

基类: airflow.providers.amazon.aws.operators.base_aws.AwsBaseOperator[airflow.providers.amazon.aws.hooks.sqs.SqsHook]

向 Amazon SQS 队列发布消息。

另请参阅

有关如何使用此操作符的更多信息，请参阅指南：向 Amazon SQS 队列发布消息

参数:

sqs_queue (str) – SQS 队列 URL（模板化）
message_content (str) – 消息内容（模板化）
message_attributes (dict | None) – 消息的附加属性（默认：None）。有关属性参数的详细信息，请参阅 botocore.client.SQS.send_message()
delay_seconds (int) – 消息延迟（模板化）（默认：0 秒）
message_group_id (str | None) – 此参数仅适用于 FIFO（先进先出）队列。（默认：None）。有关属性参数的详细信息，请参阅 botocore.client.SQS.send_message()
message_deduplication_id (str | None) – 此参数仅适用于 FIFO（先进先出）队列。有关属性参数的详细信息，请参阅 botocore.client.SQS.send_message()
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[source]¶

template_fields: collections.abc.Sequence[str][source]¶

template_fields_renderers[source]¶

ui_color = '#6ad3fa'[source]¶

sqs_queue[source]¶

message_content[source]¶

delay_seconds = 0[source]¶

message_attributes[source]¶

message_group_id = None[source]¶

message_deduplication_id = None[source]¶

execute(context)[source]¶

将消息发布到 Amazon SQS 队列。

参数:: context (airflow.utils.context.Context) – 上下文对象
返回值:: 包含发送消息信息的字典。有关返回字典的详细信息，请参阅 botocore.client.SQS.send_message()
返回值类型:: dict