Поделиться через

Обработка сообщений в решении Интернета вещей

  • Статья

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

На следующей схеме показано высокоуровневое представление компонентов в типичном пограничном решении Интернета вещей. В этой статье рассматриваются компоненты обработки сообщений для пограничного решения Интернета вещей.

Схема, на котором показана высокоуровневая архитектура решения Интернета вещей с выделением областей обработки сообщений.

В Azure IoT обработка сообщений относится к таким процессам, как маршрутизация и обогащение сообщений, отправленных ресурсами и устройствами. Эти процессы используются для управления потоком сообщений через решение Интернета вещей и добавления дополнительных сведений в сообщения.

Маршрутизация сообщений

Для маршрутизации сообщений из ресурсов в различные конечные точки операции Интернета вещей Azure используют потоки данных. Конечные точки назначения могут находиться в облаке или на границе. Список доступных конечных точек назначения включает:

Тип конечной точки Описание
MQTT; Для двунаправленного обмена сообщениями с брокерами MQTT, включая один встроенный в Azure IoT Operations and Event Grid.
Kafka Для двунаправленного обмена сообщениями с брокерами Kafka, включая Центры событий Azure.
Data Lake Для отправки данных в учетные записи хранения Azure Data Lake 2-го поколения.
Microsoft Fabric OneLake Для отправки данных в хранилища данных Microsoft Fabric OneLake.
Обозреватель данных Azure Для отправки данных в базы данных Azure Data Explorer.
Локальное хранилище Для передачи данных на локальный доступный постоянный том можно при необходимости настроить хранилище контейнеров Azure, включенное с помощью Azure Arc.

Интерфейс веб-интерфейса операций предоставляет среду без кода для создания и запуска потоков данных.

Для повышения безопасности данных, которые направляются в конечные точки, в конечных точках потока данных используются облачные и пограничные синхронизированные секреты для проверки подлинности.

Хотя потоки данных позволяют настроить маршрутизацию на границе, вы также можете определить маршрутизацию в облаке. Если поток данных передает сообщения в Службу "Сетка событий Azure", вы можете использовать его возможности маршрутизации, чтобы определить, куда отправлять сообщения.

Дополнительные сведения см. в разделе "Обработка и маршрутизация данных" с потоками данных.

Обогащение, преобразование и обработка сообщений

Обогащения и преобразования можно применять к данным во время этапа обработки для выполнения различных операций. Эти операции могут включать:

  • Вычисление новых свойств: на основе существующих свойств в сообщении
  • Переименование свойств: стандартизация или уточнение данных
  • Преобразование единиц: преобразование значений в разные единицы измерения
  • Стандартизация значений: масштабирование значений свойств в определяемый пользователем диапазон
  • Контекстуализация данных: добавление ссылочных данных в сообщения для обогащения и анализа вождения

Реестр схем хранит схемы для сообщений, поступающих от ваших активов. Потоки данных используют эти схемы сообщений для декодирования сообщений из различных форматов, чтобы их можно было обрабатывать потоками данных.

Интерфейс веб-интерфейса операций предоставляет среду без кода для создания и выполнения преобразований в потоках данных.

Дополнительные сведения см. в статье "Обогащение данных с помощью потоков данных".

В Azure IoT Operations можно развернуть собственные высокодоступные приложения для краевых устройств в кластере Kubernetes. Пограничные приложения могут взаимодействовать со встроенным брокером MQTT:

  • Используйте настраиваемую логику обработки сообщений в сообщениях MQTT.
  • Создайте пользовательскую логику приложения для запуска на периферии.
  • Запуск моделей Edge AI для обработки данных и принятия решений в режиме реального времени на источнике данных, что снижает задержку и использование пропускной способности.

Дополнительные сведения см. в статье "Разработка высокодоступных приложений для брокера MQTT операций Интернета вещей Azure".

Другие облачные службы

Вы можете использовать другие облачные службы для обработки сообщений из ресурсов и устройств.

В точках потока данных Azure IoT Operations можно подключаться к облачным службам для отправки и получения данных с ваших устройств. Конечная точка потока данных — это точка подключения для потока данных.

Дополнительные сведения см. на следующих ресурсах:

В Центре Интернета вещей и IoT Central можно направлять сообщения в другие службы. Например, вы можете пересылать сообщения в Azure Stream Analytics для анализа и обработки больших объемов потоковых данных или функций Azure для выполнения кода в ответ на события. Stream Analytics также доступен в среде выполнения Azure IoT Edge, что позволяет обрабатывать данные на границе, а не в облаке.

Дополнительные сведения см. на следующих ресурсах:

Связанный контент