Обработка сообщений в решении Интернета вещей
В этом обзоре представлены основные понятия обработки сообщений, отправленных с устройств в типичном решении Интернета вещей Azure. Каждый раздел содержит ссылки на содержимое, которое содержит дополнительные сведения и рекомендации.
На следующей схеме показано высокоуровневое представление компонентов в типичном решении Интернета вещей. В этой статье рассматриваются компоненты обработки сообщений решения Интернета вещей.
В 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 для Функции Azure
- Визуализация данных датчика в режиме реального времени из Центр Интернета вещей Azure с помощью Power BI
- Расширение возможностей Azure IoT Central с помощью настраиваемых правил с использованием Stream Analytics, Функций Azure и SendGrid
Следующие шаги
Теперь, когда вы ознакомились с общими сведениями об управлении устройствами и контролем в решениях Интернета вещей Azure, ниже приведены следующие шаги.