Skip to main content

通过 Kafka 进行设备预配置

概述​

通过 Node-RED 进行设备数据流转发的核心目的是为已使用 Kafka 作为消息中间件的系统提供一个可视化、低代码的数据流桥接方案，将 Kafka 主题中的设备数据经过可选的处理后，转发至 MQTT 协议接口，从而接入 Neuron 数据平台。

tip

该方法适用于需要快速实现 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。