iot裝置上報資料中,需要幫助我們去刷選出符合我們業務需求的資料,例如電量小於30%、多裝置通訊需要知道裝置的上下線狀態等。
emq提供了開源的規則引擎,使用webhook資料型別,將資料傳送到web服務。企業版支援更多方式。
下圖是emq規則引擎架構 :
基於sql、動態配置emqx訊息流與裝置事件的處理、響應規則,進行訊息儲存、事件處理。
當裝置傳送訊息時,訊息路由正常流轉,發布到訊息訂閱者應用上,與此同時emq還會將訊息流轉到規則引擎,規則引擎進行刷選、匹配、處理,最後將符合條件的資料進行輸出到mysql、http等動作裡面。
十餘種,例儲存到mysql、**到kafka、redis、http等
更多emq規則引擎介紹詳見文件 : 官方文件
首先在emq的dashboard頁面建立規則,$events/client_connected為裝置上線事件、$events/client_disconnected為裝置下線事件。兩者應在from字句後。
mysql 規則引擎 為什麼使用規則引擎？
一天，朱斯參加了一場code review研討會。會上的一群人正在討論著如何對祖傳 進行變更，大家你一言，我一語,場面十分熱鬧！突然，只見人群中的乙個人滿面愁容，說道 昨天在專案中看到下面這樣一段 分支太多了！維護起來很煩啊！if day 周一 else if day 周二 else if day ...
規則引擎pyke
1.官網 2.安裝第三方包 pyenv global anaconda3 4.2.0 pip install htmltemplate 3.原始碼安裝pyke pyenv global anaconda3 4.2.0 cd pyke3 1.1.1 python setup.py build pyth...
規則引擎 easy rules
直接看官方的例子。經典的例子 大致的步驟 建立各種規則，即rule.可以通過 pojo 或 rulebuilder api 兩種方式建立。建立規則容器rules rules new rules 註冊建立的規則rules.add rule 建立流，即facts.流控制規則的引數輸入.facts fac...