airflow.providers.amazon.aws.notifications.sqs¶

属性¶

send_sqs_notification

类¶

SqsNotifier

Amazon SQS (Simple Queue Service) 通知器。

模块内容¶

class airflow.providers.amazon.aws.notifications.sqs.SqsNotifier(*, aws_conn_id=SqsHook.default_conn_name, queue_url, message_body, message_attributes=None, message_group_id=None, delay_seconds=0, region_name=None)[source]¶

基类: airflow.providers.common.compat.notifier.BaseNotifier

Amazon SQS (Simple Queue Service) 通知器。

另请参阅

有关如何使用此通知器的更多信息，请参阅指南： Amazon Simple Queue Service (Amazon SQS) 通知操作指南

参数:

aws_conn_id (str | None) – 用于 AWS 凭证的 Amazon Web Services 连接 id。如果为 None 或为空，则使用默认的 boto3 行为。
queue_url (str) – 发送消息到的 Amazon SQS 队列的 URL。
message_body (str) – 要发送的消息。
message_attributes (dict | None) – 消息的附加属性。有关 attributes 参数的详细信息，请参阅 botocore.client.SQS.send_message()。
message_group_id (str | None) – 此参数仅适用于 FIFO (first-in-first-out) 队列。有关 attributes 参数的详细信息，请参阅 botocore.client.SQS.send_message()。
delay_seconds (int) – 延迟消息的时间长度，以秒为单位。
region_name (str | None) – AWS region_name。如果未指定，则使用默认的 boto3 行为。

template_fields: collections.abc.Sequence[str] = ('queue_url', 'message_body', 'message_attributes', 'message_group_id', 'delay_seconds',...[source]¶

aws_conn_id = 'aws_default'[source]¶

region_name = None[source]¶

queue_url[source]¶

message_body[source]¶

message_attributes[source]¶

message_group_id = None[source]¶

delay_seconds = 0[source]¶

property hook: airflow.providers.amazon.aws.hooks.sqs.SqsHook[source]¶

Amazon SQS Hook（已缓存）。

notify(context)[source]¶: 将通知消息发布到 Amazon SQS 队列。

airflow.providers.amazon.aws.notifications.sqs.send_sqs_notification[source]¶