Tworzenie połączenia danych usługi IoT Hub dla usługi Azure Data Explorer

W tym artykule pokazano, jak pozyskiwać dane do usługi Azure Data Explorer z usługi IoT Hub, platformy przesyłania strumieniowego danych big data i usługi pozyskiwania IoT.

Aby dowiedzieć się, jak utworzyć połączenie w witrynie Azure Portal lub przy użyciu szablonu usługi ARM, zobacz Tworzenie połączenia danych IoT.

Aby uzyskać ogólne informacje na temat pozyskiwania do usługi Azure Data Explorer z usługi IoT Hub, zobacz Nawiązywanie połączenia z usługą IoT Hub.

Uwaga

Tylko zdarzenia umieszczone w kolejce po utworzeniu połączenia danych są pozyskiwane.

Przykłady kodu oparte na poprzednich wersjach zestawu SDK można znaleźć w zarchiwizowanym artykule.

Wymagania wstępne

• Subskrypcja platformy Azure. Utwórz bezpłatne konto platformy Azure.
• Baza danych i klaster usługi Azure Data Explorer. Utwórz klaster i bazę danych.
• Tabela docelowa. Utwórz tabelę lub użyj istniejącej tabeli.
• Mapowanie pozyskiwania dla tabeli.
• Usługa IoT Hub z danymi do pozyskiwania.

Tworzenie połączenia danych usługi IoT Hub

W tej sekcji ustanowisz połączenie między usługą IoT Hub i tabelą usługi Azure Data Explorer. O ile to połączenie jest na miejscu, dane są przesyłane z usługi IoT Hub do tabeli docelowej.

Portal

1. W menu po lewej stronie klastra usługi Azure Data Explorer wybierz pozycję Bazy danych , a następnie wybierz bazę danych zawierającą tabelę docelową.

   

2. Wybierz pozycję Połączenia danych i Dodaj połączenie danych. Z listy rozwijanej wybierz pozycję IoT Hub.

   

3. Wypełnij formularz, używając poniższych informacji.

   Ustawienie	Opis pola
   Nazwa połączenia danych	Nazwa połączenia, które chcesz utworzyć w usłudze Azure Data Explorer
   Subskrypcja	Identyfikator subskrypcji, w której znajduje się zasób usługi Event Hubs.
   Usługa IoT Hub	Nazwa centrum IoT
   Zasady dostępu współdzielonego	Nazwa zasad dostępu współdzielonego. Musi mieć uprawnienia do odczytu
   Grupa konsumentów	Grupa odbiorców zdefiniowana w wbudowanym punkcie końcowym usługi IoT Hub
   Właściwości systemu zdarzeń	Właściwości systemu zdarzeń usługi IoT Hub. Podczas dodawania właściwości systemu utwórz lub zaktualizuj schemat tabeli i mapowanie , aby uwzględnić wybrane właściwości.

   

   Uwaga

   • Właściwości systemu zdarzeń są obsługiwane w przypadku zdarzeń z pojedynczym rekordem.
   • W przypadku mapowania woluminów CSV właściwości są dodawane na początku rekordu. W przypadku mapowania JSON właściwości są dodawane zgodnie z nazwą wyświetlaną na liście rozwijanej.

4. W zależności od przypadku użycia może być konieczne włączenie routingu z wieloma bazami danych. Aby uzyskać więcej informacji na temat routingu bazy danych, zobacz Routing zdarzeń.

   

5. Wypełnij następujące ustawienia routingu:

   Ustawienie	Sugerowana wartość	Opis pola
   Nazwa tabeli	TestTable	Tabela utworzona w bazie danych testdb.
   Format danych	JSON	Obsługiwane formaty to AVRO, CSV, JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHE AVRO i W3CLOG.
   Mapowanie	TestMapping	Mapowanie utworzone w bazie danych testdb, które mapuje dane przychodzące na nazwy kolumn i typy danych bazy danych testdb. Jeśli nie zostanie określony, zostanie użyte mapowanie danych tożsamości pochodzące ze schematu tabeli.

   

   Uwaga

   • Dane JSON są domyślnie analizowane jako multijson. Wybierz pozycję Ignoruj błędy formatu, aby pozyskać dane w ścisłym formacie JSON.
   • W przypadku wybrania właściwości systemu zdarzeń należy uwzględnić właściwości systemowe w schemacie tabeli i mapowaniu.

6. Wybierz pozycję Utwórz.

Ostrzeżenie

W przypadku ręcznego przejścia w tryb failover utwórz ponownie połączenie danych.

Szablon usługi ARM

Poniższy przykład przedstawia szablon usługi Azure Resource Manager do dodawania połączenia danych usługi IoT Hub. Szablon można edytować i wdrożyć w witrynie Azure Portal przy użyciu formularza.

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

Usuwanie połączenia danych usługi IoT Hub

Aby usunąć połączenie usługi IoT Hub z witryny Azure Portal, wykonaj następujące czynności:

1. Przejdź do klastra. W menu po lewej stronie wybierz pozycję Bazy danych. Następnie wybierz bazę danych zawierającą tabelę docelową.
2. W menu po lewej stronie wybierz pozycję Połączenia danych. Następnie zaznacz pole wyboru obok odpowiedniego połączenia danych usługi IoT Hub.
3. Na górnym pasku menu wybierz pozycję Usuń.

---

Powiązana zawartość

• Wykonywanie zapytań dotyczących danych w internetowym interfejsie użytkownika usługi Azure Data Explorer