为Azure Data Explorer创建IoT Hub数据连接

1. 在Azure Data Explorer群集的左侧菜单中，选择Databases然后选择包含目标表的数据库。

   

2. 选择“数据连接”，然后选择“添加数据连接”。 从下拉列表中选择IoT Hub。

   

3. 请使用以下信息填写表格。

   设置	字段说明
   数据连接名称	要在Azure Data Explorer中创建的连接的名称
   订阅	事件中心资源所在的订阅 ID。
   IoT Hub	IoT Hub名称
   共享访问策略	共享访问策略的名称。 必须有读取权限
   消费者组	在 IoT Hub 内置终结点中定义的消费者组
   事件系统属性	IoT Hub事件系统属性。 添加系统属性时，需要create或update表格模式和mapping，以包括所选属性。

   

   注意事项

   • 单记录事件的系统属性得到了支持。
   • 在 CSV 映射中，属性被添加到记录的开头。 对于 JSON 映射，将根据下拉列表中显示的名称添加属性。

4. 可能需要根据用例启用多数据库路由。 有关数据库路由的详细信息，请参阅事件路由。

   Azure Data Explorer Web UI 的屏幕截图，显示数据路由设置选项被设置为“允许”。

5. 填写以下路由设置：

   设置	建议的值	字段说明
   表名	TestTable	在“testdb”中创建的表。
   数据格式	JSON	支持的格式为 AVRO、CSV、JSON、ORC、PARQUET、PSV、SCSV、SOHSV、TSV、TXT、TSVE、APACHE AVRO 和 W3CLOG。
   映射	TestMapping	在 testdb 中创建的 映射会将传入的数据映射为 testdb 的列名称和数据类型。 如果未指定，将使用从表的模式派生的 identity 数据映射。

   Azure Data Explorer Web UI 的截图，显示了目标表格中的默认路由设置。

   注意事项

   • 默认情况下，JSON 数据默认解析为 multijson。
   • 如果选择了“事件系统属性”，则表架构和映射中必须包含系统属性。

6. 选择“创建” 。

以下示例演示用于添加IoT Hub数据连接的Azure Resource Manager模板。 可以使用表单edit 并在 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')]"
            }
        }
    ]
}