Начало Каталог Помощ
Вход
kennyh
/
emqx4.3
1
0
Разклонения 0
Файлове Задачи 0 Заявки за сливане 0 Уики
ИН на ревизия: 9de609224e
Клонове Маркери
emqx4.3
/
apps
/
emqx_rule_engine
Xinyu Liu 866810cea6 Merge pull request #8006 from emqx/copy-of-kjell/jq/timeout преди 3 години
..
etc 05032467bd feat(rule_engine): default timeout for jq/2 and jq/3 with timeout преди 3 години
i18n 866810cea6 Merge pull request #8006 from emqx/copy-of-kjell/jq/timeout преди 3 години
include 02c3f87b31 style: reformat all remaining apps преди 3 години
src 866810cea6 Merge pull request #8006 from emqx/copy-of-kjell/jq/timeout преди 3 години
test 866810cea6 Merge pull request #8006 from emqx/copy-of-kjell/jq/timeout преди 3 години
.gitignore 4a877a3a69 chore(apps): relocate some apps преди 5 години
README.md 1be3eb1446 chore: rename EMQX Broker to just EMQX преди 4 години
rebar.config 74c33cd4e5 feat(rule_engine): add jq function to the rule engine преди 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;