`airflow.contrib.sensors.mongo_sensor`¶

Module Contents¶

class airflow.contrib.sensors.mongo_sensor.MongoSensor(collection, query, mongo_conn_id='mongo_default', *args, **kwargs)[source]¶

Bases: airflow.sensors.base_sensor_operator.BaseSensorOperator

Checks for the existence of a document which matches the given query in MongoDB. Example:

>>> mongo_sensor = MongoSensor(collection="coll",
...                            query={"key": "value"},
...                            mongo_conn_id="mongo_default",
...                            task_id="mongo_sensor")

template_fields = ['collection', 'query'][source]¶

poke(self, context)[source]¶

Was this entry helpful?