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

此條目是否有用？