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。