Создание подключения к данным Центр Интернета вещей для Azure Data Explorer

В этой статье показано, как принимать данные в Azure Data Explorer из Центра Интернета вещей, платформы потоковой передачи больших данных и службы приема данных Интернета вещей.

Сведения о том, как создать подключение в портал Azure или с помощью шаблона ARM, см. в статье Создание подключения к данным Интернета вещей.

Общие сведения о передаче данных в Azure Data Explorer из Центра Интернета вещей см. в разделе Подключение к Центру Интернета вещей.

Примечание

Принимаются только события, поставленные в очередь после создания подключения к данным.

Примеры кода, основанные на предыдущих версиях пакета SDK, см. в архивной статье.

Предварительные требования

• Подписка Azure. Создайте бесплатную учетную запись Azure.
• Кластер и база данных Azure Data Explorer. Создайте кластер и базу данных.
• Целевая таблица. Создайте таблицу или используйте существующую таблицу.
• Сопоставление приема для таблицы.
• Центр Интернета вещей с данными для приема.

Создание подключения к данным Центр Интернета вещей

В этом разделе описано, как установить подключение между Центр Интернета вещей и таблицей azure Data Explorer. Пока это подключение установлено, данные передаются из Центр Интернета вещей в целевую таблицу.

Портал

1. В меню слева кластера Azure Data Explorer выберите Базы данных, а затем выберите базу данных, содержащую целевую таблицу.

   

2. Выберите Подключение к базе данных и Добавить подключение к данным. В раскрывающемся списке выберите Центр Интернета вещей.

   

3. Заполните форму, указав следующую информацию.

   Параметр	Описание поля
   Имя подключения к данным	Имя подключения, которое вы хотите создать в Azure Data Explorer
   Подписка	Идентификатор подписки, в которой размещается ресурс Центров событий.
   Центр Интернета вещей	Имя Центра Интернета вещей
   Политика общего доступа	Название политики общего доступа. Должны быть разрешения на чтение
   Группа потребителей	Группа потребителей, определенная во встроенной конечной точке Центра Интернета вещей
   Свойства системы событий	Свойства системы событий Центра Интернета вещей. При добавлении системных свойств выполните создание или обновление схемы таблицы, а также сопоставление, чтобы добавить выбранные свойства.

   

   Примечание

   • Для событий с одной записью поддерживаются свойства системы событий.
   • Для сопоставления CSV свойства добавляются в начале записи. Для сопоставления JSON свойства добавляются в соответствии с именем, которое отображается в раскрывающемся списке.

4. В зависимости от варианта использования может потребоваться включить маршрутизацию с несколькими базами данных. Дополнительные сведения о маршрутизации в базы данных см. в разделе Маршрутизация событий.

   

5. Заполните следующие параметры маршрутизации:

   Параметр	Рекомендуемое значение	Описание поля
   Имя таблицы	TestTable	Таблица, которую вы создали в testdb.
   Формат данных	JSON	Поддерживаемые форматы: AVRO, CSV, JSON, ORC, PARQUET, PSV, SCSV, SOHSV, TSV, TXT, TSVE, APACHE AVRO и W3CLOG.
   Сопоставление	TestMapping	Сопоставление, которое вы создали в testdb, которое сопоставляет входящие данные с именами столбцов и типами данных testdb. Если значение не указано, используется сопоставление данных удостоверений, полученное из схемы таблицы.

   

   Примечание

   • По умолчанию данные JSON анализируются как multijson. Выберите Игнорировать ошибки формата , чтобы принимать данные в строгом формате JSON.
   • Если вы выбрали свойства системы событий, необходимо включить системные свойства в схему и сопоставление таблицы.

6. Нажмите кнопку создания.

Предупреждение

В случае отработки отказа вручную повторно создайте подключение к данным.

Шаблон ARM

В следующем примере показан шаблон Azure Resource Manager для добавления подключения к данным Центра Интернета вещей. Вы можете изменить и развернуть шаблон на портале Azure с помощью формы.

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

Удаление подключения к данным Центр Интернета вещей

Чтобы удалить подключение Центр Интернета вещей из портал Azure, выполните следующие действия.

1. Перейдите в кластер. В меню слева выберите Базы данных. Затем выберите базу данных, содержащую целевую таблицу.
2. В меню слева выберите Подключения к данным. Затем установите флажок рядом с соответствующим Центр Интернета вещей подключением к данным.
3. В верхней строке меню выберите Удалить.

---

См. также

• Запрашивание данных в пользовательском веб-интерфейсе Azure Data Explorer