yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
emqx/apps/emqx_rule_engine
History
Kjell Winblad 9ea0147a8c feat(rule engine jq function): config for changing implementation 
This commit adds a rule engine configuration option for changing the
implementation module used for the rule engine function jq. The two
options are `jq_port` (uses Erlang port programs to interact with jq)
and `jq_nif` (uses an Erlang NIF library to interact with jq).

Thanks to @terry-xiaoyu (Xinyu Liu <506895667@qq.com>) for Chinese
translations
 		2022-09-22 09:02:30 +02:00
..
etc feat: generate a minimized emqx.conf 2022-05-31 19:20:27 +08:00
i18n feat(rule engine jq function): config for changing implementation 2022-09-22 09:02:30 +02:00
include refactor(rule): rename outputs -> actions 2022-05-25 17:02:37 +08:00
src feat(rule engine jq function): config for changing implementation 2022-09-22 09:02:30 +02:00
test feat: list rules support for pagination and fuzzy filtering 2022-07-25 09:36:08 +08:00
.gitignore chore(apps): relocate some apps 2021-02-19 11:24:41 +01:00
README.md chore: rename EMQX Broker to just EMQX 2022-02-19 12:51:34 +01:00
rebar.config refactor: stop releasing edge edition 2022-05-26 20:05:46 +02:00

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;