Creare una connessione dati hub IoT per Azure Esplora dati

Questo articolo illustra come inserire dati in Azure Esplora dati da hub IoT, una piattaforma di streaming Di Big Data e un servizio di inserimento IoT.

Per informazioni su come creare la connessione nel portale di Azure o con un modello di Resource Manager, vedere Creare una connessione dati IoT.

Per informazioni generali sull'inserimento in Azure Esplora dati da hub IoT, vedere Connettersi a hub IoT.

Nota

Vengono inseriti solo gli eventi accodati dopo aver creato la connessione dati.

Per esempi di codice basati sulle versioni precedenti dell'SDK, vedere l'articolo archiviato.

Prerequisiti

• Una sottoscrizione di Azure. Creare un account Azure gratuito.
• Un cluster e un database di Esplora dati di Azure. Creare un cluster e un database.
• Tabella di destinazione. Creare una tabella o usare una tabella esistente.
• Mapping di inserimento per la tabella.
• Un hub IoT con dati per l'inserimento.

Creare una connessione dati hub IoT

In questa sezione si stabilirà una connessione tra la hub IoT e la tabella di Azure Esplora dati. Purché questa connessione sia attivata, i dati vengono trasmessi dalla hub IoT alla tabella di destinazione.

Portale

1. Nel menu a sinistra del cluster di Azure Esplora dati selezionare Database e quindi selezionare il database che contiene la tabella di destinazione.

   

2. Selezionare Connessioni dati e Aggiungi connessione dati. Nell'elenco a discesa selezionare hub IoT.

   

3. Compilare il modulo con le informazioni seguenti.

   Impostazione	Descrizione campo
   Nome connessione dati	Nome della connessione da creare in Azure Esplora dati
   Abbonamento	ID sottoscrizione in cui si trova la risorsa di Hub eventi.
   Hub IoT	Nome hub IoT
   Criteri di accesso condiviso	Nome dei criteri di accesso condiviso. Deve disporre delle autorizzazioni di lettura
   Gruppo di consumer	Gruppo di consumer definito nell'endpoint predefinito hub IoT
   Proprietà del sistema per gli eventi	Proprietà del sistema eventi hub IoT. Quando si aggiungono proprietà del sistema, creare o aggiornare lo schema e il mapping della tabella per includere le proprietà selezionate.

   

   Nota

   • Le proprietà del sistema di eventi sono supportate per gli eventi a record singolo.
   • Per il mapping CSV, le proprietà vengono aggiunte all'inizio del record. Per il mapping JSON, le proprietà vengono aggiunte in base al nome visualizzato nell'elenco a discesa.

4. A seconda del caso d'uso, è possibile attivare il routing multi-database. Per altre informazioni sul routing del database, vedere Routing degli eventi.

   

5. Completare le impostazioni di routing seguenti:

   Impostazione	Valore consigliato	Descrizione campo
   Nome tabella	TestTable	Tabella creata in testdb.
   Formato dati	JSON	I formati supportati sono AVRO, CSV, JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHE AVRO e W3CLOG.
   Mapping	TestMapping	Mapping creato in testdb, che esegue il mapping dei dati in ingresso ai nomi di colonna e ai tipi di dati di testdb. Se non specificato, viene usato un mapping dei dati Identity derivato dallo schema della tabella.

   

   Nota

   • I dati JSON vengono analizzati come multijson per impostazione predefinita. Selezionare Ignora errori di formato per inserire i dati in formato JSON rigoroso.
   • Se sono state selezionate proprietà del sistema eventi, è necessario includere le proprietà di sistema nello schema e nel mapping della tabella.

6. Seleziona Crea.

Avviso

In caso di failover manuale, ricreare la connessione dati.

Modello ARM

L'esempio seguente illustra un modello di Azure Resource Manager per l'aggiunta di una connessione dati hub IoT. È possibile modificare e distribuire il modello nel portale di Azure usando il modulo.

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

Rimuovere una connessione dati hub IoT

Per rimuovere la connessione hub IoT dalla portale di Azure, eseguire le operazioni seguenti:

1. Passare al cluster. Nel menu a sinistra selezionare Database. Selezionare quindi il database contenente la tabella di destinazione.
2. Dal menu a sinistra selezionare Connessioni dati. Selezionare quindi la casella di controllo accanto alla connessione dati hub IoT pertinente.
3. Nella barra dei menu in alto selezionare Elimina.

---

Contenuto correlato

• Eseguire query sui dati nell'interfaccia utente Web di Azure Esplora dati