airflow.providers.mongo.sensors.mongo

Module Contents

Classes

MongoSensor

Checks for the existence of a document which
class airflow.providers.mongo.sensors.mongo.MongoSensor(*, collection, query, mongo_conn_id='mongo_default', mongo_db=None, **kwargs)[source]

Bases: airflow.sensors.base.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",
...                            mongo_db="admin",
...                            task_id="mongo_sensor")
Parameters

  • collection (str) – Target MongoDB collection.

  • query (dict) – The query to find the target document.

  • mongo_conn_id (str) – The Mongo connection id to use when connecting to MongoDB.

  • mongo_db – Target MongoDB name.

template_fields: Sequence[str] = ('collection', 'query')[source]
poke(context)[source]

Function defined by the sensors while deriving this class should override.

Was this entry helpful?