airflow.providers.amazon.aws.notifications.sqs

模块内容

类

SqsNotifier

Amazon SQS（简单队列服务）通知器。

属性

send_sqs_notification

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)[源代码]

基类: airflow.notifications.basenotifier.BaseNotifier

Amazon SQS（简单队列服务）通知器。

另请参阅

有关如何使用此通知器的更多信息，请查看指南：Amazon 简单队列服务 (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（先进先出）队列。有关 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',...[源代码]
hook()[源代码]

Amazon SQS Hook (已缓存)。

notify(context)[源代码]

将通知消息发布到 Amazon SQS 队列。

airflow.providers.amazon.aws.notifications.sqs.send_sqs_notification[源代码]

此条目是否有帮助？