Введение

Rule Engine - это простая в использовании платформа для создания рабочих процессов на основе событий. Есть 3 основных компонента:

  • Сообщение - любое входящее событие. Это могут быть входящие данные с устройств, событие жизненного цикла устройства, событие REST API, запрос RPC и т. д.

  • Узел правила - функция обработки входящего сообщения. Существует много различных типов узлов, которые могут фильтровать, преобразовывать или выполнять некоторые действия с входящим сообщением.

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

Сценарии использования

Rule Engine - это настраиваемая платформа для обработки сложных событий. Вот несколько распространенных сценариев использования:

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

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

  • Создание/обновление/очистка сигналов на основе определенных условий.

  • Запуск действий на основе событий жизненного цикла устройства. Например, создание оповещения, если устройство находится в режиме онлайн/оффлайн.

  • Загрузка дополнительных данных, необходимых для обработки. Например, порогового значения температуры устройства, которое определено в атрибуте владельца устройства.

  • Запуск вызовов REST API во внешние системы.

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

  • Обработка событий в соответствии с настройками в аккаунте пользователя.

  • Вызовы RPC на основе определенных условий.

  • Интеграция с внешними системами, через Kafka, MQTT, REST API и т. д.