官方文檔：WebHook | EMQ Docs

一、啟用webhook和觸發規則

編輯webhook規則配置文件：/etc/emqx/plugins/emqx_web_hook.conf?

指定webhook的url位置：web.hook.url = http://127.0.0.1:5000/mqtt/webhook

增加消息推送事件規則：指定主題名稱為“a/b/c”進行推送，設備上下線推送

• web.hook.rule.client.connected.1 ? ? = {"action": "on_client_connected"}
• web.hook.rule.client.disconnected.1 ?= {"action": "on_client_disconnected"}?
• web.hook.rule.message.publish.1 = {"action": "on_message_publish", "topic": "a/b/c"}

在dashboard中啟用webhook插件:

二、使用flask編寫webhook

flask 連接Mysql：

flask 編寫數據庫模型

創建數據表：

?flask編寫webhook路由：

?三、測試

1、運行flask: flask run

?2、mqttclient連接，并推送數據至主題“a/b/c”

3、flask收到推送，打印相關信息

4、查看mysql，數據已經入庫

總結

以上是生活随笔為你收集整理的emqx使用webhook数据持久化到mysql的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。