`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 数据库名称。
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')[源代码]¶

poke(context)[源代码]¶

在派生此类时重写。

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

模块内容¶

类¶

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