airflow.providers.microsoft.azure.sensors.cosmos¶

類¶

AzureCosmosDocumentSensor

檢查 CosmosDB 中是否存在與給定查詢匹配的文件。

模組內容¶

類 airflow.providers.microsoft.azure.sensors.cosmos.AzureCosmosDocumentSensor(*, database_name, collection_name, document_id, azure_cosmos_conn_id='azure_cosmos_default', **kwargs)[source]¶

基類: airflow.sensors.base.BaseSensorOperator

檢查 CosmosDB 中是否存在與給定查詢匹配的文件。

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",
)

引數：

database_name (str) – 目標 CosmosDB 資料庫名稱。
collection_name (str) – 目標 CosmosDB 集合名稱。
document_id (str) – 目標文件的 ID。
azure_cosmos_conn_id (str) – 對Azure CosmosDB 連線的引用。

template_fields: collections.abc.Sequence[str] = ('database_name', 'collection_name', 'document_id')[source]¶

azure_cosmos_conn_id = 'azure_cosmos_default'[source]¶

database_name[source]¶

collection_name[source]¶

document_id[source]¶

poke(context)[source]¶

派生此類時重寫此方法。