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

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

.. py:module:: airflow.contrib.sensors.azure_cosmos_sensor


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

.. py:class:: AzureCosmosDocumentSensor(database_name, collection_name, document_id, azure_cosmos_conn_id='azure_cosmos_default', *args, **kwargs)

   Bases: :class:`airflow.sensors.base_sensor_operator.BaseSensorOperator`

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

   >>> azure_cosmos_sensor = AzureCosmosDocumentSensor(database_name="somedatabase_name",
   ...                            collection_name="somecollection_name",
   ...                            document_id="unique-doc-id",
   ...                            azure_cosmos_conn_id="azure_cosmos_default",
   ...                            task_id="azure_cosmos_sensor")

   .. attribute:: template_fields
      :annotation: = ['database_name', 'collection_name', 'document_id']

      

   
   .. method:: poke(self, context)