Настройка конечных точек потока данных
Внимание
На этой странице содержатся инструкции по управлению компонентами Операций Интернета вещей Azure с помощью манифестов развертывания Kubernetes, которые доступны в предварительной версии. Эта функция предоставляется с несколькими ограничениями и не должна использоваться для рабочих нагрузок.
Юридические условия, применимые к функциям Azure, которые находятся в состоянии бета-версии, предварительной версии или иным образом еще не выпущены в общедоступной версии, см. на странице Дополнительные условия использования предварительных версий в Microsoft Azure.
Чтобы приступить к работе с потоками данных, сначала создайте конечные точки потока данных. Конечная точка потока данных — это точка подключения для потока данных. Для потока данных можно использовать конечную точку в качестве источника или назначения. Некоторые типы конечных точек можно использовать как источники, так и назначения, а другие — только для назначений. Для потока данных требуется по крайней мере одна исходная конечная точка и одна конечная точка назначения.
Используйте следующую таблицу, чтобы выбрать тип конечной точки для настройки:
| Тип конечной точки | Description | Можно использовать в качестве источника | Может использоваться в качестве назначения |
|---|---|---|---|
| MQTT; | Для двунаправленного обмена сообщениями с брокерами MQTT, включая один встроенный в Azure IoT Operations and Event Grid. | Да | Да |
| Kafka | Для двунаправленного обмена сообщениями с брокерами Kafka, включая Центры событий Azure. | Да | Да |
| Data Lake | Для отправки данных в учетные записи хранения Azure Data Lake 2-го поколения. | No | Да |
| Microsoft Fabric OneLake | Для отправки данных в озера Microsoft Fabric OneLake. | No | Да |
| Обозреватель данных Azure | Для отправки данных в базы данных Azure Data Explorer. | No | Да |
| Локальное хранилище | Для отправки данных в локальный доступный постоянный том, с помощью которого можно отправлять данные с помощью хранилища контейнеров Azure, включенного томами пограничных вычислений Azure Arc. | No | Да |
Внимание
Для конечных точек хранилища требуется схема сериализации. Чтобы использовать поток данных с Microsoft Fabric OneLake, Azure Data Lake Storage, Обозреватель данных Azure или локальное хранилище, необходимо указать ссылку на схему.
Чтобы создать схему из примера файла данных, используйте вспомогательный элемент schema Gen.
Потоки данных должны использовать локальную конечную точку брокера MQTT
При создании потока данных укажите исходные и конечные точки назначения. Поток данных перемещает данные из исходной конечной точки в конечную точку назначения. Одну конечную точку можно использовать для нескольких потоков данных, и вы можете использовать ту же конечную точку, что и источник, и назначение в потоке данных.
Однако использование пользовательских конечных точек как источника, так и назначения в потоке данных не поддерживается. Это ограничение означает, что встроенный брокер MQTT в Операциях Интернета вещей Azure должен быть по крайней мере одной конечной точкой. Это может быть источник, назначение или оба. Чтобы избежать сбоев развертывания потока данных, используйте конечную точку потока данных MQTT по умолчанию в качестве источника или назначения для каждого потока данных.
Конкретное требование заключается в том, что каждый поток данных должен иметь исходный или целевой объект, настроенный с конечной точкой MQTT с узлом aio-broker. Поэтому не обязательно использовать конечную точку по умолчанию, и вы можете создать дополнительные конечные точки потока данных, указывающие на локальный брокер MQTT, если узел находится aio-broker. Однако, чтобы избежать проблем с путаницой и управляемостью, конечная точка по умолчанию рекомендуется.
В следующей таблице показаны поддерживаемые сценарии:
| Сценарий | Поддерживается |
|---|---|
| Конечная точка по умолчанию в качестве источника | Да |
| Конечная точка по умолчанию в качестве назначения | Да |
| Пользовательская конечная точка в качестве источника | Да, если назначение — конечная точка по умолчанию или конечная точка MQTT с узлом aio-broker |
| Пользовательская конечная точка в качестве назначения | Да, если источник является конечной точкой по умолчанию или конечной точкой MQTT с узлом aio-broker |
| Пользовательская конечная точка в качестве источника и назначения | Нет, если одна из них не является конечной точкой MQTT с узлом aio-broker |
Повторное использование конечных точек
Подумайте о каждой конечной точке потока данных в виде пакета параметров конфигурации, содержащих данные, из которых должны поступать данные или перейти ( host значение), как пройти проверку подлинности с конечной точкой и другими параметрами, такими как конфигурация TLS или пакетная обработка. Поэтому необходимо создать его один раз, а затем повторно использовать его в нескольких потоках данных, где эти параметры будут одинаковыми.
Чтобы упростить повторное использование конечных точек, фильтр раздела MQTT или Kafka не входит в конфигурацию конечной точки. Вместо этого вы указываете фильтр раздела в конфигурации потока данных. Это означает, что вы можете использовать одну конечную точку для нескольких потоков данных, использующих различные фильтры разделов.
Например, можно использовать конечную точку потока данных брокера MQTT по умолчанию. Его можно использовать как для исходного, так и для назначения с различными фильтрами разделов:
Аналогичным образом можно создать несколько потоков данных, использующих одну и ту же конечную точку MQTT для других конечных точек и разделов. Например, можно использовать ту же конечную точку MQTT для потока данных, который отправляет данные в конечную точку Центров событий.
Аналогично примеру MQTT, можно создать несколько потоков данных, которые используют одну конечную точку Kafka для разных разделов или одну конечную точку Data Lake для разных таблиц.
Следующие шаги
Создайте конечную точку потока данных: