docs-archive/1.10.13/_sources/_api/airflow/contrib/sensors/mongo_sensor/index.rst.txt

: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)