AzureCosmosInsertDocumentOperator

Microsoft Azure

Inserts a new document into the specified Cosmos database and collection It will create both the database and collection if they do not already exist

View Source

Last Updated: May. 7, 2021

Access Instructions

Install the Microsoft Azure provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.

Parameters

database_namestrThe name of the database. (templated)
collection_namestrThe name of the collection. (templated)
documentdictThe document to insert
azure_cosmos_conn_idstrreference to a CosmosDB connection.

Documentation

Inserts a new document into the specified Cosmos database and collection It will create both the database and collection if they do not already exist

Was this page helpful?