다음을 통해 공유

快速入门：适用于 Node.js 的 Azure Cosmos DB for Table 库

  • 아티클

适用对象： 表

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

API 参考文档 | 库源代码 | 包 (npm) | Azure Developer CLI

先决条件

初始化项目

使用 Azure Developer CLI (azd) 创建 Azure Cosmos DB for Table 帐户并部署容器化示例应用程序。 示例应用程序使用客户端库来管理、创建、读取和查询示例数据。

  1. 在空目录中打开终端。

  2. 如果尚未经过身份验证，请使用 azd auth login 向 Azure Developer CLI 进行身份验证。 按照该工具指定的步骤，使用首选 Azure 凭据向 CLI 进行身份验证。

    azd auth login

  3. 使用 azd init 来初始化项目。

    azd init --template cosmos-db-table-nodejs-quickstart

  4. 在初始化期间，配置唯一的环境名称。

  5. 使用 azd up 部署 Azure Cosmos DB 帐户。 Bicep 模板还部署示例 Web 应用程序。

    azd up

  6. 在预配过程中，选择订阅、所需位置和目标资源组。 等待预配过程完成。 此过程可能需要大约 5 分钟。

  7. 预配 Azure 资源后，输出中将包含指向正在运行的 Web 应用程序的 URL。

    Deploying services (azd deploy)

  (✓) Done: Deploying service web
- Endpoint: <https://[container-app-sub-domain].azurecontainerapps.io>

SUCCESS: Your application was provisioned and deployed to Azure in 5 minutes 0 seconds.

  8. 使用控制台中的 URL 在浏览器中导航到 Web 应用程序。 观察正在运行的应用的输出。

    正在运行的 Web 应用程序的屏幕截图。

安装客户端库

客户端库可通过 npm 作为 @azure/data-tables 包使用。

  1. 打开终端并导航到 /src/ts 文件夹。

    cd ./src/ts

  2. 使用 npm install 安装 @azure/data-tables 包（如果尚未安装）。

    npm install --save @azure/data-tables

  3. 打开并查看 src/ts/package.json 文件以验证 @azure/data-tables 条目是否存在。

  1. 打开终端并导航到 /src/js 文件夹。

    cd ./src/js

  2. 使用 npm install 安装 @azure/data-tables 包（如果尚未安装）。

    npm install --save @azure/data-tables

  3. 打开并查看 src/js/package.json 文件以验证 @azure/data-tables 条目是否存在。

对象模型

名称 描述
TableServiceClient 此类型是主要客户端类型，用于管理帐户范围的元数据或数据库。
TableClient 此类型表示帐户中表的客户端。

代码示例

模板中的示例代码使用名为 cosmicworks-products 的表。 cosmicworks-products 表包含每个产品的详细信息，例如名称、类别、数量、价格、唯一标识符和销售标志。 容器使用唯一标识符*作为行键，使用类别作为分区键。

验证客户端

此示例创建 TableServiceClient 类型的新实例。

let client: TableServiceClient = new TableServiceClient("<azure-cosmos-db-table-account-endpoint>", credential);

let client = new TableServiceClient("<azure-cosmos-db-table-account-endpoint>", credential);

获取表

此示例使用 TableServiceClient 类型的 GetTableClient 函数创建 TableClient 类型的实例。

let table: TableClient = new TableClient("<azure-cosmos-db-table-account-endpoint>", "<azure-cosmos-db-table-name>", credential);

let table = new TableClient("<azure-cosmos-db-table-account-endpoint>", "<azure-cosmos-db-table-name>", credential);

创建项

在表中新建项目的最简单方法是从 TableEntity 中派生出一个新接口，然后创建该类型的新对象。

export interface Product extends TableEntity {
    name: string;
    quantity: number;
    price: number;
    clearance: boolean;
}

const entity: Product = {
    rowKey: '70b63682-b93a-4c77-aad2-65501347265f',
    partitionKey: 'gear-surf-surfboards',
    name: 'Yamba Surfboard',
    quantity: 12,
    price: 850.00,
    clearance: false
};

在表中新建项目的最简单方法是构建 JSON 对象。

const entity = {
    rowKey: '70b63682-b93a-4c77-aad2-65501347265f',
    partitionKey: 'gear-surf-surfboards',
    name: 'Yamba Surfboard',
    quantity: 12,
    price: 850.00,
    clearance: false
};

使用 upsertEntity 实例中的 TableService 方法在集合中创建一个项目。

await table.upsertEntity<Product>(entity, "Replace"); 

await table.upsertEntity(entity, "Replace");

获取项

可以使用 getEntity 方法、项目的行键和项目的分区键从表中检索特定项目。

const response: GetTableEntityResponse<TableEntityResult<Product>> = await table.getEntity<Product>(partitionKey, rowKey);

const entity: Product = response as Product;

const entity = await table.getEntity(partitionKey, rowKey);

查询项

插入项目后，还可以通过使用带有 OData 筛选器的 listEntities 来运行查询以获取与特定筛选器匹配的所有项目。

const partitionKey: string = 'gear-surf-surfboards';

const filter: string = `PartitionKey eq '${partitionKey}'`

const queryOptions: TableEntityQueryOptions = { filter: filter }

const entities: PagedAsyncIterableIterator<TableEntityResult<Product>, TableEntityResultPage<Product>> = table.listEntities<Product>({ queryOptions: queryOptions });

const partitionKey = 'gear-surf-surfboards';

const entities = table.listEntities({
    queryOptions: {
        filter: `PartitionKey eq '${partitionKey}'`
    }
});

通过对 entities 的分页集使用异步 for await 循环来解析查询的分页结果。

for await(const entity of entities) {
    // Do something
}

for await(const entity of entities) {
    // Do something
}

清理资源

不再需要示例应用程序或资源时，请删除相应的部署和所有资源。

azd down

相关内容