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

模組內容¶

類別¶

AzureCosmosDocumentSensor

檢查 CosmosDB 中是否存在符合指定查詢的文件。

class airflow.providers.microsoft.azure.sensors.cosmos.AzureCosmosDocumentSensor(*, database_name, collection_name, document_id, azure_cosmos_conn_id='azure_cosmos_default', **kwargs)[原始碼]¶

基底： 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 database_name。
collection_name (str) – 目標 CosmosDB collection_name。
document_id (str) – 目標文件的 ID。
azure_cosmos_conn_id (str) – 參考至 Azure CosmosDB 連線。

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

poke(context)[原始碼]¶

覆寫衍生類別時。

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

模組內容¶

類別¶

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