快速入门：将 Azure Cosmos DB for NoSQL 与 Azure SDK for Rust 配合使用

在本快速入门中，你将使用 Azure SDK for Rust 部署基本的 Azure Cosmos DB for Table 应用程序。 Azure Cosmos DB for Table 是一种无架构数据存储，允许应用程序在云中存储结构化表数据。 你将了解如何使用 Azure SDK for Rust 在 Azure Cosmos DB 资源中创建表、行并执行基本任务。

API 参考文档 | 库源代码 | Crate (Rust) | Azure 开发人员 CLI

先决条件

• Docker Desktop
• Rust 1.80 或更高版本

如果没有 Azure 帐户，请在开始前创建一个免费帐户。

安装客户端库

客户端库可通过 Rust 作为 azure_data_cosmos Crate 使用。

1. 使用 cargo install 安装 azure_data_cosmos Crate（如果尚未安装）。

   cargo install azure_data_cosmos
   

2. 另请安装 azure_identity Crate（如果尚未安装）。

   cargo install azure_identity
   

对象模型

代码示例

• 对客户端进行身份验证
• 获取数据库
• 获取容器
• 创建项
• 获取项
• 查询项

模板中的示例代码使用名为 cosmicworks 的数据库和名为 products 的容器。 products 容器包含每个产品的名称、类别、数量、唯一标识符和销售标志等详细信息。 该容器使用 /category 属性作为逻辑分区键。

验证客户端

此示例使用 CosmosClient::new 创建一个新的 CosmosClient 实例并使用 DefaultAzureCredential 实例进行身份验证。

let credential = DefaultAzureCredential::new()?;

let client = CosmosClient::new(&endpoint, credential, None)?;

获取数据库

使用 client.database 检索名为 cosmicworks 的现有数据库。

let database = client.database_client("cosmicworks");

获取容器

使用 database.container 检索现有的 products 容器。

let container = database.container_client("products");

创建项

使用要序列化为 JSON 的所有成员构建一个新类型。 在此示例中，该类型具有唯一标识符以及用于类别、名称、数量、价格和销售的字段。 在此类型上派生 serde::Serialize 特征，以便它可序列化为 JSON。

use serde::{Deserialize, Serialize};

#[derive(Serialize, Deserialize)]
pub struct Item {
    pub id: String,
    pub category: String,
    pub name: String,
    pub quantity: i32,
    pub price: f64,
    pub clearance: bool,
}

使用 container.upsert_item 在容器中创建某个项。 此方法会“更新插入”该项，有效地替换该项（如果该项已存在）。

let item = Item {
    id: "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb".to_string(),
    category: "gear-surf-surfboards".to_string(),
    name: "Yamba Surfboard".to_string(),
    quantity: 12,
    price: 850.00,
    clearance: false,
};

let partition_key = PartitionKey::from(item.category.clone());
        
let partition_key = PartitionKey::from(item.category.clone());

container.upsert_item(partition_key, item.clone(), None).await?;

读取项

同时使用唯一标识符 (id) 和分区键字段来执行点读取操作。 使用 container.ReadItem 以有效检索特定项。

let item_id = "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb";
let item_partition_key = "gear-surf-surfboards";

let response = container.read_item(item_partition_key, item_id, None).await?;

let item: Item = response.into_json_body().await?;

查询项

使用 container.NewQueryItemsPager 对容器中的多个项执行查询。 使用此参数化查询查找指定类别中的所有项：

SELECT * FROM products p WHERE p.category = @category

let item_partition_key = "gear-surf-surfboards";

let query = Query::from("SELECT * FROM c WHERE c.category = @category")
    .with_parameter("@category", item_partition_key)?;

let mut pager = container.query_items::<Item>(query, item_partition_key, None)?;

while let Some(page_response) = pager.next().await {

    let page = page_response?.into_body().await?;

    for item in page.items {
        // Do something
    }

}

浏览数据

使用适用于 Azure Cosmos DB 的 Visual Studio Code 扩展来浏览 NoSQL 数据。 可以执行核心数据库操作，这些操作包括但不限于：

• 使用剪贴簿或查询编辑器执行查询
• 修改、更新、创建和删除项
• 从其他源导入批量数据
• 管理数据库和容器

有关详细信息，请参阅如何使用 Visual Studio Code 扩展来浏览 Azure Cosmos DB for NoSQL 数据。

相关内容

• .NET 快速入门
• Node.js 快速入门
• Java 快速入门
• Python 快速入门
• Go 快速入门

下一步