北向应用
南向驱动完成数据采集后，数据的去向决定北向应用的选型。EMQX Neuron 提供四类去向，各自对应一种典型的工厂场景。
| 使用场景 | 对应应用 |
|---|---|
| 数据上云 总部或云平台要汇总多个工厂的数据 | MQTT · AWS IoT · Azure IoT |
| 对接工业物联网平台（统一命名空间） 让平台自动认出设备，新增设备不用改平台配置 | Sparkplug B |
| 对接上位系统 SCADA、MES、组态软件要从网关取数，且不改造这些系统 | OPC UA Server · WebSocket |
| 接入大数据与边缘计算 进数据湖做长期分析，或先在边缘过滤聚合 | Kafka · 规则引擎应用 |
前三类由 EMQX Neuron 主动上报数据；对接上位系统方向相反，由厂内系统作为客户端接入读取。各类别对反向控制的支持情况见下表。
通用步骤
所有北向应用的配置流程一致：
数据以组为单位上报。一个应用可订阅多个采集组，同一采集组亦可被多个应用订阅，即同一份数据可同时上报至云平台、供上位系统读取并写入数据平台。
能力对比
应用 | 数据方向 | 反控设备 | 断网缓存 | 安全 |
|---|---|---|---|---|
| MQTT | 主动上报 | 写请求 / 写响应主题 | 支持 | TLS、双向认证 |
| Sparkplug B | 主动上报 | NCMD / DCMD 命令 | 支持 | TLS、双向认证 |
| AWS IoT | 主动上报 | 写请求 / 写响应主题 | 支持 | 设备证书 |
| Azure IoT | 主动上报 | 云到设备（C2D）消息 | 支持 | SAS 令牌、X.509 证书 |
| OPC UA Server | 被动取数 | 客户端直接写变量节点 | — | 安全策略、证书、用户名密码 |
| WebSocket | 主动上报 | 不支持 | — | wss、双向认证 |
| Kafka | 主动上报 | 不支持（仅生产者） | — | SASL、TLS |
| 规则引擎应用 | 内部 | Neuron Sink 写回 | — | — |
TIP
除北向应用外，EMQX Neuron 还提供 RESTful API 读写点位，见 HTTP API。
下一步
- 上报前需要加工数据 —— 过滤、降采样、聚合或统一字段名，见数据处理。
- 确认数据已经上报 —— 在应用卡片查看
send_msgs_total，见订阅南向数据 · 验证。 - 上线后的监控与告警 —— 见运维。