背景信息

北向通道

北向通道指设备数据的上报通道。 现场设备接入边缘智能节点（一体机）后，设备数据将由节点采集。只有在节点上部署了北向通道，才能使节点采集的数据上报给不同类型的业务应用进行消费。

sink 节点

北向通道可将采集的设备数据流式传输到多种目标系统（在边缘智能称为 “sink”，表示数据接收方）进行数据处理。目前支持的数据接收方（sink）包括：Kafka 消息流平台、MQTT Broker 服务器、InfluxDB 数据库、RESTful API 终端。

准备工作

• 已将节点绑定到边缘智能项目。具体内容，请参见绑定节点。

• 根据业务需要，您可以在同一个北向通道中配置不同类型的 sink 节点。关于不同类型 sink 节点的说明及相关的准备工作请参见下表。

  sink 类型	说明	环境搭建
  rest	将边缘侧设备的属性数据发送到一个 RESTful API，通常用于与 HTTP/HTTPS 协议兼容的服务进行交互。	您已经搭建 Web 服务，并获取了 Web 服务的 Url。
  kafka	将边缘侧设备的属性数据上报到 Kafka 消息系统进行处理。	您已经搭建了 Kafka 系统并获取了 Kafka 系统的以下参数值：Brokers、topic。
  influx2	将边缘侧设备的属性数据上报到 InfluxDB 2.x 数据库进行实时分析。	您已经搭建了 InfluxDB 数据库并获取了 InfluxDB 数据库的以下参数值：Url、Organization、Bucket、Measurement、Token。
  influx	将边缘侧设备的属性数据上报到 InfluxDB 1.x 数据库进行实时分析。	您已经搭建了 InfluxDB 数据库并获取了 InfluxDB 数据库的以下参数值：Url、Database、Measurement。
  mqtt	将边缘侧设备的属性数据上报到 MQTT 代理服务器的主题进行处理。	您已经搭建了 MQTT 服务器，并获取了 MQTT 服务器的以下参数值： MQTT 代理服务器地址 、Topic。

前提条件

升级一体机到 2.7.0 及以上版本。具体内容，请参见升级节点软件。

操作步骤

1. 登录边缘智能控制台。

2. 在左侧导航栏顶部的 我的项目 区域，选择您的项目。

3. 在左侧导航栏，选择 设备管理 > 北向通道。

4. 在 北向通道 页面，单击 创建北向通道。

5. 在 创建北向通道 页面，根据以下配置说明完成相关配置。

   区域	配置项	说明
   基本信息	名称	为北向通道设置一个名称。输入要求如下： 允许使用英文大小写字母、数字、下划线（_）、连字符（-）。长度不超过 32 个字符。 开头和结尾不允许使用特殊字符（下划线（_）、连字符（-）），并且不允许使用连续的特殊字符。
   	描述	为北向通道添加描述信息。长度不超过 128 个字符。
   数据源配置	节点	选择一个或多个节点。 北向通道将部署到您选择的节点上。
   	设备模板	选择一个或全部的设备模板。
   	驱动模板	选择一个或全部的驱动模板。
   	设备实例	选择一个或全部的设备实例。 节点将采集使用了所选设备模板和驱动模板的设备实例的数据，并通过北向通道传输到 sink 节点。
   sink节点配置	名称	为 sink 节点设置一个名称。
   	sink类型	根据接收数据的目标系统，选择对应的 sink 节点类型。支持选择： rest kafka influx2 influx mqtt
   	参数配置	系统根据您选择的 sink 类型，会自动生成对应的参数配置模板。您可以根据需要配置所需参数。相关内容，请参见sink 节点参数配置说明。
   	连通性测试	单击 连通性测试，检查节点和 sink 节点之间的网络连接是否通畅。

6. 如果您需要将采集到的数据发送到不同的系统或服务进行进一步的处理，您可以单击 添加sink节点，继续添加其他 sink 节点。

7. 完成以上配置后，单击右下角的 保存。
   系统将在节点上部署北向通道。您可以在 北向通道 页面查看部署 状态，待北向通道的状态由 创建中 变为 运行中 后，表示该北向通道已部署成功。
   

sink 节点参数配置说明

根据选择的 sink 类型，您需要配置相关的参数。本节介绍不同 sink 类型的参数配置说明、示例以及部署成功北向通道后，您如何来验证通道已正常工作。

rest

参数说明

• url：您的 Web 服务的 http/https 访问地址。

配置示例

## RESTful API 终端地址，例如 https://www.example.com/api/dummy
url = "http://xx.xx.xx.xx:8000"

验证方法

如果您的 Web 服务接收到来自边缘智能节点的数据，表示通道在正常工作。

kafka

参数说明

配置示例

## Kafka brokers 的 URL 列表
brokers = "192.168.1.100:9092,192.168.1.101:9092,192.168.1.102:9092"
## 订阅主题
topic = "my_kafka_topic"
## Kafka 的 Sasl 认证类型，可设置为 none, plain, scram-256, scram-512。默认为 none。
saslAuthType = "none"

验证方法

通道部署成功后，您可以登录 Kafka 服务查看数据。当您在 Kafka 服务中查看到节点上报的设备运行数据，表示通道在正常工作。

influx2

参数说明

配置示例

# InfluxDB v2 服务器地址，假设使用默认端口 8086
addr = "http://localhost:8086"

# InfluxDB 组织名称
org = "my-organization"

# InfluxDB bucket 名称
bucket = "my-bucket-name"

# 测量名称，表示数据的类型或分类
measurement = "sensor-data"

# InfluxDB API 令牌
token = "my-api-token"

# 时间戳的精度，默认是毫秒
precision = "ms"

验证方法

通道部署成功后，您可以登录 InfluxDB 服务查看数据。当您在 InfluxDB 服务中查看到节点上报的设备运行数据，表示通道在正常工作。

mqtt

参数说明

配置示例

# MQTT 服务器地址
server = "tcp://mqtt.example.com:1883"

# MQTT 消息主题
topic = "home/analysis/result"

验证方法

通道部署成功后，您可以使用配置的连接信息连接到 MQTT 服务器，然后订阅配置的主题，以便开始接收消息。当您在 MQTT 服务中接收到节点上报的设备运行数据，表示通道在正常工作。

Influx

参数说明

配置示例

# InfluxDB v1.x 服务器地址
addr = "http://localhost:8086"
# InfluxDB 数据库名
database = "my_database"

# 数据的度量名称
measurement = "sensor_data"

# 时间戳的精度，默认为毫秒。
precision = "ms"

验证方法

通道部署成功后，您可以登录 InfluxDB 服务查看数据。当您在 InfluxDB 服务中查看到节点上报的设备运行数据，表示通道在正常工作。