airflow.providers.amazon.aws.hooks.sqs

此模块包含 AWS SQS hook。

类

SqsHook

与 Amazon Simple Queue Service 交互。

模块内容

class airflow.providers.amazon.aws.hooks.sqs.SqsHook(*args, **kwargs)[source]

基类: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

与 Amazon Simple Queue Service 交互。

提供围绕 boto3.client("sqs") 的精简封装。

可以指定其他参数（例如 aws_conn_id），这些参数将传递给底层的 AwsBaseHook。

参阅

create_queue(queue_name, attributes=None)[source]

使用连接对象创建队列。

参阅

参数:

  • queue_name (str) – 队列名称。

  • attributes (dict | None) – 队列的其他属性（默认值: None）

返回:

包含队列信息的字典。

返回类型:

dict

send_message(queue_url, message_body, delay_seconds=0, message_attributes=None, message_group_id=None, message_deduplication_id=None)[source]

发送消息到队列。

参阅

参数:

  • queue_url (str) – 队列 URL

  • message_body (str) – 消息内容

  • delay_seconds (int) – 消息延迟秒数

  • message_attributes (dict | None) – 消息的其他属性（默认值: None）

  • message_group_id (str | None) – 仅适用于 FIFO（先进先出）队列。（默认值: None）

  • message_deduplication_id (str | None) – 仅适用于 FIFO（先进先出）队列。

返回:

包含已发送消息信息的字典

返回类型:

dict

此条目是否有用？