IoT Hub-adatkapcsolat létrehozása az Azure Data Explorerhez

Ez a cikk bemutatja, hogyan lehet adatokat beolvasni az Azure Data Explorerbe az IoT Hubról, egy big data streaming platformról és egy IoT-betöltési szolgáltatásból.

Az Azure Data Explorerbe az IoT Hubról való betöltéséről a Csatlakozás az IoT Hubhoz című témakörben olvashat.

Feljegyzés

Csak az adatkapcsolat létrehozása után lekért események vannak betöltve.

Előfeltételek

• Azure-előfizetés. Hozzon létre egy ingyenes Azure-fiókot.
• Egy Azure Data Explorer-fürt és -adatbázis. Hozzon létre egy fürtöt és egy adatbázist.
• Céltábla. Hozzon létre egy táblát , vagy használjon egy meglévő táblát.
• A táblázat betöltési leképezése .
• Egy IoT Hub a betöltéshez szükséges adatokkal.

IoT Hub-adatkapcsolat létrehozása

Ebben a szakaszban kapcsolatot fog létesíteni az IoT Hub és az Azure Data Explorer-tábla között. Amíg ez a kapcsolat működik, a rendszer adatokat továbbít az IoT Hubról a céltáblába.

Portál

1. Az Azure Data Explorer-fürt bal oldali menüjében válassza az Adatbázisok lehetőséget, majd válassza ki a céltáblát tartalmazó adatbázist.

   

2. Válassza az Adatkapcsolatok lehetőséget, és adja meg az adatkapcsolatot. A legördülő menüben válassza az IoT Hubot.

   

3. Adja meg az alábbi adatokat az űrlapon.

   Beállítás	Mező leírása
   Adatkapcsolat neve	Az Azure Data Explorerben létrehozni kívánt kapcsolat neve
   Előfizetés	Az előfizetés azonosítója, ahol az Event Hubs-erőforrás található.
   IoT Hub	Iot-központ neve
   Megosztott hozzáférési szabályzat	A megosztott hozzáférési szabályzat neve. Olvasási engedélyekkel kell rendelkeznie
   Fogyasztói csoport	Az IoT Hub beépített végpontjában definiált fogyasztói csoport
   Eseményrendszer tulajdonságai	Az IoT Hub eseményrendszer tulajdonságai. Rendszertulajdonságok hozzáadásakor hozzon létre vagy frissítse a táblázatsémát és a leképezést a kiválasztott tulajdonságok belefoglalásához.

   

   Feljegyzés

   • Az eseményrendszer tulajdonságai egyrekordos események esetén támogatottak.
   • CSV-megfeleltetés esetén a rendszer a rekord elején adja hozzá a tulajdonságokat. JSON-megfeleltetés esetén a tulajdonságok a legördülő listában megjelenő név alapján lesznek hozzáadva.

4. A használati esettől függően érdemes lehet bekapcsolni a többadatbázisos útválasztást. Az adatbázis-útválasztásról további információt az Események útválasztása című témakörben talál.

   

5. Adja meg a következő útválasztási beállításokat:

   Beállítás	Ajánlott érték	Mező leírása
   Tábla neve	TestTable	A testdb-ben létrehozott tábla.
   Adatformátum	JSON	Támogatott formátumok: AVRO, CSV, JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHE AVRO és W3CLOG.
   Hozzárendelés	TestMapping	A testdb-ben létrehozott leképezés, amely leképezi a bejövő adatokat a testdb oszlopneveihez és adattípusaihoz. Ha nincs megadva, a rendszer a tábla sémájából származtatott identitásadat-leképezést használja.

   

   Feljegyzés

   • A JSON-adatok alapértelmezés szerint multijsonként vannak elemezve. Válassza a Formátumhibák figyelmen kívül hagyása lehetőséget az adatok szigorú JSON-formátumban való betöltéséhez.
   • Ha az Eseményrendszer tulajdonságai lehetőséget választotta, a rendszertulajdonságokat meg kell adnia a táblasémában és a leképezésben.

6. Válassza a Létrehozás lehetőséget.

Figyelmeztetés

Manuális feladatátvétel esetén hozza létre újra az adatkapcsolatot.

C#

1. Telepítse a Microsoft.Azure.Management.Kusto NuGet csomagot.

2. Hozzon létre egy Azure AD-alkalmazásnevet a hitelesítéshez. Szüksége lesz a címtár (bérlő) azonosítójára, az alkalmazásazonosítóra és az ügyfél titkos kódjára.

3. Futtassa a következő kódot.

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

   Beállítás	Ajánlott érték	Mező leírása
   tenantId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	Az Ön bérlőazonosítója. Más néven könyvtárazonosító.
   subscriptionId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	Az erőforrás-létrehozáshoz használt előfizetés-azonosító.
   clientId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	Annak az alkalmazásnak az ügyfélazonosítója, amely hozzáfér a bérlő erőforrásaihoz.
   clientSecret	PlaceholderClientSecret	Az alkalmazás ügyfélkulcsa, amely hozzáfér a bérlő erőforrásaihoz.
   resourceGroupName	testrg	A fürtöt tartalmazó erőforráscsoport neve.
   clusterName	mykustocluster	A fürt neve.
   databaseName	mykustodatabase	A fürt céladatbázisának neve.
   iotHubConnectionName	myiothubconnect	Az adatkapcsolat kívánt neve.
   tableName	StormEvents	A céltábla neve a céladatbázisban.
   mappingRuleName	StormEvents_CSV_Mapping	A céltáblához kapcsolódó oszlopleképezés neve.
   dataFormat	csv	Az üzenet adatformátuma.
   iotHubResourceId	Erőforrás-azonosító	A betöltéshez szükséges adatokat tartalmazó IoT Hub erőforrás-azonosítója.
   sharedAccessPolicyName	iothubforread	A megosztott hozzáférési szabályzat neve, amely meghatározza az IoT Hubhoz való csatlakozáshoz szükséges eszközök és szolgáltatások engedélyeit.
   consumerGroup	$Default	Az eseményközpont fogyasztói csoportja.
   hely	USA középső régiója	Az adatkapcsolati erőforrás helye.
   databaseRouting	Több - vagy egyszemélyes	A kapcsolat adatbázis-útválasztása. Ha az értéket egyetlen értékre állítja, az adatkapcsolat a fürt egyetlen adatbázisához lesz irányítva a databaseName beállításban megadottak szerint. Ha multi értékre állítja az értéket, felülbírálhatja az alapértelmezett céladatbázist az Adatbázis-betöltési tulajdonság használatával. További információ: Események útválasztása.

Python

1. Telepítse a szükséges kódtárakat.

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

2. Hozzon létre egy Azure AD-alkalmazásnevet a hitelesítéshez. Szüksége lesz a címtár (bérlő) azonosítójára, az alkalmazásazonosítóra és az ügyfél titkos kódjára.

3. Futtassa a következő kódot.

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

   Beállítás	Ajánlott érték	Mező leírása
   tenant_id	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	Az Ön bérlőazonosítója. Más néven könyvtárazonosító.
   subscriptionId	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	Az erőforrás-létrehozáshoz használt előfizetés-azonosító.
   ügyfél azonosítója	xxxxxxxx-xxxxx-xxxx-xxxx-xxxx-xxxxxxxxx	Annak az alkalmazásnak az ügyfélazonosítója, amely hozzáfér a bérlő erőforrásaihoz.
   titkos ügyfélkód	xxxxxxxxxxxxxx	Az alkalmazás ügyfélkulcsa, amely hozzáfér a bérlő erőforrásaihoz.
   resource_group_name	testrg	A fürtöt tartalmazó erőforráscsoport neve.
   cluster_name	mykustocluster	A fürt neve.
   database_name	mykustodatabase	A fürt céladatbázisának neve.
   data_connection_name	myeventhubconnect	Az adatkapcsolat kívánt neve.
   table_name	StormEvents	A céltábla neve a céladatbázisban.
   mapping_rule_name	StormEvents_CSV_Mapping	A céltáblához kapcsolódó oszlopleképezés neve.
   data_format	csv	Az üzenet adatformátuma.
   iot_hub_resource_id	Erőforrás-azonosító	A betöltéshez szükséges adatokat tartalmazó IoT Hub erőforrás-azonosítója.
   shared_access_policy_name	iothubforread	A megosztott hozzáférési szabályzat neve, amely meghatározza az IoT Hubhoz való csatlakozáshoz szükséges eszközök és szolgáltatások engedélyeit.
   consumer_group	$Default	Az eseményközpont fogyasztói csoportja.
   hely	USA középső régiója	Az adatkapcsolati erőforrás helye.
   database_routing	Több - vagy egyszemélyes	A kapcsolat adatbázis-útválasztása. Ha az értéket egyetlen értékre állítja, az adatkapcsolat a fürt egyetlen adatbázisához lesz irányítva a databaseName beállításban megadottak szerint. Ha multi értékre állítja az értéket, felülbírálhatja az alapértelmezett céladatbázist az Adatbázis-betöltési tulajdonság használatával. További információ: Események útválasztása.

ARM-sablon

Az alábbi példa egy Azure Resource Manager-sablont mutat be egy IoT Hub-adatkapcsolat hozzáadásához. A sablont az űrlap használatával szerkesztheti és helyezheti üzembe az Azure Portalon.

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

IoT Hub-adatkapcsolat eltávolítása

Portál

Ha el szeretné távolítani az IoT Hub-kapcsolatot az Azure Portalról, tegye a következőket:

1. Nyissa meg a fürtöt. A bal oldali menüben válassza az Adatbázisok lehetőséget. Ezután válassza ki a céltáblát tartalmazó adatbázist.
2. A bal oldali menüben válassza az Adatkapcsolatok lehetőséget. Ezután jelölje be a megfelelő IoT Hub-adatkapcsolat melletti jelölőnégyzetet.
3. A felső menüsávon válassza a Törlés lehetőséget.

C#

Az IoT Hub-kapcsolat eltávolításához futtassa a következő parancsot:

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

Python

Az IoT Hub-kapcsolat eltávolításához futtassa a következő parancsot:

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)

Következő lépések

• Adatok lekérdezése az Azure Data Explorerben