airflow.providers.amazon.aws.operators.sqs
¶
Publish message to SQS queue
Module Contents¶
Classes¶
Publish a message to an Amazon SQS queue. |
|
This operator is deprecated. |
- class airflow.providers.amazon.aws.operators.sqs.SqsPublishOperator(*, sqs_queue, message_content, message_attributes=None, delay_seconds=0, aws_conn_id='aws_default', **kwargs)[source]¶
Bases:
airflow.models.BaseOperator
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
- Parameters
sqs_queue (str) – The SQS queue url (templated)
message_content (str) – The message content (templated)
message_attributes (Optional[dict]) – additional attributes for the message (default: None) For details of the attributes parameter see
botocore.client.SQS.send_message()
delay_seconds (int) – message delay (templated) (default: 1 second)
aws_conn_id (str) – AWS connection id (default: aws_default)
- class airflow.providers.amazon.aws.operators.sqs.SQSPublishOperator(*args, **kwargs)[source]¶
Bases:
SqsPublishOperator
This operator is deprecated. Please use
airflow.providers.amazon.aws.operators.sqs.SqsPublishOperator
.