AzureCosmosInsertDocumentOperator
Microsoft AzureInserts a new document into the specified Cosmos database and collection It will create both the database and collection if they do not already exist
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_nameRequiredThe name of the database. (templated)
collection_nameRequiredThe name of the collection. (templated)
documentRequiredThe document to insert
azure_cosmos_conn_idReference to the Azure 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