Azure Cosmos DB

Cosmos Database (DB) is a globally distributed, low latency, multi-model database for managing data at large scales. It is a cloud-based NoSQL database offered as a PaaS (Platform as a Service) from Microsoft Azure. It is a highly available, high throughput, reliable database and is often called a serverless database. Cosmos database contains the Azure Document DB and is available everywhere.

Azure Cosmos Document Sensor

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

tests/system/providers/microsoft/azure/example_azure_cosmosdb.py[source]

t1 = AzureCosmosDocumentSensor(
    task_id="check_cosmos_file",
    collection_name="airflow_example_coll",
    document_id="airflow_checkid",
    database_name="database_name",
)

Was this entry helpful?