airflow.providers.microsoft.azure.operators.cosmos¶

類¶

AzureCosmosInsertDocumentOperator

將新文件插入指定的 Cosmos 資料庫和集合中。

模組內容¶

class airflow.providers.microsoft.azure.operators.cosmos.AzureCosmosInsertDocumentOperator(*, database_name, collection_name, document, azure_cosmos_conn_id='azure_cosmos_default', **kwargs)[source]¶

基類: airflow.models.BaseOperator

將新文件插入指定的 Cosmos 資料庫和集合中。

如果資料庫和集合尚不存在，則會自動建立它們。

引數:

database_name (str) – 資料庫的名稱。(模板化的)
collection_name (str) – 集合的名稱。(模板化的)
document (dict) – 要插入的文件
azure_cosmos_conn_id (str) – 對 Azure CosmosDB 連線的引用。

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

ui_color = '#e4f0e8'[source]¶

database_name[source]¶

collection_name[source]¶

document[source]¶

azure_cosmos_conn_id = 'azure_cosmos_default'[source]¶

execute(context)[source]¶

建立運算子時派生。

上下文是與渲染 jinja 模板時使用的相同的字典。

有關更多上下文，請參閱 get_template_context。