为 Azure 数据资源管理器创建 IoT 中心数据连接

1. 在 Azure 数据资源管理器群集的左侧菜单中，选择“数据库”，然后选择包含目标表的数据库。

   

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

   

3. 使用以下信息填写窗体。

   设置	字段说明
   数据连接名称	要在 Azure 数据资源管理器中创建的连接的名称
   订阅	事件中心资源所在的订阅 ID。
   IoT 中心	IoT 中心名称
   共享访问策略	共享访问策略的名称。 必须有读取权限
   使用者组	在 IoT 中心的内置终结点中定义的使用者组
   事件系统属性	IoT 中心事件系统属性。 添加系统属性时，创建或更新表架构和映射以包括所选属性。

   

   注意

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

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

   

5. 填写以下路由设置：

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

   

   注意

   • 默认情况下，JSON 数据分析为 multijson。 选择“忽略格式错误”以引入采用严格 JSON 格式的数据。
   • 如果选择了“事件系统属性”，则表架构和映射中必须包含系统属性。

6. 选择“创建” 。

以下示例显示用于添加 IoT 中心数据连接的 Azure 资源管理器模板。 可以使用此窗体在 Azure 门户中编辑和部署模板。

{
    "$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')]"
            }
        }
    ]
}