Почетна Преглед Помоћ
Пријавите се
kennyh
/
emqx4.3
1
0
Креирај огранак 0
Датотеке Дискусије 0 Захтеви за спајање 0 Вики
Дрво: 093da2d8cf
Гране Ознаке
emqx4.3
/
apps
/
emqx_rule_engine
Zaiming (Stone) Shi b398617614 chore: bump app versions пре 3 година
..
etc 8aa60cc0a5 feat: generate a minimized emqx.conf пре 3 година
i18n f3df2c80d8 feat: add user_properties arg for republish action пре 3 година
include ca52b8eb29 fix: start connector-mqtt failed when username/password not provided пре 3 година
src b398617614 chore: bump app versions пре 3 година
test 7ee53e5319 Merge tag 'v5.0.11' into dev/ee5.0 пре 3 година
.gitignore 4a877a3a69 chore(apps): relocate some apps пре 5 година
README.md 1be3eb1446 chore: rename EMQX Broker to just EMQX пре 4 година
rebar.config ebe4d7c3fb refactor: stop releasing edge edition пре 3 година

README.md

emqx-rule-engine

IoT Rule Engine

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;