`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)[源代码]¶

基类：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')[源代码]¶

ui_color = '#e4f0e8'[源代码]¶

execute(context)[源代码]¶

在创建操作符时派生。

上下文与渲染 Jinja 模板时使用的字典相同。

请参考 get_template_context 以获取更多上下文。

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

模块内容¶

类¶

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