Главная Обзор Помощь
Вход
kennyh
/
emqx4.3
1
0
Ответвить 0
Файлы Задачи 0 Запросы на слияние 0 Вики
Дерево: ea1bf58a2d
Ветки Метки
emqx4.3
/
apps
/
emqx_rule_engine
Zaiming (Stone) Shi 667d66eb1e docs(README): EMQ X -> EMQX 4 лет назад
..
etc b063b6f253 feat(rules): support configure rules in config file 4 лет назад
include 63167cea70 chore: update copyright 4 лет назад
src f5415589e9 chore(schema): use emqx_schema:qos() instead of union integer. 4 лет назад
test b69dca4f08 feat(rule): add testcase for '/delivery_dropped' 4 лет назад
.gitignore 4a877a3a69 chore(apps): relocate some apps 5 лет назад
README.md 667d66eb1e docs(README): EMQ X -> EMQX 4 лет назад
rebar.config 82e3565344 chore: major mode file variable for Emacs 4 лет назад

README.md

emqx-rule-engine

IoT Rule Engine for EMQX Broker.

Concept

iot rule "Rule Name"
  when
     match TopicFilters and Conditions
  select
    para1 = val1
    para2 = val2
  then
    take action(#{para2 => val1, #para2 => val2})

Architecture

          |-----------------|
 Pub ---->| Message Routing |----> Sub
          |-----------------|
               |     /|\
              \|/     |
          |-----------------|
          |   Rule Engine   |
          |-----------------|
               |      |
        Backends Services Bridges

SQL for Rule query statement

select id, time, temperature as t from "topic/a" where t > 50;