SqsPublishOperator
AmazonPublish a message to an Amazon SQS queue.
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.
Parameters
sqs_queueRequiredThe SQS queue url (templated)
message_contentRequiredThe message content (templated)
message_attributesadditional attributes for the message (default: None) For details of the attributes parameter see botocore.client.SQS.send_message()
delay_secondsmessage delay (templated) (default: 1 second)
message_group_idThis parameter applies only to FIFO (first-in-first-out) queues. (default: None) For details of the attributes parameter see botocore.client.SQS.send_message()
aws_conn_idAWS connection id (default: aws_default)
Documentation
Publish a message to an Amazon SQS queue.
See also
For more information on how to use this operator, take a look at the guide: Publish a message to an Amazon SQS queue