Sākums Izpētīt Palīdzība
Pierakstīties
kennyh
/
emqx4.3
1
0
Atdalīts 0
Faili Problēmas 0 Izmaiņu pieprasījumi 0 Vikivietne
Koks: fb7c7dffb7
Atzari Tagi
emqx4.3
/
apps
/
emqx_rule_engine
Xinyu Liu 21fe7f01ee Merge pull request #7624 from DDDHuang/fix_api_params 3 gadi atpakaļ
..
etc b3d9605722 chore(conf): EMQ X -> EMQX in conf files 4 gadi atpakaļ
include a892ff9006 fix(dialyzer): update the specs for the rule() 4 gadi atpakaļ
src 21fe7f01ee Merge pull request #7624 from DDDHuang/fix_api_params 3 gadi atpakaļ
test e4b62f3a5f feat: add rule-engine functions 3 gadi atpakaļ
.gitignore 4a877a3a69 chore(apps): relocate some apps 5 gadi atpakaļ
README.md 1be3eb1446 chore: rename EMQX Broker to just EMQX 4 gadi atpakaļ
rebar.config 82e3565344 chore: major mode file variable for Emacs 4 gadi atpakaļ

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;