Publish message to a SQS queue.

View on GitHub

Last Updated: Jul. 19, 2021

Access Instructions

Install the Amazon provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.


sqs_queueRequiredstrThe SQS queue url (templated)
message_contentRequiredstrThe message content (templated)
message_attributesdictadditional attributes for the message (default: None) For details of the attributes parameter see botocore.client.SQS.send_message()
delay_secondsintmessage delay (templated) (default: 1 second)
aws_conn_idstrAWS connection id (default: aws_default)


Publish message to a SQS queue.

Was this page helpful?