tasks = new List(); foreach (var item in itemsToUpsert) { tasks.Add(container.UpsertItemAsync(item, new PartitionKey(item.PartitionKey))); } await Task.WhenAll(tasks); Internally the SDK groups operations by partition key, packs them into micro-batches that fit within the 2 MB request limit and 100-operation transactional batch limit, and dispatches multiple batches concurrently. It handles 429 retries with the retry-after delay automatically so your code does not need to implement backoff logic manually. For Java and Python SDKs, similar bulk APIs exist. In Java the CosmosBulkOperations builder pattern is used. Bulk mode is best for initial data loads, migrations, large backfills, or any scenario where you need to insert or update tens of thousands of items quickly."> tasks = new List(); foreach (var item in itemsToUpsert) { tasks.Add(container.UpsertItemAsync(item, new PartitionKey(item.PartitionKey))); } await Task.WhenAll(tasks); Internally the SDK groups operations by partition key, packs them into micro-batches that fit within the 2 MB request limit and 100-operation transactional batch limit, and dispatches multiple batches concurrently. It handles 429 retries with the retry-after delay automatically so your code does not need to implement backoff logic manually. For Java and Python SDKs, similar bulk APIs exist. In Java the CosmosBulkOperations builder pattern is used. Bulk mode is best for initial data loads, migrations, large backfills, or any scenario where you need to insert or update tens of thousands of items quickly." />

Prev Next

Database / Azure Cosmos DB interview questions

What is the Cosmos DB Bulk Executor and how do you use bulk operations in the SDK?

Bulk operations in Azure Cosmos DB allow you to send multiple create, upsert, replace, delete, or read operations in a single SDK call that the library optimizes internally — batching by partition, retrying 429 throttles automatically, and maximizing throughput by saturating available RU/s concurrently. This is far more efficient than issuing individual operations in a loop because each individual await creates a round-trip overhead and underutilizes provisioned throughput.

In the v3 .NET SDK, bulk execution is enabled by setting AllowBulkExecution = true on the CosmosClientOptions. Once enabled, you can create a list of tasks and await them all together — the SDK transparently groups them into optimized batches per partition:

CosmosClient client = new CosmosClient(endpoint, key,
    new CosmosClientOptions { AllowBulkExecution = true });

Container container = client.GetContainer("mydb", "mycontainer");

List<Task> tasks = new List<Task>();
foreach (var item in itemsToUpsert)
{
    tasks.Add(container.UpsertItemAsync(item, new PartitionKey(item.PartitionKey)));
}

await Task.WhenAll(tasks);

Internally the SDK groups operations by partition key, packs them into micro-batches that fit within the 2 MB request limit and 100-operation transactional batch limit, and dispatches multiple batches concurrently. It handles 429 retries with the retry-after delay automatically so your code does not need to implement backoff logic manually.

For Java and Python SDKs, similar bulk APIs exist. In Java the CosmosBulkOperations builder pattern is used. Bulk mode is best for initial data loads, migrations, large backfills, or any scenario where you need to insert or update tens of thousands of items quickly.

How do you enable bulk execution mode in the Cosmos DB v3 .NET SDK?
What does the Cosmos DB SDK automatically handle in bulk mode that you would otherwise need to code yourself?

Invest now in Acorns!!! 🚀 Join Acorns and get your $5 bonus!

Invest now in Acorns!!! 🚀
Join Acorns and get your $5 bonus!

Earn passively and while sleeping

Acorns is a micro-investing app that automatically invests your "spare change" from daily purchases into diversified, expert-built portfolios of ETFs. It is designed for beginners, allowing you to start investing with as little as $5. The service automates saving and investing. Disclosure: I may receive a referral bonus.

Invest now!!! Get Free equity stock (US, UK only)!

Use Robinhood app to invest in stocks. It is safe and secure. Use the Referral link to claim your free stock when you sign up!.

The Robinhood app makes it easy to trade stocks, crypto and more.


Webull! Receive free stock by signing up using the link: Webull signup.

More Related questions...

What is Azure Cosmos DB and what problems does it solve? What are the different APIs available in Azure Cosmos DB? What is a partition key in Azure Cosmos DB and why is choosing it correctly so important? What are Request Units (RU/s) in Azure Cosmos DB? What are the five consistency levels in Azure Cosmos DB? How does global distribution work in Azure Cosmos DB? What is the Cosmos DB Change Feed and what are its main use cases? What is provisioned throughput vs autoscale vs serverless in Cosmos DB? How does indexing work in Azure Cosmos DB? What is Time to Live (TTL) in Cosmos DB and how do you configure it? What is a stored procedure in Cosmos DB and what are its limitations? What is the difference between a point read and a query in Cosmos DB? What is the Cosmos DB NoSQL query language and how does it differ from standard SQL? What is the Cosmos DB transactional batch API? What is Cosmos DB Integrated Cache and how does it reduce RU consumption? How does optimistic concurrency work in Azure Cosmos DB? What is hierarchical partition keys in Cosmos DB and when do you use it? What is the Cosmos DB Bulk Executor and how do you use bulk operations in the SDK? What are Cosmos DB triggers and user-defined functions (UDFs)? How does Cosmos DB handle conflicts in multi-region write (multi-master) setups? What is the Cosmos DB Emulator and how is it used in development? What is Cosmos DB for MongoDB API and what version compatibility does it provide? What is the Cosmos DB analytical store and Azure Synapse Link? What are Cosmos DB materialized views and how do they differ from containers? How does Cosmos DB pricing work and what are the key cost drivers? What is the Cosmos DB Gremlin API and what is it optimized for? How does Cosmos DB backup and restore work? What is the Cosmos DB Patch API and how does it differ from Replace? What is the Cosmos DB Cassandra API and how does CQL map to Cosmos DB concepts? How do you model one-to-many relationships in Cosmos DB? What is the Cosmos DB free tier and what does it include? What is the Cosmos DB SDK and what are the key client configuration options? What is the Cosmos DB Table API and when would you migrate from Azure Table Storage to it? How does Cosmos DB handle security and access control?


Comments & Discussions