Créer une connexion de données IoT Hub pour Azure Data Explorer

Cet article vous montre comment ingérer des données dans Azure Data Explorer depuis IoT Hub, plateforme de streaming de big data et service d’ingestion IoT.

Pour savoir comment créer la connexion dans le Portail Azure ou avec un modèle ARM, consultez Créer une connexion de données IoT.

Pour obtenir des informations générales sur l’ingestion dans Azure Data Explorer à partir d’IoT Hub, consultez Connexion à IoT Hub.

Remarque

Seuls les événements mis en file d’attente après que vous avez créé la connexion de données sont ingérés.

Pour obtenir des exemples de code basés sur les versions précédentes du Kit de développement logiciel (SDK), consultez l’article archivé.

Prérequis

• Un abonnement Azure. Créez un compte Azure gratuit.
• Un cluster et une base de données Azure Data Explorer. Créez un cluster et une base de données.
• Une table de destination. Créez une table ou utilisez une table existante.
• Un mappage d’ingestion pour la table.
• Un hub IoT avec des données pour l’ingestion.

Créer une connexion de données IoT Hub

Dans cette section, vous allez établir une connexion entre IoT Hub et votre table Azure Data Explorer. Tant que cette connexion est en place, les données sont transmises depuis le hub IoT dans votre table cible.

Portail

1. Dans le menu de gauche de votre cluster Azure Data Explorer, sélectionnez Bases de données , puis sélectionnez la base de données qui contient votre table cible.

   

2. Sélectionnez Connexion de données, puis Ajouter une connexion de données. Dans la liste déroulante, sélectionnez IoT Hub.

   

3. Renseignez le formulaire avec les informations suivantes.

   Paramètre	Description du champ
   Nom de la connexion de données	Nom de la connexion que vous souhaitez créer dans Azure Data Explorer
   Abonnement	ID d’abonnement dans lequel se trouve la ressource Event Hubs.
   IoT Hub	Nom de l’IoT Hub
   Stratégie d’accès partagé	Nom de la stratégie d’accès partagé. Doit avoir des autorisations de lecture
   Groupe de consommateurs	Groupe de consommateurs défini dans le point de terminaison intégré au hub IoT
   Propriétés du système d’événements	Propriétés système d’événement du hub IoT. Lors de l’ajout des propriétés système, créez ou mettez à jour le schéma de table et le mappage pour inclure les propriétés sélectionnées.

   

   Remarque

   • Les propriétés du système d’événements sont prises en charge pour les événements à enregistrement unique.
   • Pour le mappage CSV, les propriétés sont ajoutées au début de l’enregistrement. Pour le mappage JSON, les propriétés sont ajoutées en fonction du nom qui apparaît dans la liste déroulante.

4. Selon votre cas d’usage, vous pouvez activer le routage multi-base de données. Pour plus d’informations sur le routage de base de données, consultez Routage des événements.

   

5. Renseignez les paramètres de routage suivants :

   Paramètre	Valeur suggérée	Description du champ
   Nom de la table	TestTable	Table que vous avez créée dans testdb.
   Format de données	JSON	Les formats pris en charge sont AVRO, CSV, JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHE AVRO et W3CLOG.
   Mappage	TestMapping	Mappage que vous avez créé dans testdb, qui mappe les données entrantes aux noms de colonnes et aux types de données de testdb. Si ce n’est pas spécifié, un mappage de données d’identité dérivé du schéma de la table est utilisé.

   

   Remarque

   • Par défaut, les données JSON sont analysées en tant que multijson. Sélectionnez Ignorer les erreurs de format pour ingérer les données au format JSON strict.
   • Si vous avez sélectionné les propriétés du système d’événements, vous devez inclure les propriétés système dans le schéma de table et le mappage.

6. Sélectionnez Créer.

Avertissement

En cas de basculement manuel, recréez la connexion de données.

Modèle ARM

L’exemple suivant montre un modèle Azure Resource Manager pour l’ajout d’une connexion de données IoT Hub. Vous pouvez modifier et déployer le modèle dans le portail Azure en utilisant le formulaire.

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

Supprimer une connexion de données IoT Hub

Pour supprimer la connexion IoT Hub de l’Portail Azure, procédez comme suit :

1. Accédez à votre cluster. Dans le menu de gauche, sélectionnez Bases de données. Ensuite, sélectionnez la base de données qui contient la table cible.
2. Dans le menu de gauche, sélectionnez Connexions de données. Ensuite, cochez la case en regard de la connexion de données IoT Hub appropriée.
3. Dans la barre de menus du haut, sélectionnez Supprimer.

---

Contenu connexe

• Interroger des données dans l’interface utilisateur web Azure Data Explorer