创建北向应用

北向应用用于把 Atlas 已采集到的南向数据继续转发、存储或交给流处理引擎处理。
通常使用方式是：

1. 创建并配置南向设备，完成数据采集；
2. 创建北向应用；
3. 为北向应用添加订阅，把指定南向设备的组数据转发给该应用；
4. 在北向应用侧查看转发、存储或调度结果。

当前支持的北向应用

Atlas 当前主程序集成了以下北向插件：

• MQTT：将组数据发布到外部 MQTT Broker，也支持后台订阅外部 MQTT 主题。
• eKuiper：把采集数据写入 eKuiper，供规则引擎做流处理、联动和告警。
• Scheduler：与 eKuiper 配合使用，用于承载调度规则并接收调度结果，再转成 /telecontrol/{node}/{group}/{tag} 控制消息。
• InfluxDBv3：将采集数据写入 InfluxDB v3，用于历史指标存储、查询和监控展示。
• DataStorage：Atlas 内置本地数据存储，用于保存点位最新值与历史值。

添加北向应用

以 MQTT 为例，创建北向应用的基本步骤如下：

1. 进入 设置 -> 数据采集 -> 北向应用；
2. 点击右上角 新增北向应用；
3. 在弹窗中填写：
   • 名称：北向应用的唯一名称，例如 mqtt
   • 插件：选择目标插件，例如 MQTT
4. 点击 创建；
5. 进入应用配置页面，填写该插件所需的连接参数；
6. 提交配置后，再为该应用添加订阅。

设置北向应用参数

创建北向应用后，进入应用配置页面设置连接参数。不同插件的参数不同，例如：

• MQTT：Broker 地址、端口、客户端 ID、主题等
• eKuiper：eKuiper 服务地址与端口
• Scheduler：监听地址、端口以及调度规则
• InfluxDBv3：数据库、Token、Measurement、TLS 等

有关具体插件参数，请参考各插件自己的说明页面。

北向应用列表

在 北向应用 页面，可以用列表或卡片方式查看当前所有北向应用。常见操作如下：

• 名称：北向应用的唯一名称
• 配置：进入应用配置页面，修改连接参数
• 编辑：修改节点名称
• 数据统计：查看该应用的发送/接收统计
• DEBUG 日志：临时打开该节点的 DEBUG 级别日志
• 删除：删除该北向应用节点
• 工作状态切换：启动或停止该应用
• 连接状态：查看当前连接状态
• 插件：查看该应用所使用的插件名称

工作状态说明

当前北向应用的工作状态如下：

• 初始化：节点刚创建
• 就绪：配置完成但尚未启动
• 运行中：节点已启动并正在工作
• 停止：节点已停止

订阅南向数据

北向应用以“南向设备 + 组”为单位订阅数据。

创建北向应用后，点击该应用进入订阅页面，点击 添加订阅，选择要订阅的南向设备及组。

订阅项包含：

• 南向设备：要订阅的南向设备，例如 inverter-01
• 组：该设备下的组，例如 group1
• 附加参数：不同插件可根据需要填写自己的订阅参数

订阅建立后，Atlas 会把该组的 groupread 数据转发给北向应用。

运行与维护

数据统计

在北向应用列表中，可点击 数据统计 查看该应用的运行状态及消息统计。

关键字段说明如下：

参数	说明
send_msgs_total	发送消息总数
send_msg_errors_total	发送消息失败总数
recv_msgs_total	接收消息总数
link_state	连接状态：DISCONNECTED = 0，CONNECTED = 1
running_state	运行状态：INIT = 1，READY = 2，RUNNING = 3，STOPPED = 4

故障诊断

如果北向应用运行异常，可点击 DEBUG 日志 临时提高该节点日志级别。
之后可在页面顶部进入 维护 -> 系统配置 -> 日志 查看相关日志，进行故障诊断。

有关系统日志的详细说明，可参考 管理日志。