本文介绍了如何借助北向通道将边缘节点采集的设备属性数据上报到第三方 MQTT 服务器。

准备工作

1. 准备一个边缘节点，并完成模拟数据源。

   注意

   边缘智能软件版本必须在 v2.7.0 及以上。

2. 准备一个 MQTT broker。
   在本文中，我们使用免费的公共 MQTT broker 进行测试。

   注意

   请勿在生产环境中使用公共 MQTT broker，否则可能带来安全风险和导致业务停机。

3. 准备一个 MQTT client 工具。
   在本文中，我们使用 MQTTX。

4. 参照创建北向通道，创建一个北向通道。
   按以下方式配置数据源（source）和数据目的地（sink）：

   类型	配置项	说明
   数据源配置	节点	选择您的边缘节点。
   	设备模板	选择 全部。
   	驱动模板	选择 全部。
   	设备实例	选择您在模拟数据源操作中，接入到边缘节点的虚拟设备。
   sink 节点配置	sink 类型	选择 mqtt。
   	参数配置	server：设置为 tcp://broker.emqx.io:1883，即公共 MQTT broker 的地址。 topic：设置为 vei/device/data/report。

完成以上配置后，单击 连通性测试。确保连通性测试成功，然后单击 保存。

验证数据上报结果

准备工作完成后，北向通道将被部署到边缘节点。当北向通道正常运行时，虚拟设备的随机属性数据将被上报到 MQTT broker。您可以按以下方式进行验证：

1. 打开 MQTTX 客户端。
2. 连接到 MQTT broker（tcp://broker.emqx.io:1883）并订阅设备属性数据（vei/device/data/report）。

在客户端可以看到边缘节点上报到 MQTT broker 的设备属性数据。

配置示例

示例1：修改 MQTT 客户端参数

在生产环境中，如果您的 MQTT broker 对消息发送客户端有要求，您可按需修改以下客户端参数：clientId、protocolVersion、qos、retained、compression、username & password。
要修改消息发送客户端的参数，按以下方式配置：

1. 编辑北向通道。
2. 根据mqtt sink 参数说明修改 参数配置。
3. 完成 连通性测试，然后单击 保存。

北向通道保存后会自动重新部署。当修改后的北向通道正常运行时，您可以到 MQTTX 客户端验证结果。如果在 MQTTX 客户端可以正常收到设备属性数据，则表示参数修改成功。（边缘节点依据修改后的参数，成功连接到 MQTT broker 并发送设备属性数据到 MQTT broker。）

示例2：修改数据转发格式

默认情况下，边缘节点采集到的设备属性数据会以原始格式转发到目标 MQTT broker。如果目标 MQTT broker 需要特定的数据格式，您可以相应地修改数据转发格式。

• 边缘智能提供了 4 种预置的数据格式模板，包括 json-simplest、json-influx、csv、yaml。通过为 mqtt sink 配置相应的数据格式模板，采集到的原始数据会被转换成指定格式，然后转发至 MQTT broker。
• 如果预置的数据格式模板无法满足需求，您还可以自定义数据格式模板。

要修改数据转发格式，按以下方式配置：

• 方式1：使用预置数据格式模板
  1. 编辑北向通道。
  2. 设置 数据格式，选择一种预置的数据格式模板。
     要查看数据预览效果，您可以选择一个设备模板。对应数据格式在所选设备模板上的预览将被展示。
  3. 完成 连通性测试，然后单击 保存。
• 方式2：自定义数据格式模板
  1. 编辑北向通道。
  2. 在 参数配置 中增加 dataTemplate 参数，并定义该参数的值为数据格式转换逻辑。

     说明

     如需编写数据格式转换逻辑，可以参考设备数据采集 - 原始数据格式以及使用 Golang template。您也可以提交工单联系我们，以获取帮助。

     
  3. 完成 连通性测试，然后单击 保存。

修改数据转发格式后，您可前往 MQTTX 客户端进行验证。在最新接收到的数据中，如果数据格式符合预期，表示数据转发格式已经修改成功。

mqtt sink 参数说明

下表介绍了 mqtt sink 支持的所有参数。