Criar uma conexão de dados do Hub IoT para o Azure Data Explorer

Este artigo mostra como ingerir dados no Azure Data Explorer do Hub IoT, de uma plataforma de streaming de Big Data e do serviço de ingestão de IoT.

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

Para obter informações gerais sobre a ingestão no Azure Data Explorer do Hub IoT, confira Conectar-se ao Hub IoT.

Observação

Somente os eventos enfileirados após a criação da conexão de dados são ingeridos.

Para obter amostras de código baseadas em versões anteriores do SDK, confira o artigo arquivado.

Pré-requisitos

• Uma assinatura do Azure. Criar uma conta gratuita do Azure.
• Um cluster e um banco de dados do Azure Data Explorer. Criar um cluster e um banco de dados.
• Uma tabela de destino. Criar uma tabela ou usar uma tabela existente.
• Um mapeamento de ingestão para a tabela.
• Um Hub IoT com dados para ingestão.

Criar uma conexão de dados do Hub IoT

Nesta seção, você estabelecerá uma conexão entre o Hub IoT e a sua tabela do Azure Data Explorer. Enquanto essa conexão estiver em vigor, os dados serão transmitidos do Hub IoT para a tabela de destino.

Portal

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

   

2. Selecione conexões de dados e Adicionar conexão de dados. Na lista suspensa, selecione Hub IoT.

   

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

   Configuração	Descrição do campo
   Nome da conexão de dados	O nome da conexão que você deseja criar no Azure Data Explorer
   Assinatura	A ID da assinatura em que o recurso dos Hubs de Eventos está localizado.
   Hub IoT	Nome do Hub IoT
   Política de acesso compartilhado	O nome da política de acesso compartilhado. Deve ter permissões de leitura
   Grupo de consumidores	O grupo de consumidores definido no ponto de extremidade interno do Hub IoT
   Propriedades do sistema de eventos	As propriedades do sistema de eventos do Hub IoT. Ao adicionar propriedades do sistema, crie ou atualize o esquema de tabela e o mapeamento de maneira a incluir as propriedades selecionadas.

   

   Observação

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

4. Dependendo do seu caso de uso, talvez você queira ativar o roteamento de vários bancos de dados. Para obter mais informações sobre o roteamento do banco de dados, confira Roteamento de eventos.

   

5. Preencha as seguintes configurações de roteamento:

   Configuração	Valor sugerido	Descrição do campo
   Nome da tabela	TestTable	A tabela criada em 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 criado em testdb, que mapeia os dados de entrada para os tipos de dados e nomes de coluna de testdb. Se não for especificado, um mapeamento de dados de identidade derivado do esquema da tabela será usado.

   

   Observação

   • Os dados JSON são analisados como multijson por padrão. Selecione Ignorar erros de formato para ingerir os dados no formato JSON estrito.
   • Se você selecionou Propriedades do sistema de eventos, deverá incluir as propriedades do sistema no esquema e no mapeamento da tabela.

6. Selecione Criar.

Aviso

No caso de um failover manual, recrie a conexão de dados.

Modelo de ARM

O exemplo a seguir mostra um modelo do Azure Resource Manager para adicionar uma conexão de dados do Hub IoT. Você pode editar e implantar o modelo no portal do Azure usando 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 conexão de dados do Hub IoT

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

1. Vá para o seu cluster. No menu à esquerda, selecione Bancos de dados. Em seguida, selecione o banco de dados que contém a tabela de destino.
2. No menu à esquerda, selecione Conexões de dados. Em seguida, marque a caixa de seleção ao lado da conexão de dados relevante do Hub IoT.
3. Na barra de menu superior, selecione Excluir.

---

Conteúdo relacionado

• Consultar dados na interface do usuário da Web do Azure Data Explorer