Маршрутизация, фильтрация и системные события

Разработка решений на основе событий и сообщений в Azure

Fiodar Sazanavets

Senior Software Engineer and Microsoft MVP

Обзор MQTT

  • Message Queuing Telemetry Transport (MQTT).

  • Используется в интернете вещей (IoT).

  • Несколько устройств, например метеостанции, непрерывно передают данные.

  • Измеряемые параметры: температура и влажность.

  • MQTT обеспечивает связь между устройствами и сервером.

  • Разработан для сетей с низкой пропускной способностью.

  • Поддерживает соединения с высокой задержкой или нестабильные соединения.

  • Применяется для датчиков на открытом воздухе или в удалённых местах.

 

Событийно-ориентированная архитектура

  • Применяется для датчиков на открытом воздухе или в удалённых местах.
Разработка решений на основе событий и сообщений в Azure

Фильтрация событий

Фильтрация событий

Разработка решений на основе событий и сообщений в Azure

Фильтрация событий в Event Grid

  • Event Grid поддерживает фильтрацию событий.
  • Можно фильтровать по:
    • Теме.
    • Типу события.
    • Свойствам в данных события.
  • Расширенная фильтрация уточняет результаты.
    • Больше чем.
    • Содержит.

Фильтрация в Event Grid

Разработка решений на основе событий и сообщений в Azure

Маршрутизация событий

Маршрутизация событий

  • Event Grid использует модель «издатель — подписчик».
  • Издатели публикуют события в темы.
  • Подписки определяют места назначения.
    • Конвейер обработки данных.
    • Azure Function.
    • Система хранения данных.
  • Обязательно для MQTT.
Разработка решений на основе событий и сообщений в Azure

Системные события

  • Предопределённые события, генерируемые службами Azure.
    • Хранилище Azure генерирует события создания и удаления BLOB.
    • События жизненного цикла IoT Hub: подключено, отключено.
  • Системные темы создаются автоматически.

Разработка решений на основе событий и сообщений в Azure

Event Grid — ключевой инструмент фильтрации событий

  • MQTT доставляет телеметрию IoT в облако.
  • Фильтрация управляет тем, какие события обрабатываются.
  • Системные события обеспечивают интеграцию с системой.

Итоги урока

Разработка решений на основе событий и сообщений в Azure

Давайте потренируемся!

Разработка решений на основе событий и сообщений в Azure

Preparing Video For Download...