Creación de una conexión de datos de IoT Hub para Azure Data Explorer

En este artículo se muestra cómo ingerir datos en Azure Data Explorer desde IoT Hub, una plataforma de streaming de macrodatos y un servicio de ingesta de IoT.

Para obtener información sobre cómo crear la conexión en Azure Portal o con una plantilla de ARM, consulte Creación de una conexión de datos de IoT.

Para información general sobre la ingesta en Azure Data Explorer desde IoT Hub, consulte Conexión a IoT Hub.

Nota:

Solamente se ingieren los eventos en cola después de crear la conexión de datos.

Para obtener ejemplos de código basados en versiones anteriores del SDK, consulte el artículo archivado.

Requisitos previos

• Suscripción a Azure. Cree una cuenta de Azure gratuita.
• Un clúster y la base de datos de Azure Data Explorer. Cree un clúster y una base de datos.
• Una tabla de destino. Cree una tabla o use una tabla existente.
• Una asignación de ingesta para la tabla.
• Un IoT Hub con datos para la ingesta.

Crear una conexión de datos de IoT Hub

En esta sección, establecerá una conexión entre IoT Hub y la tabla de Azure Data Explorer. Siempre que esta conexión esté en vigor, los datos se transmiten desde IoT Hub a la tabla de destino.

Portal

1. En el menú izquierdo del clúster de Azure Data Explorer, seleccione Bases de datos y, a continuación, seleccione la base de datos que contiene la tabla de destino.

   

2. Seleccione Conexiones de datos y Agregar la conexión de datos. En la lista desplegable, seleccione IoT Hub.

   

3. Rellene el formulario con la siguiente información.

   Configuración	Descripción del campo
   Nombre de la conexión de datos	Nombre de la conexión que desea crear en Azure Data Explorer.
   Subscription	Identificador de la suscripción donde se encuentra el recurso de Event Hubs.
   IoT Hub	Nombre de IoT Hub
   Directiva de acceso compartido	Nombre de la directiva de acceso compartido. Debe tener permisos de lectura.
   Grupo de consumidores	Grupo de consumidores definido en el punto de conexión integrado de IoT Hub
   Propiedades del sistema de eventos	Propiedades del sistema de eventos de IoT Hub Cuando agregue las propiedades del sistema, cree o actualice el esquema de tabla y la asignación para incluir las propiedades seleccionadas.

   

   Nota:

   • Las propiedades del sistema de eventos se admiten para eventos de registro único.
   • Para la asignación de CSV, las propiedades se agregan al principio del registro. Para la asignación de JSON, las propiedades se agregan según el nombre que aparece en la lista desplegable.

4. En función de su caso de uso, es posible que desee activar el enrutamiento de varias bases de datos. Para más información acerca del enrutamiento de bases de datos, consulte Enrutamiento de eventos.

   

5. Rellene la siguiente configuración de enrutamiento:

   Configuración	Valor sugerido	Descripción del campo
   Nombre de la tabla	TestTable	La tabla que creó en testdb.
   Formato de datos	JSON	Los formatos admitidos son AVRO, CSV, JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHE AVRO y W3CLOG.
   Asignación	TestMapping	Asignación que creó en testdb, que asigna los datos entrantes a los nombres de columnas y tipos de datos de testdb. Si no se especifica, se usa una asignación de datos de identidad derivada del esquema de la tabla.

   

   Nota:

   • Los datos JSON se analizan como multijson de forma predeterminada. Seleccione Omitir errores de formato para ingerir los datos en formato JSON estricto.
   • Si seleccionó Propiedades del sistema de eventos, debe incluir propiedades del sistema en el esquema de tabla y la asignación.

6. Seleccione Crear.

Advertencia

En el caso de una conmutación por error manual, vuelva a crear la conexión de datos.

Plantilla ARM

En el ejemplo siguiente se muestra una plantilla de Azure Resource Manager para agregar una conexión de datos de IoT Hub. Puede editar e implementar la plantilla en Azure Portal mediante el formulario.

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

Eliminar una conexión de datos de IoT Hub

Para quitar la conexión de IoT Hub de Azure Portal, haga lo siguiente:

1. Vaya al clúster. En el menú de la izquierda, seleccione Bases de datos. A continuación, seleccione la base de datos que contiene la tabla de destino.
2. En el menú de la izquierda, seleccione Conexiones de datos. A continuación, active la casilla situada junto a la conexión de datos de IoT Hub correspondiente.
3. Seleccione Eliminar en la barra de menús superior.

---

Contenido relacionado

• Consulta de datos en la interfaz de usuario web de Azure Data Explorer