数据采集平台

新建 MQTT 连接

点击 MQTT 后的“新建连接”，进入创建 MQTT 协议连接页面。

填写 MQTT 协议连接基本信息：

• 连接名称：输入 MQTT 连接的名称，支持中文和英文。注意：不可与列表中已有连接重名，不可为空，不可包含空格，最大长度为 50。

• 服务器地址：输入 MQTT 服务器的 IP 地址或域名。

• 端口：输入 MQTT 服务器监听的端口号。MQTT 默认端口为 1883（非加密连接），但根据服务器的配置，可能使用其他端口。注意：有效值为 1-65535 的整数。

• 用户名/密码：输入 MQTT 服务器的用户名和密码。其中密码支持明文和暗文两种输入模式。

新建 Kafka 连接

编辑连接

点击编辑连接对应的符号，进入编辑页面，对连接信息进行修改。

删除连接

新增 MQTT 订阅

点击新增订阅，进入创建订阅页面。

输入订阅基本信息：

• 订阅名称：输入 MQTT 连接的名称，支持中文和英文，不可与列表中已有连接重名。

• 订阅主题：输入 MQTT 服务器上的主题（Topic），MQTT 服务器会根据订阅的主题来过滤并分发消息给相应的订阅者。

• 节点：指定处理订阅消息的节点。如果未指定，则默认为当前操作的节点。在多节点环境中，此选项允许用户灵活地将消息处理任务分配给不同的节点。

• 是否需要点位解析：选择是否需要对接收到的消息进行点位解析。点位解析是指将接收到的数据按照特定的规则或模板进行解析，以提取出有用的数据点或字段，并将这些数据点或字段存储到流表中供后续处理或分析。

  • 无需点位解析时（即使用默认解析模板 saveJsonMsg），仅需填入流表名称（系统将自动创建流表），系统会将订阅到的数据以完整的字符串形式存入指定的流表中，不进行 JSON 解析。

    
    

    

    
    

  • 需要进行点位解析时，需要选择解析模板，可选自定义模板或内置模板，并填写相应模板参数。其中自定义解析模板的输出流表需要用户自行创建。

    
    

    

    
    

• 接收缓冲区大小：设置接收缓冲区的大小，以控制一次接收消息的最大数据量。如果未设置，系统将使用默认值 20480 字节。

点击确定即可完成订阅。

新增 Kafka 订阅

相较 MQTT，Kafka 订阅无需设置接收缓冲区大小，增加了分区、偏移量以及消费者参数配置项。

• 分区与偏移量需同时设置，或者均不设置。有效值为非负整数。

• 消费者参数和值由用户自行配置，可参考此文档。

  • group.id 是必须配置的参数，用于标识消费者所属的消费组。

  • 设置偏移量与分区时，group.id 参数会失效。

  • 点击增加消费参数配置，可配置其他参数。

    
    

    

    
    

对停用的订阅可以进行编辑或者删除操作。已启用的订阅需先停用后才能进行编辑或删除。

点击编辑，进入修改订阅页面，对订阅信息进行修改。修改后将默认按照更新时间对订阅进行排序。