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

  • Статья

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

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

Diagram that shows the high-level IoT solution architecture highlighting message processing areas.

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

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

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

Маршрутизация в Центре Интернета вещей

В Центре Интернета вещей можно настроить маршрутизацию для доставки сообщений телеметрии в выбранные вами назначения. К назначениям относятся:

  • Контейнеры хранилища
  • Очереди служебной шины
  • Разделы служебной шины
  • Event Hubs

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

Дополнительные сведения см. в разделе Использование маршрутизации сообщений в Центре Интернета вещей для отправки с устройства в облако в разные конечные точки.

Запросы можно использовать для фильтрации сообщений , отправленных в разные назначения.

Маршрутизация IoT Central

Если вы используете IoT Central, вы можете использовать экспорт данных для отправки сообщений телеметрии другим подчиненным службам. К назначениям относятся:

  • Контейнеры хранилища
  • Очереди служебной шины
  • Разделы служебной шины
  • Event Hubs
  • Azure Data Explorer
  • Веб-перехватчики

Конфигурация экспорта данных IoT Central позволяет фильтровать сообщения, отправленные в место назначения.

Дополнительные сведения см. в статье "Экспорт данных из Интернета вещей".

Сетка событий

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

Дополнительные сведения см. в статье React to Центр Интернета вещей события с помощью сетки событий для активации действий и сравнения маршрутизации сообщений и сетки событий для Центр Интернета вещей.

Обогащение или преобразование сообщений

Чтобы упростить подчиненную обработку, может потребоваться добавить данные в сообщения телеметрии или изменить их структуру.

обогащения сообщений Центр Интернета вещей

Центр Интернета вещей обогащения сообщений позволяют добавлять данные в сообщения, отправленные устройствами. Вы можете добавить:

  • Статическую строку
  • Имя центра Интернета вещей, обрабатывающего сообщение
  • Сведения из двойника устройства

Дополнительные сведения см. в статье "Обогащение сообщений в облако" для сообщений Центр Интернета вещей устройств.

Преобразования сообщений IoT Central

IoT Central имеет два варианта преобразования сообщений телеметрии:

  • Используйте сопоставления для преобразования сложной телеметрии устройства в структурированные данные для входящего трафика в IoT Central.
  • Используйте преобразования для управления форматом и структурой данных устройства перед экспортом в место назначения.

Обработка сообщений на границе

Модуль Azure IoT Edge может обрабатывать данные телеметрии с подключенного датчика или устройства перед отправкой в Центр Интернета вещей. Например, прежде чем отправлять данные в облако, модуль IoT Edge может:

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

Вы можете использовать другие службы Azure для обработки сообщений телеметрии с устройств. Как Центр Интернета вещей, так и IoT Central могут направлять сообщения в другие службы. Например, вы можете пересылать сообщения телеметрии в следующее:

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

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

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

Следующие шаги

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