airflow.contrib.sensors.aws_sqs_sensor
¶
Module Contents¶
-
class
airflow.contrib.sensors.aws_sqs_sensor.
SQSSensor
(sqs_queue, aws_conn_id='aws_default', max_messages=5, wait_time_seconds=1, *args, **kwargs)[source]¶ Bases:
airflow.sensors.base_sensor_operator.BaseSensorOperator
Get messages from an SQS queue and then deletes the message from the SQS queue. If deletion of messages fails an AirflowException is thrown otherwise, the message is pushed through XCom with the key
message
.- Parameters