:mod:`airflow.contrib.sensors.mongo_sensor`
===========================================

.. py:module:: airflow.contrib.sensors.mongo_sensor







Module Contents
---------------






.. py:class:: MongoSensor(collection, query, mongo_conn_id='mongo_default', *args, **kwargs)

   Bases::class:`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")


   

   

   .. attribute:: template_fields
      :annotation: = ['collection', 'query'] 

      



   

   

   

   .. method:: poke(self, context)