Azure Cosmos DB for NoSQL SDK を使用して複数のドキュメントを一括移動する

一括操作を実行する方法を学習する最も簡単な方法は、クラウド内の Azure Cosmos DB for NoSQL アカウントに多くのドキュメントをプッシュしてみることです。 SDK の一括機能を使用すると、System.Threading.Tasks 名前空間のわずかな助けを借りてこれを行うことができます。

このラボでは、NuGet の Bogus ライブラリを使用して架空のデータを生成し、それを Azure Cosmos DB アカウントに配置します。

開発環境を準備する

このラボで作業している環境に DP-420 のラボコードのリポジトリをまだクローンしていない場合は、次の手順に従ってクローンします。それ以外の場合は、以前にクローンしたフォルダーを Visual Studio Code で開きます。

Visual Studio Code を起動します。

📝 Visual Studio Code インターフェイスについてまだよく理解していない場合は、作業の開始に関するドキュメントをご覧ください
コマンドパレットを開き、Git: Clone を実行して、任意のローカルフォルダーに https://github.com/microsoftlearning/dp-420-cosmos-db-dev GitHub リポジトリをクローンします。

💡 Ctrl + Shift + P キーボードショートカットを使用してコマンドパレットを開くことができます。
リポジトリが複製されたら、Visual Studio Code で選択したローカルフォルダーを開きます。

Azure Cosmos DB for NoSQL アカウントを作成し、SDK プロジェクトを構成する

新しい Web ブラウザーウィンドウまたはタブで、Azure portal (portal.azure.com) に移動します。
ご利用のサブスクリプションに関連付けられている Microsoft 資格情報を使用して、ポータルにサインインします。

[+ リソースの作成] を選択し、Cosmos DB を検索して、新しい Azure Cosmos DB for NoSQL アカウントリソースを作成します。以下を設定して、残りの設定はすべて既定値のままにします。

設定	Value
サブスクリプション	’‘既存の Azure サブスクリプション’’
リソースグループ	’‘既存のリソースグループを選択するか、新しいものを作成します’’
アカウント名	’‘グローバルに一意の名前を入力します’’
場所	’‘使用可能なリージョンを選びます’’
容量モード	プロビジョニング済みスループット
Apply Free Tier Discount (Free レベル割引の適用)	適用しない

📝 ご利用のラボ環境には、新しいリソースグループを作成できない制限が存在する場合があります。その場合は、事前に作成されている既存のリソースグループを使用します。

デプロイタスクが完了するまで待ってから、このタスクを続行してください。
新しく作成された Azure Cosmos DB アカウントリソースに移動し、 [キー] ペインに移動します。
このペインには、SDK からアカウントに接続するために必要な接続の詳細と資格情報が含まれています。具体的な内容は次のとおりです。
1. [URI] フィールドに注目します。このエンドポイントの値は、この演習で後ほど使用します。
2. [主キー] フィールドに注目してください。このキーの値は、この演習で後ほど使用します。
引き続き、新しく作成された Azure Cosmos DB アカウントリソース内で、[データエクスプローラー] ペインに移動します。

[データエクスプローラー] で、[新しいコンテナー] を選択してから、次の設定で新しいコンテナーを作成します。残りの設定はすべて既定値のままにします。

設定	Value
データベース ID	新規作成 \| `cosmicworks`
コンテナー間でスループットを共有する	選択しない
コンテナー ID	`products`
パーティションキー	`/categoryId`
コンテナーのスループット	自動スケーリング \| `4000`

Visual Studio Code に戻ります。
[エクスプローラー] ウィンドウで、08-sdk-bulk フォルダーを参照します。
08-sdk-bulk フォルダー内の script.cs コードファイルを開きます。

📝 [Microsoft.Azure.Cosmos][nuget.org/packages/microsoft.azure.cosmos/3.22.1] ライブラリは、既に NuGet から事前にインポートされています。
endpoint という名前の string 変数を見つけます。その値を、先ほど作成した Azure Cosmos DB アカウントのエンドポイントに設定します。
```
 string endpoint = "<cosmos-endpoint>";
```
📝 たとえば、ご自分のエンドポイントが https://dp420.documents.azure.com:443/ の場合、C# ステートメントは string endpoint = “https://dp420.documents.azure.com:443/”; になります。
key という名前の string 変数を見つけます。その値を、先ほど作成した Azure Cosmos DB アカウントのキーに設定します。
```
 string key = "<cosmos-key>";
```
📝 たとえば、キーが fDR2ci9QgkdkvERTQ== の場合、C# ステートメントは string key = “fDR2ci9QgkdkvERTQ==”; になります。
script.cs コードファイルを保存します。
08-sdk-bulk フォルダーのコンテキストメニューを開き、[統合ターミナルで開く] を選択して新しいターミナルインスタンスを開きます。

📝 このコマンドを実行すると、開始ディレクトリが 08-sdk-bulk フォルダーに既に設定されているターミナルが開きます。
次のコマンドを使用して、NuGet から Microsoft.Azure.Cosmos (nuget.org/packages/microsoft.azure.cosmos/3.22.1) パッケージを追加します。
```
 dotnet add package Microsoft.Azure.Cosmos --version 3.22.1
```
dotnet build コマンドを使用してプロジェクトをビルドします。
```
 dotnet build
```
統合ターミナルを閉じます。

25,000 ドキュメントの一括挿入

“がんばって” 多くのドキュメントを挿入してみて、このしくみを確認しましょう。内部テストでは、ラボ仮想マシンと Azure Cosmos DB for NoSQL アカウントが互いに地理的に比較的近い場合、これには約 1 分から 2 分かかる場合があります。

script.cs コードファイルのエディタータブに戻ります。
AllowBulkExecution プロパティが true の値に設定された options クラスという名前の CosmosClientOptions の新しいインスタンスを作成します。
```
 CosmosClientOptions options = new () 
 { 
     AllowBulkExecution = true 
 };
```
コンストラクターパラメーターとして endpoint、key、および options 変数を渡して、client という名前の CosmosClient クラスの新しいインスタンスを作成します。
```
 CosmosClient client = new (endpoint, key, options); 
```
client 変数の GetContainer メソッドを使用し、データベースの名前 (cosmicworks) とコンテナーの名前 (products) を使って既存のコンテナーを取得します。
```
 Container container = client.GetContainer("cosmicworks", "products");
```
この特殊なサンプルコードを使用して、NuGet からインポートされた Bogus ライブラリの Faker クラスを使用して 25,000 の架空の製品を生成します。
```
 List<Product> productsToInsert = new Faker<Product>()
     .StrictMode(true)
     .RuleFor(o => o.id, f => Guid.NewGuid().ToString())
     .RuleFor(o => o.name, f => f.Commerce.ProductName())
     .RuleFor(o => o.price, f => Convert.ToDouble(f.Commerce.Price(max: 1000, min: 10, decimals: 2)))
     .RuleFor(o => o.categoryId, f => f.Commerce.Department(1))
     .Generate(25000);
```
💡 Bogus ライブラリは、ユーザーインターフェイスアプリケーションをテストするために架空のデータを設計するために使用されるオープンソースライブラリであり、一括インポート/エクスポートアプリケーションの開発方法を学習するために最適です。
concurrentTasks という名前の Task 型の新しいジェネリック List<> を作成します。
```
 List<Task> concurrentTasks = new List<Task>();
```
このアプリケーションで以前に生成された製品の一覧を反復処理する foreach ループを作成します。
```
 foreach(Product product in productsToInsert)
 {
 }
```
foreach ループ内に、Azure Cosmos DB for NoSQL に製品を非同期的に挿入する Task を作成します。必ず、パーティションキーを明示的に指定し、concurrentTasks という名前のタスクの一覧にタスクを追加してください。
```
 concurrentTasks.Add(
     container.CreateItemAsync(product, new PartitionKey(product.categoryId))
 );   
```
foreach ループの後、concurrentTasks 変数の Task.WhenAll の結果を非同期的に待ちます。
```
 await Task.WhenAll(concurrentTasks);
```
組み込みの Console.WriteLine 静的メソッドを使用して、Bulk tasks complete の静的メッセージをコンソールに出力します。
```
 Console.WriteLine("Bulk tasks complete");
```

完了すると、コードファイルが次のようになるはずです。

 using System;
 using System.Collections.Generic;
 using System.Threading.Tasks;
 using Bogus;
 using Microsoft.Azure.Cosmos;
    
 string endpoint = "<cosmos-endpoint>";
 string key = "<cosmos-key>";
    
 CosmosClientOptions options = new () 
 { 
     AllowBulkExecution = true 
 };
    
 CosmosClient client = new (endpoint, key, options);  
    
 Container container = client.GetContainer("cosmicworks", "products");
    
 List<Product> productsToInsert = new Faker<Product>()
     .StrictMode(true)
     .RuleFor(o => o.id, f => Guid.NewGuid().ToString())
     .RuleFor(o => o.name, f => f.Commerce.ProductName())
     .RuleFor(o => o.price, f => Convert.ToDouble(f.Commerce.Price(max: 1000, min: 10, decimals: 2)))
     .RuleFor(o => o.categoryId, f => f.Commerce.Department(1))
     .Generate(25000);
        
 List<Task> concurrentTasks = new List<Task>();
    
 foreach(Product product in productsToInsert)
 {    
     concurrentTasks.Add(
         container.CreateItemAsync(product, new PartitionKey(product.categoryId))
     );
 }
    
 await Task.WhenAll(concurrentTasks);   

 Console.WriteLine("Bulk tasks complete");

script.cs コードファイルを保存します。
Visual Studio Code で、08-sdk-bulk フォルダーのコンテキストメニューを開き、[統合ターミナルで開く] を選択して新しいターミナルインスタンスを開きます。
dotnet run コマンドを使用して、プロジェクトをビルドして実行します。
```
 dotnet run
```
アプリケーションは自動的に実行されるはずです。実行されて自動的に完了するまで、約 1 分から 2 分かかります。
統合ターミナルを閉じます。

結果を確認する

これで、Azure Cosmos DB に 25,000 項目を送信しました。次はデータエクスプローラーを見てみましょう。

1.Web ブラウザーに戻り、[データエクスプローラー] ウィンドウに移動します。

[データエクスプローラー] で、cosmicworks データベースノードを展開して、NOSQL API ナビゲーションツリー内の products コンテナーノードを確認します。
products ノードを展開してから、[項目] ノードを選択します。コンテナー内の項目の一覧を確認します。
NoSQL API ナビゲーションツリー内の products コンテナーノードを選んでから、[新しい SQL クエリ] を選択します。
エディター領域のコンテンツを削除します。
一括操作を使用して作成されたすべてのドキュメントの数を返す新しい SQL クエリを作成します。
```
 SELECT COUNT(1) FROM items
```
[クエリの実行] を選択します。
コンテナー内の項目の数を確認します。
Web ブラウザーのウィンドウまたはタブを閉じます。