We\u2019re excited to announce the public preview of the Azure Cosmos DB SDK for Rust, a native Rust SDK that enables developers to interact with Azure Cosmos DB for NoSQL accounts from their Rust applications.<\/p>\n
Following the release of Azure SDK for Rust Beta<\/a>, the Azure Cosmos DB Rust SDK provides an idiomatic API for performing operations on databases, containers, and items. With this release, Rust developers can now build high-performance, scalable applications using Azure Cosmos DB.<\/p>\n Rust is an excellent choice for modern application development due to its focus on performance, memory safety, and concurrency. Rust eliminates common bugs such as null pointer dereferences and buffer overflows through its powerful ownership model. Additionally, Rust\u2019s strong type system and borrow checker ensure thread safety, making it ideal for building reliable, concurrent applications at scale. With its growing ecosystem and support for WebAssembly, Rust is increasingly becoming a go-to language for performance-critical workloads, cloud services, and distributed systems like Azure Cosmos DB.<\/p>\n Prerequisites:<\/strong><\/p>\n To run a Rust program using the Azure Cosmos DB SDK, follow these steps:<\/p>\n For the samples below, create the following dependencies in Cargo.toml:<\/p>\n To interact with Azure Cosmos DB, you need an account. You can create one using the Azure portal<\/a>, Azure CLI, or Azure Resource Manager templates. If you don\u2019t have an Azure Subscription, you can create a free trial account<\/a> or use the Azure Cosmos DB Emulator<\/a>.<\/p>\n Once you have an account, you can create a client using To retrieve a database, use the To retrieve a container, use To insert an item into a container, use <\/p>\n To read an item, use You can perform queries using SQL-like syntax:<\/p>\n The Azure Cosmos DB client library for Rust enables developers to build highly available applications with Azure Cosmos DB. Check out our samples repository<\/a> and follow the quickstart guide<\/a> to get started. Find out more about the Azure SDK for Rust Beta here<\/a>.<\/p>\n We welcome feedback! If you have questions or suggestions, please report issues on our GitHub repository<\/a>. We look forward to seeing what you build with Azure Cosmos DB and Rust!<\/p>\n Azure Cosmos DB is a fully managed and serverless NoSQL and vector database for modern app development, including AI applications. With its SLA-backed speed and availability as well as instant dynamic scalability, it is ideal for real-time NoSQL and MongoDB applications that require high performance and distributed computing over massive volumes of NoSQL and vector data.<\/p>\n Try Azure Cosmos DB for free here.<\/a> To stay in the loop on Azure Cosmos DB updates, follow us on X<\/a>, YouTube<\/a>, and LinkedIn<\/a>.<\/p>\n","protected":false},"excerpt":{"rendered":" We\u2019re excited to announce the public preview of the Azure Cosmos DB SDK for Rust, a native Rust SDK that enables developers to interact with Azure Cosmos DB for NoSQL accounts from their Rust applications. Following the release of Azure SDK for Rust Beta, the Azure Cosmos DB Rust SDK provides an idiomatic API for […]<\/p>\n","protected":false},"author":9387,"featured_media":9610,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"_acf_changed":false,"footnotes":""},"categories":[14],"tags":[940],"class_list":["post-9557","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-core-sql-api","tag-rust"],"acf":[],"blog_post_summary":" We\u2019re excited to announce the public preview of the Azure Cosmos DB SDK for Rust, a native Rust SDK that enables developers to interact with Azure Cosmos DB for NoSQL accounts from their Rust applications. Following the release of Azure SDK for Rust Beta, the Azure Cosmos DB Rust SDK provides an idiomatic API for […]<\/p>\n","_links":{"self":[{"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/posts\/9557","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/users\/9387"}],"replies":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/comments?post=9557"}],"version-history":[{"count":0,"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/posts\/9557\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/media\/9610"}],"wp:attachment":[{"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/media?parent=9557"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/categories?post=9557"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cosmosdb\/wp-json\/wp\/v2\/tags?post=9557"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}Getting started<\/h3>\n
\n
Running a Rust program<\/h3>\n
\n
cargo new cosmosdb-example\r\ncd cosmosdb-example<\/code><\/pre>\n<\/li>\ncargo install azure_data_cosmos\r\ncargo install azure_identity<\/code><\/pre>\n<\/li>\nsrc\/main.rs<\/code> with your Rust program.<\/li>\ncargo run<\/code><\/pre>\n<\/li>\n<\/ol>\n<\/h3>\n
Installing dependencies<\/h3>\n
[dependencies]\r\nazure_data_cosmos = \"0.22.0\"\r\nazure_identity = \"0.22.0\"\r\nazure_core = \"0.22.0\"<\/span>\r\nclap = { version = \"4.3\", features = [\"derive\"] }\r\ntracing = \"0.1\" \r\ntokio = { version = \"1\", features = [\"full\"] } # for async support\r\ntracing-subscriber = { version = \"0.3\", features = [\"env-filter\"] }\r\nserde = { version = \"1.0\", features = [\"derive\"] } # For JSON serialization\/deserialization\r\nserde_json = \"1.0\" # For working with JSON data\r\nfutures = \"0.3\" <\/code><\/pre>\nCreating a client<\/h3>\n
CosmosClient::new<\/code> and authenticate using either the DefaultAzureCredential<\/code> (recommended) or an account key.<\/p>\nUse DefaultAzureCredential for authentication (recommended)<\/h4>\n
DefaultAzureCredential<\/code> provides authentication using Microsoft Entra ID (formerly Azure Active Directory) and is the recommended approach for production and development scenarios.<\/p>\nuse azure_core::StatusCode;\r\nuse azure_data_cosmos::{CosmosClient, PartitionKey};\r\nuse azure_identity::DefaultAzureCredential;\r\nuse serde::Serialize;\r\nuse futures::StreamExt;\r\nuse std::env;\r\nuse tokio;\r\n\r\n#[tokio::main(flavor = \"current_thread\")]\r\nasync fn main() -> Result<(), Box<dyn std::error::Error>> {\r\n let credential = DefaultAzureCredential::new().unwrap();\r\n let client = CosmosClient::new(\"myCosmosAccount\", credential, None)?;\r\n\r\n println!(\"Cosmos client initialized successfully\");\r\n\r\n Ok(())\r\n}<\/code><\/pre>\nRetrieve a database<\/h3>\n
database_client<\/code> method on client<\/code>:<\/p>\n\/\/ must exist - create database not supported in Entra ID\r\nlet database = client.database_client(\"my-database\");<\/code><\/pre>\nCreating a container<\/h3>\n
container_client<\/code> on database<\/code>:<\/p>\n\/\/ must exist with myPartitionKey as partition key for examples below - create container not supported in Entra ID)\r\nlet container_client = database.container_client(\"my-container\");<\/code><\/pre>\nPerforming operations on items<\/h3>\n
Create an item<\/h4>\n
create_item<\/code>:<\/p>\n#[derive(Serialize)] \/\/ensure serde is in Cargo.toml as a dependency \r\nstruct Item {\r\n id: String,\r\n myPartitionKey: String,\r\n name: String,\r\n}\r\n\r\nlet item = Item {\r\n id: \"aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb\".to_string(),\r\n myPartitionKey: \"myPartitionKeyValue\".to_string(),\r\n name: \"Theo\".to_string(),\r\n};\r\n\r\nlet partition_key = PartitionKey::from(item.myPartitionKey.clone());\r\n\r\ncontainer_client.create_item(partition_key, item, None).await?;<\/code><\/pre>\nRead an item<\/h4>\n
read_item<\/code>:<\/p>\n\r\n\/\/ read item\r\nlet read_response = container_client\r\n .read_item(\"myPartitionKeyValue\", \"aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb\", None)\r\n .await;\r\nmatch read_response {\r\n Err(e) if e.http_status() == Some(StatusCode::NotFound) => println!(\"Item not found!\"),\r\n Ok(r) => {\r\n let item: serde_json::Value = r.into_json_body().await?;\r\n println!(\"Found item:\");\r\n println!(\"{:#?}\", item);\r\n }\r\n Err(e) => return Err(e.into()),\r\n};<\/code><\/pre>\nQuery items<\/h4>\n
\/\/ query items\r\nlet query = \"SELECT * FROM c\";\r\n\r\nlet pk = PartitionKey::from(\"myPartitionKeyValue\");\r\nlet mut items =\r\n container_client.query_items::<serde_json::Value>(&query.to_string(), pk, None)?;\r\n\r\nwhile let Some(page) = items.next().await {\r\n let page = page?.into_body().await?;\r\n println!(\"Query results page\");\r\n println!(\" Items:\");\r\n for item in page.items {\r\n println!(\" * {:#?}\", item);\r\n }\r\n}<\/code><\/pre>\nNext steps<\/h3>\n
About Azure Cosmos DB<\/h3>\n