Criar uma ligação de dados Hub IoT para o Azure Data Explorer

Este artigo mostra-lhe como ingerir dados no Azure Data Explorer a partir de Hub IoT, uma plataforma de transmissão em fluxo de macrodados e o serviço de ingestão de IoT.

Para saber como criar a ligação no portal do Azure ou com um modelo do ARM, veja Criar uma ligação de dados IoT.

Para obter informações gerais sobre como ingerir no Azure Data Explorer a partir de Hub IoT, veja Ligar ao Hub IoT.

Nota

Apenas os eventos colocados em fila depois de criar a ligação de dados são ingeridos.

Para obter exemplos de código com base em versões anteriores do SDK, veja o artigo arquivado.

Pré-requisitos

• Uma subscrição do Azure. Crie uma conta gratuita do Azure.
• Um cluster e uma base de dados do Azure Data Explorer. Criar um cluster e uma base de dados.
• Uma tabela de destino. Crie uma tabela ou utilize uma tabela existente.
• Um mapeamento de ingestão para a tabela.
• Uma Hub IoT com dados para ingestão.

Criar uma ligação de dados Hub IoT

Nesta secção, irá estabelecer uma ligação entre a Hub IoT e a tabela de Data Explorer do Azure. Desde que esta ligação esteja implementada, os dados são transmitidos do Hub IoT para a tabela de destino.

Portal

1. No menu esquerdo do cluster do Azure Data Explorer, selecione Bases de dados e, em seguida, selecione a base de dados que contém a tabela de destino.

   

2. Selecione Ligações de dados e Adicionar ligação de dados. Na lista pendente, selecione Hub IoT.

   

3. Preencha o formulário com as seguintes informações.

   Definição	Descrição do campo
   Nome da ligação de dados	O nome da ligação que pretende criar no Azure Data Explorer
   Subscrição	O ID da subscrição onde está localizado o recurso dos Hubs de Eventos.
   IoT Hub	Hub IoT nome
   Política de acesso partilhado	O nome da política de acesso partilhado. Tem de ter permissões de leitura
   Grupo de consumidores	O grupo de consumidores definido no Hub IoT ponto final incorporado
   Propriedades do sistema de eventos	O Hub IoT propriedades do sistema de eventos. Ao adicionar propriedades do sistema, crie ou atualize o esquema e o mapeamento da tabela para incluir as propriedades selecionadas.

   

   Nota

   • As propriedades do sistema de eventos são suportadas para eventos de registo único.
   • Para o mapeamento CSV, as propriedades são adicionadas no início do registo. Para o mapeamento JSON, as propriedades são adicionadas de acordo com o nome que aparece na lista pendente.

4. Consoante o seu caso de utilização, poderá querer ativar o encaminhamento de várias bases de dados. Para obter mais informações sobre o encaminhamento de bases de dados, veja Encaminhamento de eventos.

   

5. Preencha as seguintes definições de encaminhamento:

   Definição	Valor sugerido	Descrição do campo
   Nome da tabela	TestTable	A tabela que criou no testdb.
   Formato de dados	JSON	Os formatos suportados são AVRO, CSV, JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHE AVRO e W3CLOG.
   Mapeamento	TestMapping	O mapeamento que criou no testdb, que mapeia os dados recebidos para os nomes das colunas e os tipos de dados do testdb. Se não for especificado, é utilizado um mapeamento de dados de identidade derivado do esquema da tabela.

   

   Nota

   • Por predefinição, os dados JSON são analisados como multijson. Selecione Ignorar erros de formato para ingerir os dados em formato JSON restrito.
   • Se tiver selecionado Propriedades do sistema de eventos, tem de incluir as propriedades do sistema no esquema e mapeamento da tabela.

6. Selecione Criar.

Aviso

Em caso de ativação pós-falha manual, recrie a ligação de dados.

Modelo ARM

O exemplo seguinte mostra um modelo do Azure Resource Manager para adicionar uma ligação de dados Hub IoT. Pode editar e implementar o modelo no portal do Azure com o formulário.

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

Remover uma ligação de dados Hub IoT

Para remover a ligação Hub IoT do portal do Azure, faça o seguinte:

1. Aceda ao cluster. No menu esquerdo, selecione Bases de Dados. Em seguida, selecione a base de dados que contém a tabela de destino.
2. No menu esquerdo, selecione Ligações de dados. Em seguida, selecione a caixa de verificação junto à ligação de dados relevante Hub IoT.
3. Na barra de menus superior, selecione Eliminar.

---

Conteúdo relacionado

• Consultar dados na IU da Web do Azure Data Explorer