MongoSensor
MongoChecks for the existence of a document which matches the given query in MongoDB. Example:
Access Instructions
Install the Mongo provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
collectionRequiredTarget MongoDB collection.
queryRequiredThe query to find the target document.
mongo_conn_idThe Mongo connection id to use when connecting to MongoDB.
mongo_dbTarget MongoDB name.
Documentation
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")