Azure Cosmos DB から Azure Data Explorer にデータを取り込む

1. Azure portal でクラスターの概要ページに移動し、[作業の開始] タブを選択します。

2. [データ インジェスト] タイルで、[データ接続を作成する]>[Cosmos DB] を選択します。

   

3. Cosmos DB の [データ接続を作成する] ウィンドウで、フォームに次の表の情報を入力します。

   

   フィールド	説明
   データベース名	データを取り込む Azure Data Explorer データベースを選択します。
   データ接続名	データ接続の名前を指定します。
   サブスクリプション	Cosmos DB NoSQL アカウントを含むサブスクリプションを選択します。
   Cosmos DB アカウント	データの取り込み元となる Cosmos DB アカウントを選択します。
   SQL データベース	データの取り込み元となる Cosmos DB データベースを選択します。
   SQL コンテナー	データの取り込み元となる Cosmos DB コンテナーを選択します。
   テーブル名	データの取り込み先となる Azure Data Explorer のテーブル名を指定します。
   マッピング名	必要に応じて、データ接続に使用するマッピング名を指定します。

4. 必要に応じて、[詳細設定] セクションで、次の操作を実行します。

   1. [イベント取得の開始日] を指定します。 これは、コネクタがデータの取り込みを開始する時刻です。 時刻を指定しない場合、コネクタはデータ接続を作成した時点からデータの取り込みを開始します。 推奨される日付形式は ISO 8601 UTC 標準で、次のように指定します: yyyy-MM-ddTHH:mm:ss.fffffffZ。

   2. [ユーザー割り当て] を選択し、ID を選択します。 既定では、システム割り当てのマネージド ID が接続で使用されます。 必要に応じて、ユーザー割り当て の ID を使用できます。

      

5. [作成] を選択して、データ接続を作成します。

独自のデータ接続テンプレートを作成するための基礎として、次のサンプル ARM テンプレートを使用し、Azure portal でデプロイします。

Cosmos DB 接続を構成するには:

1. Cosmos DB 接続認証用にシステム マネージド ID を構成します。

   1. Azure Data Explorer Web UI で、左側のナビゲーション メニューから [クエリ] を選択し、データ接続用のクラスターまたはデータベースを選択します。

2. Cosmos DB アカウントにアクセスするためのデータ接続アクセス許可を付与します。 Cosmos DB へのデータ接続アクセスを提供することで、データベースにアクセスしてデータベースからデータを取得できます。 クラスターのプリンシパル ID が必要です。これは Azure portal で確認できます。 詳細については、クラスターのマネージド ID の構成に関する説明を参照してください。

   Note

   • 次の手順では、次のロールをプリンシパル ID に割り当てます。
     • Cosmos DB 組み込みデータ リーダー
       • Azure portal のロールの割り当て機能を使用して、Cosmos DB 組み込みデータ閲覧者ロールを割り当てることはできません。
     • Cosmos DB アカウントの閲覧者ロール

   Cosmos DB アカウントへのアクセスを許可するには、次のいずれかのオプションを使用します。

   • Azure CLI を使用してアクセス権を付与する: 次の表の情報を使用して CLI コマンドを実行し、プレースホルダーを適切な値に置き換えます。

     az cosmosdb sql role assignment create --account-name <CosmosDbAccountName> --resource-group <CosmosDbResourceGroup> --role-definition-id 00000000-0000-0000-0000-000000000001 --principal-id <ClusterPrincipalId> --scope "/"
     
     az role assignment create --role fbdf93bf-df7d-467e-a4d2-9458aa1360c8 --assignee <ClusterPrincipalId> --scope <CosmosDBAccountResourceId>
     

     プレースホルダー	説明
     <CosmosDBAccountName>	Cosmos DB アカウントの名前。
     <CosmosDBResourceGroup>	Cosmos DB アカウントを含むリソース グループの名前。
     <CosmosDBAccountResourceId>	Cosmos DB アカウントの Azure リソース ID (subscriptions/ で始まる)。
     <ClusterPrincipalId>	クラスターに割り当てられているマネージド ID のプリンシパル ID。 クラスターのプリンシパル ID は、Azure portal で確認できます。 詳細については、クラスターのマネージド ID の構成に関する説明を参照してください。

   • ARM テンプレートを使用してアクセス権を付与する: Cosmos DB アカウント リソース グループに次のテンプレートをデプロイします。

     {
         "$schema": "https://schema.management.azure.com/schemas/2019-04-01/deploymentTemplate.json#",
         "contentVersion": "1.0.0.0",
         "parameters": {
             "clusterPrincipalId": {
                 "type": "string",
                 "metadata": { "description": "The principle ID of your cluster." }
             },
             "cosmosDbAccount": {
                 "type": "string",
                 "metadata": { "description": "The name of your Cosmos DB account." }
             },
             "cosmosDbAccountResourceId": {
                 "type": "string",
                 "metadata": { "description": "The resource ID of your Cosmos DB account." }
             }
         },
         "variables": {
             "cosmosDataReader": "00000000-0000-0000-0000-000000000001",
             "dataRoleDefinitionId": "[format('/subscriptions/{0}/resourceGroups/{1}/providers/Microsoft.DocumentDB/databaseAccounts/{2}/sqlRoleDefinitions/{3}', subscription().subscriptionId, resourceGroup().name, parameters('cosmosDbAccount'), variables('cosmosDataReader'))]",
             "roleAssignmentId": "[guid(parameters('cosmosDbAccountResourceId'), parameters('clusterPrincipalId'))]",
             "rbacRoleDefinitionId": "[format('/subscriptions/{0}/providers/Microsoft.Authorization/roleDefinitions/{1}', subscription().subscriptionId, 'fbdf93bf-df7d-467e-a4d2-9458aa1360c8')]"
         },
         "resources": [
             {
                 "type": "Microsoft.DocumentDB/databaseAccounts/sqlRoleAssignments",
                 "apiVersion": "2022-08-15",
                 "name": "[concat(parameters('cosmosDbAccount'), '/', guid(parameters('clusterPrincipalId'), parameters('cosmosDbAccount')))]",
                 "properties": {
                     "principalId": "[parameters('clusterPrincipalId')]",
                     "roleDefinitionId": "[variables('dataRoleDefinitionId')]",
                     "scope": "[resourceId('Microsoft.DocumentDB/databaseAccounts', parameters('cosmosDbAccount'))]"
                 }
             },
             {
                 "type": "Microsoft.Authorization/roleAssignments",
                 "apiVersion": "2022-04-01",
                 "name": "[variables('roleAssignmentId')]",
                 "scope": "[format('Microsoft.DocumentDb/databaseAccounts/{0}', parameters('cosmosDbAccount'))]",
                 "properties": {
                     "description": "Giving RBAC reader on Cosmos DB",
                     "principalId": "[parameters('clusterPrincipalId')]",
                     "principalType": "ServicePrincipal",
                     "roleDefinitionId": "[variables('rbacRoleDefinitionId')]"
                 }
             }
         ]
     }
     

3. 次の ARM テンプレートをデプロイして、Cosmos DB データ接続を作成します。 プレースホルダーを適切な値に置き換えます。

   {
     "$schema": "https://schema.management.azure.com/schemas/2019-04-01/deploymentTemplate.json#",
     "contentVersion": "1.0.0.0",
     "parameters": {
       "kustoClusterName": {
         "type": "string",
         "metadata": { "description": "Kusto Cluster name" }
       },
       "kustoDbName": {
         "type": "string",
         "metadata": { "description": "Kusto Database name" }
       },
       "kustoConnectionName": {
         "type": "string",
         "metadata": { "description": "Kusto Database connection name" }
       },
       "kustoLocation": {
         "type": "string",
         "metadata": { "description": "Location (Azure Region) of the Kusto cluster" }
       },
       "kustoTable": {
         "type": "string",
         "metadata": { "description": "Kusto Table name where to ingest data" }
       },
       "kustoMappingRuleName": {
         "type": "string",
         "defaultValue": "",
         "metadata": { "description": "Mapping name of the Kusto Table (if omitted, default mapping is applied)" }
       },
       "managedIdentityResourceId": {
         "type": "string",
         "metadata": { "description": "ARM resource ID of the managed identity (cluster resource ID for system or user identity)" }
       },
       "cosmosDbAccountResourceId": {
         "type": "string",
         "metadata": { "description": "ARM resource ID of Cosoms DB account" }
       },
       "cosmosDbDatabase": {
         "type": "string",
         "metadata": { "description": "Cosmos DB Database name" }
       },
       "cosmosDbContainer": {
         "type": "string",
         "metadata": { "description": "Cosmos DB container name" }
       },
       "retrievalStartDate": {
         "type": "string",
         "defaultValue": "",
         "metadata": { "description": "Date-time at which to start the data retrieval; default: 'now' if not provided. Recommended format: yyyy-MM-ddTHH:mm:ss.fffffffZ" }
       }
     },
     "variables": { },
     "resources": [{
       "type": "Microsoft.Kusto/Clusters/Databases/DataConnections",
       "apiVersion": "2022-11-11",
       "name": "[concat(parameters('kustoClusterName'), '/', parameters('kustoDbName'), '/', parameters('kustoConnectionName'))]",
       "location": "[parameters('kustoLocation')]",
       "kind": "CosmosDb",
       "properties": {
         "tableName": "[parameters('kustoTable')]",
         "mappingRuleName": "[parameters('kustoMappingRuleName')]",
         "managedIdentityResourceId": "[parameters('managedIdentityResourceId')]",
         "cosmosDbAccountResourceId": "[parameters('cosmosDbAccountResourceId')]",
         "cosmosDbDatabase": "[parameters('cosmosDbDatabase')]",
         "cosmosDbContainer": "[parameters('cosmosDbContainer')]",
         "retrievalStartDate": "[parameters('retrievalStartDate')]"
       }
     }]
   }