快速入门：将 Azure Cosmos DB for MongoDB (vCore) 与适用于 Node.js 的 MongoDB 驱动程序配合使用

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

   cd ./src/ts
   

2. 使用 mongodb 安装 npm install 包（如果尚未安装）。

   npm install --save mongodb
   

3. 使用 @azure/identity 安装 npm install 包（如果尚未安装）。

   npm install --save @azure/identity
   

4. 打开并查看 src/ts/package.json 文件，以验证这两个包条目是否存在。

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

   cd ./src/js
   

2. 使用 mongodb 安装 npm install 包（如果尚未安装）。

   npm install --save mongodb
   

3. 使用 @azure/identity 安装 npm install 包（如果尚未安装）。

   npm install --save @azure/identity
   

4. 打开并查看 src/js/package.json 文件，以验证这两个包条目是否存在。

将以下命名空间导入应用程序代码：

import { DefaultAzureCredential, TokenCredential } from '@azure/identity';

import { MongoClient } from 'mongodb';

将所有必需的类型导入应用程序代码，包括但不限于：

import { AccessToken, DefaultAzureCredential, TokenCredential } from '@azure/identity';

import { Collection, Db, Filter, FindCursor, MongoClient, OIDCCallbackParams, OIDCResponse, UpdateFilter, UpdateOptions, UpdateResult, WithId } from 'mongodb';

1. 首先，定义一个名为 AzureIdentityTokenCallback 的回调，该回调接收 OIDCCallbackParams 和 TokenCredential，然后异步返回一个 OIDCResponse。

   const AzureIdentityTokenCallback = async (params: OIDCCallbackParams, credential: TokenCredential): Promise<OIDCResponse> => {
       const tokenResponse: AccessToken | null = await credential.getToken(['https://ossrdbms-aad.database.chinacloudapi.cn/.default']);
       return {
           accessToken: tokenResponse?.token || '',
           expiresInSeconds: (tokenResponse?.expiresOnTimestamp || 0) - Math.floor(Date.now() / 1000)
       };
   };
   

2. 为群集名称和令牌凭据定义变量。

   const clusterName: string = '<azure-cosmos-db-mongodb-vcore-cluster-name>';
   
   const credential: TokenCredential = new DefaultAzureCredential();
   

3. 使用您的群集名称和适用于 MongoDB vCore 的 Azure Cosmos DB 已知最佳实践配置选项来构建 MongoClient 实例。 此外，请配置自定义身份验证机制。

   const client = new MongoClient(
       `mongodb+srv://${clusterName}.global.mongocluster.cosmos.azure.com/`, {
       connectTimeoutMS: 120000,
       tls: true,
       retryWrites: true,
       authMechanism: 'MONGODB-OIDC',
       authMechanismProperties: {
               OIDC_CALLBACK: (params: OIDCCallbackParams) => AzureIdentityTokenCallback(params, credential),
               ALLOWED_HOSTS: ['*.azure.com']
           }
       }
   );
   

1. 首先，定义一个回调 azureIdentityTokenCallback ，该回调采用参数和令牌凭据，然后异步返回响应。

   const azureIdentityTokenCallback = async (_, credential) => {
       const tokenResponse = await credential.getToken(['https://ossrdbms-aad.database.chinacloudapi.cn/.default']);
   
       if (!tokenResponse || !tokenResponse.token) {
           throw new Error('Failed to retrieve a valid access token.');
       }
   
       return {
           accessToken: tokenResponse.token,
           expiresInSeconds: Math.floor((tokenResponse.expiresOnTimestamp - Date.now()) / 1000),
       };
   };
   

2. 为群集名称和令牌凭据定义变量。

   const clusterName = '<azure-cosmos-db-mongodb-vcore-cluster-name>';
   
   const credential = new DefaultAzureCredential();
   

3. 使用您的群集名称和适用于 MongoDB vCore 的 Azure Cosmos DB 已知最佳实践配置选项来构建 MongoClient 实例。 此外，请配置自定义身份验证机制。

   client = new MongoClient(`mongodb+srv://${clusterName}.global.mongocluster.cosmos.azure.com/`, {
       connectTimeoutMS: 120000,
       tls: true,
       retryWrites: true,
       authMechanism: 'MONGODB-OIDC',
       authMechanismProperties: {
           OIDC_CALLBACK: (params) => azureIdentityTokenCallback(params, credential),
           ALLOWED_HOSTS: ['*.azure.com']
       }
   });
   
   await client.connect();
   

const database: Db = client.db("<database-name>");

const database = client.db("<database-name>");

此函数具有一个泛型参数，该参数使用接口中定义的 Product 类型。

const collection: Collection<Product> = database.collection<Product>("<collection-name>");

export interface Product {
    _id: string;
    category: string;
    name: string;
    quantity: number;
    price: number;
    clearance: boolean;
}

const collection = database.collection("<collection-name>");

var document: Product = {
    _id: 'aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb',
    category: 'gear-surf-surfboards',
    name: 'Yamba Surfboard',
    quantity: 12,
    price: 850.00,
    clearance: false
};

var query: Filter<Product> = {
    _id: 'aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb',
    category: 'gear-surf-surfboards'
};
var payload: UpdateFilter<Product> = {
    $set: document
};
var options: UpdateOptions = {
    upsert: true
};
var response: UpdateResult<Product> = await collection.updateOne(query, payload, options);

var document = {
    _id: 'aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb',
    category: 'gear-surf-surfboards',
    name: 'Yamba Surfboard',
    quantity: 12,
    price: 850.00,
    clearance: false
};

const query = {
    _id: 'aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb',
    category: 'gear-surf-surfboards'
};
const payload = {
    $set: document
};
const options = {
    upsert: true,
    new: true
};
var response = await collection.updateOne(query, payload, options);

var query: Filter<Product> = { 
    _id: 'aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb', 
    category: 'gear-surf-surfboards' 
};

var response: WithId<Product> | null = await collection.findOne(query);

var query = { 
    _id: 'aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb', 
    category: 'gear-surf-surfboards' 
};

var response = await collection.findOne(query);

var query: Filter<Product> = { 
    category: 'gear-surf-surfboards' 
};

var response: FindCursor<WithId<Product>> = collection.find(query);

for await (const item of response) {
    // Do something with each item
}

var query = { 
    category: 'gear-surf-surfboards' 
};

var response = collection.find(query);

for await (const item of response) {
    // Do something with each item
}

var filter: Filter<Product> = { 
    _id: 'aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb'
};

await collection.deleteOne(filter);

const filter = {
    _id: 'aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb'
};

await collection.deleteOne(filter);