airflow.providers.amazon.aws.hooks.sqs
¶
This module contains AWS SQS hook
Module Contents¶
-
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.
Additional arguments (such as
aws_conn_id
) may be specified and are passed down to the underlying AwsBaseHook.See also
-
create_queue
(self, queue_name: str, attributes: Optional[Dict] = None)[source]¶ Create queue using connection object
- Parameters
- Returns
dict with the information about the queue For details of the returned value see
SQS.create_queue()
- Return type
-
send_message
(self, queue_url: str, message_body: str, delay_seconds: int = 0, message_attributes: Optional[Dict] = None)[source]¶ Send message to the queue
- Parameters
- Returns
dict with the information about the message sent For details of the returned value see
botocore.client.SQS.send_message()
- Return type
-