クイックスタート: MongoDB ドライバーで Node.js 用の Azure Cosmos DB for MongoDB vCore を使用する

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. まず、OIDCCallbackParamsとTokenCredentialを受け取り、OIDCResponseを非同期的に返すAzureIdentityTokenCallbackという名前のコールバックを定義します。

   const AzureIdentityTokenCallback = async (params: OIDCCallbackParams, credential: TokenCredential): Promise<OIDCResponse> => {
       const tokenResponse: AccessToken | null = await credential.getToken(['https://ossrdbms-aad.database.windows.net/.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. クラスター名と、Azure Cosmos DB for MongoDB 仮想コアの既知のベスト プラクティス構成オプションを使用して、 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.windows.net/.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. クラスター名と、Azure Cosmos DB for MongoDB 仮想コアの既知のベスト プラクティス構成オプションを使用して、 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);