airflow.providers.amazon.aws.hooks.sqs

此模块包含 AWS SQS hook。

模块内容

类

SqsHook

与 Amazon Simple Queue Service 交互。
class airflow.providers.amazon.aws.hooks.sqs.SqsHook(*args, **kwargs)[源代码]

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

使用连接对象创建队列。

另请参阅

参数

  • queue_name (str) – 队列的名称。

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

返回

包含队列信息的字典。

返回类型

dict

send_message(queue_url, message_body, delay_seconds=0, message_attributes=None, message_group_id=None)[源代码]

向队列发送消息。

另请参阅

参数

  • queue_url (str) – 队列 URL

  • message_body (str) – 消息内容

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

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

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

返回

包含有关发送消息信息的字典

返回类型

dict

此条目是否有帮助？