History

Zaiming (Stone) Shi 2065be569e fix(emqx_cluster_rpc): fail fast on stale state Due to: * Cluster RPC MFA is not idempotent! * There is a lack of rollback for callback's side-effects For instance, when two nodes try to add a cluster-singleton concurrently, one of them will have to wait for the table lock then try to catch-up, then try to apply MFA. The catch-up will have the singleton created, but the initiated initiated multicall apply will fail causing the commit to rollback, but not to 'undo' the singleton creation. Later, the retries will fail indefinitely.		2022-06-12 20:18:48 +02:00
..
etc	feat: generate a minimized emqx.conf	2022-05-31 19:20:27 +08:00
i18n	refactor(rule): rename outputs -> actions	2022-05-25 17:02:37 +08:00
include	refactor(rule): rename outputs -> actions	2022-05-25 17:02:37 +08:00
src	fix(emqx_cluster_rpc): fail fast on stale state	2022-06-12 20:18:48 +02:00
test	fix: add telemetry testcases in all/0	2022-05-25 21:55:28 +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;