跳至主要内容

透過 Kafka 進行設備預配置

概述​

透過 Node-RED 進行設備數據流轉發的核心目的是為已使用 Kafka 作為訊息中介軟體的系統提供一個視覺化、低程式碼的數據流橋接方案，將 Kafka 主題中的設備數據經過可選的處理後，轉發至 MQTT 協議介面，從而接入 Neuron 數據平台。

提示

該方法適用於需要快速實現 Kafka 與 MQTT 之間協議轉換與數據路由，且希望以靈活的、圖形化程式設計方式而非純程式碼開發來建構數據管道的場景，尤其適合原型驗證或對複雜數據流處理需求不高的整合專案。

訪問方式與先決條件​

如何訪問​

安裝Node-RED的方法有很多種。本指南假設您具備基本的終端/命令列技能，並擁有伺服器的管理權限。 您可以在 YouTube 上找到一些常用的安裝說明： https://www.youtube.com/watch?v=TbXU3PRDN1w

安裝完畢後，透過本地或伺服器上部署的Node-RED實例進行訪問。

開始之前​

需要確保已具備伺服器管理員權限、已安裝Node.js執行環境，並且目標Kafka叢集與MQTT Broker的服務連線資訊及認證憑證已準備就緒。

Node-RED 操作​

步驟 1. 登入 Node-RED​

步驟 2. 安裝 Kafka 節點​

在使用者設定頁面找到相應的 "Kafka" 節點並下載。

步驟 3. 配置 Kafka 輸入節點​

從節點面板拖出 「kafka in」 節點，雙擊節點以配置 Kafka 服務的連線資訊。

步驟 4. 新增數據處理節點​

拖出 「function」 節點並將其與 Kafka 節點連接，用於實現數據解析或格式轉換邏輯。

步驟 5. 配置 MQTT 數據發佈​

最後，使用 「MQTT OUT」 節點連接到流程末端，配置 MQTT Server 及 Topic 資訊，將處理後的數據發佈至指定 MQTT Topic。

設備接入 Neuron 數據平台​

參照 MQTT設備接入 在Neuron平台註冊設備。

透過 MQTT 接入 Neuron 平台時，需要選擇與上文一致的 MQTT Server 及 Topic。