Azure Veri Gezgini için IoT Hub veri bağlantısı oluşturma

1. Azure Veri Gezgini kümenizin sol menüsünde Veritabanları'nı ve ardından hedef tablonuzu içeren veritabanını seçin.

   

2. Veri bağlantıları'nı ve Veri bağlantısı ekle'yi seçin. Açılan listeden IoT Hub'ı seçin.

   

3. Formu aşağıdaki bilgilerle doldurun.

   Ayar	Alan açıklaması
   Veri bağlantısı adı	Azure Veri Gezgini'da oluşturmak istediğiniz bağlantının adı
   Abonelik	Event Hubs kaynağının bulunduğu abonelik kimliği.
   IoT Hub	IoT Hub adı
   Paylaşılan erişim ilkesi	Paylaşılan erişim ilkesinin adı. Okuma izinlerine sahip olmalıdır
   Tüketici grubu	IoT Hub yerleşik uç noktasında tanımlanan tüketici grubu
   Olay sistemi özellikleri	IoT Hub olay sistemi özellikleri. Sistem özellikleri eklerken, tablo şemasını ve eşlemesini, seçili özellikleri içerecek şekilde oluşturun veya güncelleştirin.

   

   Not

   • Olay sistemi özellikleri tek kayıtlı olaylar için desteklenir.
   • CSV eşlemesi için özellikler kaydın başına eklenir. JSON eşlemesi için, özellikler açılan listede görünen ada göre eklenir.

4. Kullanım örneğine bağlı olarak, çok veritabanılı yönlendirmeyi açmak isteyebilirsiniz. Veritabanı yönlendirmesi hakkında daha fazla bilgi için bkz . Olay yönlendirme.

   

5. Aşağıdaki yönlendirme ayarlarını doldurun:

   Ayar	Önerilen değer	Alan açıklaması
   Tablo adı	TestTable	testdb'de oluşturduğunuz tablo.
   Veri biçimi	JSON	Desteklenen biçimler AVRO, CSV, JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHE AVRO ve W3CLOG'dur.
   Eşleme	TestMapping	Testdb'de oluşturduğunuz eşleme, gelen verileri testdb'nin sütun adlarına ve veri türlerine eşler. Belirtilmezse, tablonun şemasından türetilen bir kimlik veri eşlemesi kullanılır.

   

   Not

   • JSON verileri varsayılan olarak multijson olarak ayrıştırılır. Verileri katı JSON biçiminde almak için Biçim hatalarını yoksay'ı seçin.
   • Olay sistemi özelliklerini seçtiyseniz, sistem özelliklerini tablo şemasına ve eşlemesine eklemeniz gerekir.

6. Oluştur'u belirleyin.

1. Microsoft.Azure.Management.Kusto NuGet paketini yükleyin.

2. Kimlik doğrulaması için kullanılacak bir Azure AD uygulama sorumlusu oluşturun. Dizin (kiracı) kimliği, uygulama kimliği ve istemci gizli dizisi gerekir.

3. Aşağıdaki kodu çalıştırın.

   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);
   

   Ayar	Önerilen değer	Alan açıklaması
   tenantId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxx	Kiracı kimliğiniz. Dizin kimliği olarak da bilinir.
   subscriptionId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxx	Kaynak oluşturmak için kullandığınız abonelik kimliği.
   clientId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxx	Kiracınızdaki kaynaklara erişebilen uygulamanın istemci kimliği.
   clientSecret	PlaceholderClientSecret	Kiracınızdaki kaynaklara erişebilen uygulamanın istemci gizli dizisi.
   resourceGroupName	testrg	Kümenizi içeren kaynak grubunun adı.
   clusterName	mykustocluster	Kümenizin adı.
   veritabanıAdı	mykustodatabase	Kümenizdeki hedef veritabanının adı.
   iotHubConnectionName	myiothubconnect	Veri bağlantınızın istenen adı.
   tableName	StormEvents	Hedef veritabanındaki hedef tablonun adı.
   mappingRuleName	StormEvents_CSV_Mapping	Hedef tabloyla ilgili sütun eşlemenizin adı.
   dataFormat	csv	İletinin veri biçimi.
   iotHubResourceId	Kaynak Kimliği	IoT hub'ınızın veri alımı için gereken verileri tutan kaynak kimliği.
   sharedAccessPolicyName	iothubforread	IoT Hub'a bağlanmak için cihazların ve hizmetlerin izinlerini tanımlayan paylaşılan erişim ilkesinin adı.
   consumerGroup	$Default	Olay hub'ınızın tüketici grubu.
   konum	Central US	Veri bağlantısı kaynağının konumu.
   databaseRouting	Çoklu veya Tek	Bağlantı için veritabanı yönlendirmesi. Değeri Tek olarak ayarlarsanız, veri bağlantısı databaseName ayarında belirtildiği gibi kümedeki tek bir veritabanına yönlendirilir. Değeri Multi olarak ayarlarsanız, Veritabanı alımı özelliğini kullanarak varsayılan hedef veritabanını geçersiz kılabilirsiniz. Daha fazla bilgi için bkz . Olay yönlendirme.

1. Gerekli kitaplıkları yükleyin.

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

2. Kimlik doğrulaması için kullanılacak bir Azure AD uygulama sorumlusu oluşturun. Dizin (kiracı) kimliği, uygulama kimliği ve istemci gizli dizisi gerekir.

3. Aşağıdaki kodu çalıştırın.

   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://video2.skills-academy.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))
   

   Ayar	Önerilen değer	Alan açıklaması
   tenant_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxx	Kiracı kimliğiniz. Dizin kimliği olarak da bilinir.
   subscriptionId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxx	Kaynak oluşturmak için kullandığınız abonelik kimliği.
   client_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxxxxxxxx	Kiracınızdaki kaynaklara erişebilen uygulamanın istemci kimliği.
   client_secret	xxxxxxxxxxx	Kiracınızdaki kaynaklara erişebilen uygulamanın istemci gizli dizisi.
   resource_group_name	testrg	Kümenizi içeren kaynak grubunun adı.
   cluster_name	mykustocluster	Kümenizin adı.
   database_name	mykustodatabase	Kümenizdeki hedef veritabanının adı.
   data_connection_name	myeventhubconnect	Veri bağlantınızın istenen adı.
   table_name	StormEvents	Hedef veritabanındaki hedef tablonun adı.
   mapping_rule_name	StormEvents_CSV_Mapping	Hedef tabloyla ilgili sütun eşlemenizin adı.
   data_format	csv	İletinin veri biçimi.
   iot_hub_resource_id	Kaynak Kimliği	IoT hub'ınızın veri alımı için gereken verileri tutan kaynak kimliği.
   shared_access_policy_name	iothubforread	IoT Hub'a bağlanmak için cihazların ve hizmetlerin izinlerini tanımlayan paylaşılan erişim ilkesinin adı.
   consumer_group	$Default	Olay hub'ınızın tüketici grubu.
   konum	Central US	Veri bağlantısı kaynağının konumu.
   database_routing	Çoklu veya Tek	Bağlantı için veritabanı yönlendirmesi. Değeri Tek olarak ayarlarsanız, veri bağlantısı databaseName ayarında belirtildiği gibi kümedeki tek bir veritabanına yönlendirilir. Değeri Multi olarak ayarlarsanız, Veritabanı alımı özelliğini kullanarak varsayılan hedef veritabanını geçersiz kılabilirsiniz. Daha fazla bilgi için bkz . Olay yönlendirme.

Aşağıdaki örnekte IoT Hub veri bağlantısı eklemeye yönelik bir Azure Resource Manager şablonu gösterilmektedir. Formu kullanarak şablonu Azure portalında düzenleyebilir ve dağıtabilirsiniz.

{
    "$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 portalından IoT Hub bağlantısını kaldırmak için aşağıdakileri yapın:

1. Kümenize gidin. Soldaki menüden Veritabanları'nı seçin. Ardından hedef tabloyu içeren veritabanını seçin.
2. Soldaki menüden Veri bağlantıları'nı seçin. Ardından ilgili IoT Hub veri bağlantısının yanındaki onay kutusunu seçin.
3. Üst menü çubuğunda Sil'i seçin.

IoT Hub bağlantısını kaldırmak için aşağıdaki komutu çalıştırın:

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

IoT Hub bağlantısını kaldırmak için aşağıdaki komutu çalıştırın:

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)