Skip to content
Permalink
Branch: master
Find file Copy path
Find file Copy path
Fetching contributors…
Cannot retrieve contributors at this time
99 lines (86 sloc) 5.57 KB
title description author ms.author ms.reviewer ms.service ms.topic origin.date ms.date ms.openlocfilehash ms.sourcegitcommit ms.translationtype ms.contentlocale ms.lasthandoff ms.locfileid
使用 Python 为 Azure 数据资源管理器创建事件中心数据连接
本文介绍如何使用 Python 为 Azure 数据资源管理器创建事件中心数据连接。
lucygoldbergmicrosoft
v-tawe
orspodek
data-explorer
conceptual
10/07/2019
01/13/2020
8ec8ac800fcb49674fc0d387f63844104684965d
6fb55092f9e99cf7b27324c61f5fab7f579c37dc
HT
zh-CN
01/03/2020
75631109

使用 Python 为 Azure 数据资源管理器创建事件中心数据连接

[!div class="op_single_selector"]

Azure 数据资源管理器是一项快速且高度可缩放的数据探索服务,适用于日志和遥测数据。 Azure 数据资源管理器提供了从事件中心、IoT 中心和写入 blob 容器的 blob 引入数据(数据加载)的功能。 在本文中,你将使用 Python 为 Azure 数据资源管理器创建事件中心数据连接。

先决条件

[!INCLUDE data-explorer-data-connection-install-package-python]

[!INCLUDE data-explorer-authentication]

添加事件中心数据连接

以下示例演示如何以编程方式添加事件中心数据连接。 请参阅连接到事件中心,了解如何使用 Azure 门户添加事件中心数据连接。

from azure.mgmt.kusto import KustoManagementClient
from azure.mgmt.kusto.models import EventHubDataConnection
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 event hub that is created as part of the Prerequisites
event_hub_resource_id = "/subscriptions/xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx/resourceGroups/xxxxxx/providers/Microsoft.EventHub/namespaces/xxxxxx/eventhubs/xxxxxx";
consumer_group = "$Default";
location = "China East 2";
#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";
#Returns an instance of LROPoller, check https://docs.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=EventHubDataConnection(event_hub_resource_id=event_hub_resource_id, consumer_group=consumer_group, location=location,
                                                                            table_name=table_name, mapping_rule_name=mapping_rule_name, data_format=data_format))
设置 建议的值 字段说明
tenant_id xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx 租户 ID。 也称为目录 ID。
subscriptionId xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx 用于创建资源的订阅 ID。
client_id xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxx 可以访问租户中资源的应用程序的客户端 ID。
client_secret xxxxxxxxxxxxxx 可以访问租户中资源的应用程序的客户端密码。
resource_group_name testrg 包含群集的资源组的名称。
cluster_name mykustocluster 群集的名称。
database_name mykustodatabase 群集中目标数据库的名称。
data_connection_name myeventhubconnect 所需的数据连接名称。
table_name StormEvents 目标数据库中目标表的名称。
mapping_rule_name StormEvents_CSV_Mapping 与目标表相关的列映射的名称。
data_format csv 消息的数据格式。
event_hub_resource_id 资源 ID 包含要引入的数据的事件中心的资源 ID。
consumer_group $Default 事件中心的使用者组。
location 中国东部 2 数据连接资源的位置。

[!INCLUDE data-explorer-data-connection-clean-resources-python]

You can’t perform that action at this time.