Обработка и маршрутизация данных с помощью потоков данных
Внимание
Предварительная версия операций Интернета вещей Azure, включенная Azure Arc в настоящее время в предварительной версии. Не следует использовать это программное обеспечение предварительной версии в рабочих средах.
Вам потребуется развернуть новую установку Операций Интернета вещей Azure, когда общедоступная версия станет доступной. Вы не сможете обновить предварительную установку.
Юридические условия, применимые к функциям Azure, которые находятся в состоянии бета-версии, предварительной версии или иным образом еще не выпущены в общедоступной версии, см. на странице Дополнительные условия использования предварительных версий в Microsoft Azure.
Потоки данных позволяют подключать различные источники данных и выполнять операции с данными, упрощая настройку путей данных для перемещения, преобразования и обогащения данных. Компонент потока данных является частью операций Интернета вещей Azure, которая развертывается в качестве расширения Azure Arc. Настройка потока данных выполняется с помощью пользовательских определений ресурсов Kubernetes (CRD).
Конфигурации можно написать для различных вариантов использования, например:
- Преобразование данных и отправка их обратно в MQTT
- Преобразование данных и отправка их в облако
- Отправка данных в облако или edge без преобразования
Потоки данных не ограничиваются регионом, в котором развертывается экземпляр операций Интернета вещей. Потоки данных можно использовать для отправки данных в облачные конечные точки в разных регионах.
Ключевые функции
Ниже приведены основные функции потоков данных.
Обработка и маршрутизация данных
Потоки данных обеспечивают прием, обработку и маршрутизацию сообщений в указанные приемники. Можно указать:
- Источники: откуда отправляются сообщения
- Назначения: где сообщения стекаются в
- Преобразования (необязательно): настройка операций обработки данных
Возможности преобразования
Преобразования можно применять к данным на этапе обработки для выполнения различных операций. Эти операции могут включать:
- Вычисление новых свойств: на основе существующих свойств в сообщении
- Переименование свойств: стандартизация или уточнение данных
- Преобразование единиц: преобразование значений в разные единицы измерения
- Стандартизация значений: масштабирование значений свойств в определяемый пользователем диапазон
- Контекстуализация данных: добавление ссылочных данных в сообщения для обогащения и анализа вождения
Настройка и развертывание
Конфигурация указана с помощью crD Kubernetes. На основе этой конфигурации оператор потока данных создает экземпляры потока данных для обеспечения высокой доступности и надежности.
Льготы
- Упрощенная настройка: простое подключение источников данных и назначений.
- Гибкие преобразования. Выполнение широких операций с данными.
- Масштабируемая конфигурация. Используйте CRD Kubernetes для масштабируемых и управляемых конфигураций.
- Высокий уровень доступности: собственный ресурс Kubernetes обеспечивает надежность.
Используя потоки данных, вы можете эффективно управлять путями данных. Вы можете убедиться, что данные точно отправляются, преобразуются и обогащены в соответствии с вашими операционными потребностями.