airflow.providers.microsoft.azure.sensors.azure_cosmos

Module Contents

class airflow.providers.microsoft.azure.sensors.azure_cosmos.AzureCosmosDocumentSensor(*, database_name: str, collection_name: str, document_id: str, azure_cosmos_conn_id: str = 'azure_cosmos_default', **kwargs)[source]

Bases: airflow.sensors.base.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”)

Parameters

  • database_name (str) – Target CosmosDB database_name.

  • collection_name (str) – Target CosmosDB collection_name.

  • document_id (str) – The ID of the target document.

  • azure_cosmos_conn_id (str) – Reference to the Azure CosmosDB connection.

template_fields = ['database_name', 'collection_name', 'document_id'][source]
poke(self, context: dict)[source]

Was this entry helpful?