Azure Data Explorer のIoT Hub データ接続を作成する

この記事では、ビッグ データのストリーミング プラットフォームとなる IoT インジェスト サービスである IoT Hub から Azure Data Explorer にデータを取り込む方法について説明します。

Azure portalまたは ARM テンプレートを使用して接続を作成する方法については、「IoT データ接続を作成する」を参照してください。

IoT Hub から Azure Data Explorer への取り込みに関する一般的な情報については、IoT Hub への接続に関する記事を参照してください。

注意

データ接続の作成後にエンキューされたイベントのみが取り込まれたます。

以前の SDK バージョンに基づくコード サンプルについては、 アーカイブされた記事を参照してください。

前提条件

• Azure サブスクリプション。 無料の Azure アカウントを作成します。
• Azure Data Explorer クラスターとデータベース。 クラスターとデータベースを作成します。
• 変換先テーブル。 テーブルを作成するか、 既存のテーブルを使用します。
• テーブルの インジェスト マッピング 。
• インジェスト用のデータを含むIoT Hub。

IoT Hub データ接続を作成する

このセクションでは、IoT Hubと Azure Data Explorer テーブルの間に接続を確立します。 この接続が確立されている限り、データはIoT Hubからターゲット テーブルに送信されます。

ポータル

1. Azure Data Explorer クラスターの左側のメニューで、[データベース] を選択し、ターゲット テーブルを含むデータベースを選択します。

   

2. [データ接続] 、 [データ接続の追加] の順に選択します。 ドロップダウンから [IoT Hub] を選択します。

   

3. フォームに次の情報を入力します。

   設定	フィールドの説明
   データ接続名	Azure Data Explorer で作成する接続の名前
   サブスクリプション	Event Hubs リソースが配置されているサブスクリプション ID。
   IoT Hub	IoT Hub 名
   共有アクセス ポリシー	共有アクセス ポリシーの名前。 読み取りアクセス許可が必要
   コンシューマー グループ	IoT Hub の組み込みのエンドポイントに定義されているコンシューマー グループ
   イベント システム プロパティ	IoT Hub イベントのシステム プロパティ。 システム プロパティを追加する場合は、テーブル スキーマとマッピングを作成または更新して、選択したプロパティを含めます。

   

   注意

   • イベント システム プロパティは、単一レコード イベントでサポートされています。
   • CSV マッピングの場合、プロパティはレコードの先頭に追加されます。 JSON マッピングの場合、ドロップダウン リストに表示される名前に従ってプロパティが追加されます。

4. ユース ケースによっては、マルチデータベース ルーティングを有効にすることもできます。 データベースのルーティングの詳細については、「イベント ルーティング」を参照してください。

   

5. 次のルーティング設定を入力します。

   設定	推奨値	フィールドの説明
   テーブル名	TestTable	testdb に作成したテーブル。
   データ形式	JSON	サポートされている形式は、AVRO、CSV、JSON、ORC、PARQUET、PSV、SCSV、SOHSV、TSV、TXT、TSVE、APACHE AVRO、W3CLOG です。
   マッピング	TestMapping	testdb に作成したマッピング。これにより、受信データを testdb の列名とデータ型にマッピングします。 指定されていない場合、テーブルのスキーマから派生した ID のデータ マッピングが使用されます。

   

   注意

   • JSON データは、既定で multijson として解析されます。 [ 形式エラーを無視 する] を選択して、厳密な JSON 形式でデータを取り込みます。
   • [イベント システム プロパティ] を選択した場合は、テーブル スキーマとマッピングにシステム プロパティを含める必要があります。

6. ［作成］ を選択します

警告

手動フェールオーバーの場合は、データ接続を再作成します。

ARM テンプレート

次の例は、IoT Hub データ接続を追加するための Azure Resource Manager テンプレートを示しています。 フォームを使用して、Azure portal でテンプレートの編集とデプロイを実行できます。

{
    "$schema": "https://schema.management.azure.com/schemas/2015-01-01/deploymentTemplate.json#",
    "contentVersion": "1.0.0.0",
    "parameters": {
        "IotHubs_iothubdemo_name": {
            "type": "string",
            "defaultValue": "iothubdemo",
            "metadata": {
                "description": "Specifies the IoT Hub name."
            }
        },
        "iothubpolices_iothubowner_name": {
            "type": "string",
            "defaultValue": "iothubowner",
            "metadata": {
                "description": "Specifies the shared access policy name."
            }
        },
        "consumergroup_default_name": {
            "type": "string",
            "defaultValue": "$Default",
            "metadata": {
                "description": "Specifies the consumer group of the IoT Hub."
            }
        },
        "Clusters_kustocluster_name": {
            "type": "string",
            "defaultValue": "kustocluster",
            "metadata": {
                "description": "Specifies the name of the cluster"
            }
        },
        "databases_kustodb_name": {
            "type": "string",
            "defaultValue": "kustodb",
            "metadata": {
                "description": "Specifies the name of the database"
            }
        },
        "tables_kustotable_name": {
            "type": "string",
            "defaultValue": "kustotable",
            "metadata": {
                "description": "Specifies the name of the table"
            }
        },
        "mapping_kustomapping_name": {
            "type": "string",
            "defaultValue": "kustomapping",
            "metadata": {
                "description": "Specifies the name of the mapping rule"
            }
        },
        "dataformat_type": {
            "type": "string",
            "defaultValue": "csv",
            "metadata": {
                "description": "Specifies the data format"
            }
        },
           "databaseRouting_type": {
            "type": "string",
            "defaultValue": "Single",
            "metadata": {
                "description": "The database routing for the connection. If you set the value to **Single**, the data connection will be routed to a single database in the cluster as specified in the *databaseName* setting. If you set the value to **Multi**, you can override the default target database using the *Database* EventData property."
            }
        },
        "dataconnections_kustodc_name": {
            "type": "string",
            "defaultValue": "kustodc",
            "metadata": {
                "description": "Name of the data connection to create"
            }
        },
        "subscriptionId": {
            "type": "string",
            "defaultValue": "[subscription().subscriptionId]",
            "metadata": {
                "description": "Specifies the subscriptionId of the IoT Hub"
            }
        },
        "resourceGroup": {
            "type": "string",
            "defaultValue": "[resourceGroup().name]",
            "metadata": {
                "description": "Specifies the resourceGroup of the IoT Hub"
            }
        },
        "location": {
            "type": "string",
            "defaultValue": "[resourceGroup().location]",
            "metadata": {
                "description": "Location for all resources."
            }
        }
    },
    "variables": {
    },
    "resources": [{
            "type": "Microsoft.Kusto/Clusters/Databases/DataConnections",
            "apiVersion": "2019-09-07",
            "name": "[concat(parameters('Clusters_kustocluster_name'), '/', parameters('databases_kustodb_name'), '/', parameters('dataconnections_kustodc_name'))]",
            "location": "[parameters('location')]",
            "kind": "IotHub",
            "properties": {
                "iotHubResourceId": "[resourceId(parameters('subscriptionId'), parameters('resourceGroup'), 'Microsoft.Devices/IotHubs', parameters('IotHubs_iothubdemo_name'))]",
                "consumerGroup": "[parameters('consumergroup_default_name')]",
                "sharedAccessPolicyName": "[parameters('iothubpolices_iothubowner_name')]",
                "tableName": "[parameters('tables_kustotable_name')]",
                "mappingRuleName": "[parameters('mapping_kustomapping_name')]",
                "dataFormat": "[parameters('dataformat_type')]",
                 "databaseRouting": "[parameters('databaseRouting_type')]"
            }
        }
    ]
}

IoT Hub データ接続を削除する

Azure portalからIoT Hub接続を削除するには、次の操作を行います。

1. クラスターに移動します。 左側のメニューから [データベース] を選択 します。 次に、ターゲット テーブルを含むデータベースを選択します。
2. 左側のメニューで、[ データ接続] を選択します。 次に、関連するIoT Hubデータ接続の横にあるチェック ボックスをオンにします。
3. 上部のメニュー バーで、[削除] を選択 します。

---

関連コンテンツ

• Azure Data Explorer の Web UI でデータのクエリを実行する