airflow.providers.amazon.aws.hooks.sqs

This module contains AWS SQS hook.

Module Contents

Classes

SqsHook

Interact with Amazon Simple Queue Service.
class airflow.providers.amazon.aws.hooks.sqs.SqsHook(*args, **kwargs)[source]

Bases: airflow.providers.amazon.aws.hooks.base_aws.AwsBaseHook

Interact with Amazon Simple Queue Service.

Provide thin wrapper around boto3.client("sqs").

Additional arguments (such as aws_conn_id) may be specified and are passed down to the underlying AwsBaseHook.

See also

create_queue(queue_name, attributes=None)[source]

Create queue using connection object.

See also

Parameters

  • queue_name (str) – name of the queue.

  • attributes (dict | None) – additional attributes for the queue (default: None)

Returns

dict with the information about the queue.

Return type

dict

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

Send message to the queue.

See also

Parameters

  • queue_url (str) – queue url

  • message_body (str) – the contents of the message

  • delay_seconds (int) – seconds to delay the message

  • message_attributes (dict | None) – additional attributes for the message (default: None)

  • message_group_id (str | None) – This applies only to FIFO (first-in-first-out) queues. (default: None)

Returns

dict with the information about the message sent

Return type

dict

Was this entry helpful?