02 youtube官網網頁版設置簽名失敗請檢查mqtt broker(EMQ X 規則引擎系列 （八）橋接消息到 MQTT Broker)

點擊 發送 按鈕，發送成功后查看得到當前規則已命中統計值為 1。

命令行中查看數據表記錄得到數據如下：

至此，我們通過規則引擎實現了使用規則引擎橋接消息到 MQTT Broker 的業務開發。

準備另外一臺 emqx 節點，啟動兩臺 emqx。

打開 EMQ X Dashboard，進入左側菜單的 資源 頁面，點擊 新建 按鈕，鍵入 EMQ X 服務器信息進行資源創建。

EMQ X 集群中節點所在網絡環境可能互不相通，資源創建成功后點擊列表中 狀態按鈕 ，查看各個節點資源連接狀況，如果節點上資源不可用，請檢查配置是否正確、網絡連通性，并點擊 重連 按鈕手動重連。

進入左側菜單的 規則 頁面，點擊 新建 按鈕，進行規則創建。這里選擇觸發事件 消息發布 ，在消息發布時觸發該規則進行數據處理。

選定觸發事件后，我們可在界面上看到可選字段及示例 SQL：

規則引擎使用 SQL 語句處理規則條件，該業務中我們需要將 payload 中所有字段單獨選擇出來，使用 payload.fieldName 格式進行選擇，還需要消息上下文的 topic 、 qos 、 id 信息，當前 SQL 如下：

使用 SQL 語句 WHERE 字句進行條件篩選，該業務中我們需要定義兩個條件：

組合上一步驟得到 SQL 如下：

借助 SQL 測試功能，我們可以實時查看當前 SQL 處理后的數據輸出，該功能需要我們指定 payload 等模擬原始數據。

payload 數據如下，注意更改 tachometer 數值大小，以滿足 SQL 條件：

點擊 SQL 測試 切換按鈕，更改 topic 與 payload 為場景中的信息，點擊 測試 按鈕查看數據輸出：

測試輸出數據為：

測試輸出與預期相符，我們可以進行后續步驟。

SQL 條件輸入輸出無誤后，我們繼續添加相應動作，配置寫入 SQL 語句，將篩選結果橋接到另一個 EMQ X。

點擊響應動作中的 添加 按鈕，選擇 橋接數據到 MQTT Broker 動作，選取剛剛選定的資源。

我們成功創建了一條規則，包含一個處理動作，動作期望效果如下：

切換到 工具 --> Websocket 頁面，使用任意信息客戶端連接到 EMQ X，連接成功后在 消息 卡片發送如下信息：

點擊 發送 按鈕，發送成功后查看得到當前規則已命中統計值為 1。

使用命令行中查看數據表記錄得到數據如下：

至此，我們通過規則引擎實現了使用規則引擎橋接消息的業務開發。

很赞哦!（83）