为 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. 选择“创建” 。

1. 安装 Microsoft.Azure.Management.Kusto NuGet 包。

2. 创建用于身份验证的 Azure AD 应用程序主体。 需要目录（租户）ID、应用程序 ID 和客户端机密。

3. 运行以下代码。

   var tenantId = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"; //Directory (tenant) ID
   var clientId = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"; //Application ID
   var clientSecret = "PlaceholderClientSecret"; //Client Secret
   var subscriptionId = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx";
   var authClient = ConfidentialClientApplicationBuilder.Create(clientId)
       .WithAuthority($"https://login.microsoftonline.com/{tenantId}")
       .WithClientSecret(clientSecret)
       .Build();
   var result = authClient.AcquireTokenForClient(new[] { "https://management.core.windows.net/" }).ExecuteAsync().Result;
   var credentials = new TokenCredentials(result.AccessToken, result.TokenType);
   var kustoManagementClient = new KustoManagementClient(credentials) { SubscriptionId = subscriptionId };
   var resourceGroupName = "testrg";
   //The cluster and database that are created as part of the Prerequisites
   var clusterName = "mykustocluster";
   var databaseName = "mykustodatabase";
   var iotHubConnectionName = "myiothubconnect";
   //The IoT hub that is created as part of the Prerequisites
   var iotHubResourceId = "/subscriptions/<iotHubSubscriptionId>/resourceGroups/<iotHubResourceGroupName>/providers/Microsoft.Devices/IotHubs/<iotHubName>";
   var sharedAccessPolicyName = "iothubforread";
   var consumerGroup = "$Default";
   var ___location = "Central US";
   //The table and column mapping are created as part of the Prerequisites
   var tableName = "StormEvents";
   var mappingRuleName = "StormEvents_CSV_Mapping";
   var dataFormat = DataFormat.CSV;
   var databaseRouting = "Multi";
   var iotHubConnectionData = new IotHubDataConnection(
       iotHubResourceId, consumerGroup, sharedAccessPolicyName,
       tableName: tableName, ___location: ___location, mappingRuleName: mappingRuleName,
       dataFormat: dataFormat, databaseRouting: databaseRouting
   );
   await kustoManagementClient.DataConnections.CreateOrUpdateAsync(resourceGroupName, clusterName, databaseName, iotHubConnectionName, iotHubConnectionData);
   

   设置	建议的值	字段说明
   租户ID	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	租户 ID。 也称为目录 ID。
   订阅编号	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	用于创建资源的订阅 ID。
   clientId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	可以访问租户中资源的应用程序的客户端 ID。
   客户密钥	PlaceholderClientSecret	可以访问租户中资源的应用程序的客户端密码。
   资源组名称	testrg	包含群集的资源组的名称。
   集群名称	mykustocluster	群集的名称。
   数据库名称	mykustodatabase	群集中目标数据库的名称。
   iotHubConnectionName	myiothubconnect	所需的数据连接名称。
   表名	StormEvents	目标数据库中目标表的名称。
   映射规则名称	风暴事件_CSV_映射	与目标表相关的列映射的名称。
   数据格式	csv	消息的数据格式。
   iotHubResourceId	资源标识符	包含要引入的数据的 IoT 中心的资源 ID。
   共享访问策略名称	iothubforread	共享访问策略的名称，这些策略定义设备与服务连接到 IoT 中心所需的权限。
   消费者组	$Default	事件中心的使用者组。
   位置	美国中部	数据连接资源的位置。
   数据库路由	多选或单选	连接的数据库路由。 如果将该值设置为“单一”，则数据连接会根据 databaseName 设置中的指定被路由到群集中的一个数据库。 如果将值设置为 “多”，则可以使用 数据库引入属性替代默认目标数据库。 有关详细信息，请参阅 事件路由。

1. 安装所需的库。

   pip install azure-common
   pip install azure-mgmt-kusto
   

2. 创建用于身份验证的 Azure AD 应用程序主体。 需要目录（租户）ID、应用程序 ID 和客户端机密。

3. 运行以下代码。

   from azure.mgmt.kusto import KustoManagementClient
   from azure.mgmt.kusto.models import IotHubDataConnection
   from azure.common.credentials import ServicePrincipalCredentials
   
   #Directory (tenant) ID
   tenant_id = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"
   #Application ID
   client_id = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"
   #Client Secret
   client_secret = "xxxxxxxxxxxxxx"
   subscription_id = "xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx"
   credentials = ServicePrincipalCredentials(
           client_id=client_id,
           secret=client_secret,
           tenant=tenant_id
       )
   kusto_management_client = KustoManagementClient(credentials, subscription_id)
   
   resource_group_name = "testrg"
   #The cluster and database that are created as part of the Prerequisites
   cluster_name = "mykustocluster"
   database_name = "mykustodatabase"
   data_connection_name = "myeventhubconnect"
   #The IoT hub that is created as part of the Prerequisites
   iot_hub_resource_id = "/subscriptions/xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx/resourceGroups/xxxxxx/providers/Microsoft.Devices/IotHubs/xxxxxx";
   shared_access_policy_name = "iothubforread"
   consumer_group = "$Default"
   ___location = "Central US"
   #The table and column mapping that are created as part of the Prerequisites
   table_name = "StormEvents"
   mapping_rule_name = "StormEvents_CSV_Mapping"
   data_format = "csv"
   database_routing = "Multi"
   
   #Returns an instance of LROPoller, check https://learn.microsoft.com/python/api/msrest/msrest.polling.lropoller?view=azure-python
   poller = kusto_management_client.data_connections.create_or_update(resource_group_name=resource_group_name, cluster_name=cluster_name, database_name=database_name, data_connection_name=data_connection_name,
                                               parameters=IotHubDataConnection(iot_hub_resource_id=iot_hub_resource_id, shared_access_policy_name=shared_access_policy_name,
                                                                                   consumer_group=consumer_group, table_name=table_name, ___location=___location, mapping_rule_name=mapping_rule_name, data_format=data_format, database_routing=database_routing))
   

   设置	建议的值	字段说明
   租户ID	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	租户 ID。 也称为目录 ID。
   订阅编号	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	用于创建资源的订阅 ID。
   客户编号	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx	可以访问租户中资源的应用程序的客户端 ID。
   客户端密钥	xxxxxxxxxxx	可以访问租户中资源的应用程序的客户端密码。
   资源组名称	testrg	包含群集的资源组的名称。
   cluster_name	mykustocluster	群集的名称。
   数据库名称	mykustodatabase	群集中目标数据库的名称。
   数据连接名称	myeventhubconnect	所需的数据连接名称。
   表名	StormEvents	目标数据库中目标表的名称。
   映射规则名称	StormEvents_CSV_Mapping	与目标表相关的列映射的名称。
   数据格式	csv	消息的数据格式。
   iot_hub_resource_id	资源标识符	包含要引入的数据的 IoT 中心的资源 ID。
   共享访问策略名称	iothubforread	共享访问策略的名称，这些策略定义设备与服务连接到 IoT 中心所需的权限。
   消费者组	$Default	事件中心的使用者组。
   位置	美国中部	数据连接资源的位置。
   数据库路由	多选或单选	连接的数据库路由。 如果将该值设置为“单一”，则数据连接会根据 databaseName 设置中的指定被路由到群集中的一个数据库。 如果将值设置为 “多”，则可以使用 数据库引入属性替代默认目标数据库。 有关详细信息，请参阅 事件路由。

以下示例显示用于添加 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')]"
            }
        }
    ]
}

若要从 Azure 门户中删除 IoT 中心连接，请执行以下操作：

1. 转到你的群集。 在左侧菜单中选择“数据库”。 然后选择包含目标表的数据库。
2. 从左侧菜单选择“数据连接”。 然后，选中相关的 IoT 中心数据连接旁边的复选框。
3. 从顶部菜单栏中选择“删除”。

若要删除 IoT 中心连接，请运行以下命令：

kustoManagementClient.DataConnections.Delete(resourceGroupName, clusterName, databaseName, dataConnectionName);

若要删除 IoT 中心连接，请运行以下命令：

kusto_management_client.data_connections.delete(resource_group_name=resource_group_name, cluster_name=kusto_cluster_name, database_name=kusto_database_name, data_connection_name=kusto_data_connection_name)