打通数据流转的每一公里

产品定位

数据集成平台是工业现场与上层应用之间的数据枢纽：一头连接现场的每一种协议，一头把清洗后的数据稳定送达数据底座。它的设计信条是——数据流转的每一公里，都应当可视化、可监控、可恢复。

解决什么问题

采集脚本散落。 十台服务器上跑着没人敢动的脚本，交接靠口口相传。平台用可视化规则编排替代脚本：拖拽连线即流程，50+ 内置节点组件按订阅、读取、网络、处理、发布、存储六组组织，覆盖数据流转全环节。

断点靠人发现。 网络抖一下，数据悄悄丢了，月底对账才发现。平台内置 LMDB 本地高性能存储：网络中断时未发送数据自动本地持久化，恢复后自动断点续传，报文携带采集时间戳保证乱序可控；离线数据（Topic、重试次数、待发送量）全程可查、可人工干预。

问题定位靠猜。 规则 → 节点 → 点位的多级质量监控逐级下钻，接收/转换/发送的六维统计实时可见，异常数据自动归档——从“大海捞针”到“顺藤摸瓜”。

核心能力详解

全协议采集，南北向兼容

主流工业协议开箱即用（Modbus TCP、OPC UA、IEC104、SNMP、CoAP），覆盖 PLC、DCS、智能仪表、电力设备；消息通道全面打通（MQTT v3/v5、Kafka、RocketMQ、RabbitMQ）；数据库直连覆盖主流关系库、时序库与 Redis。SOURCE/TARGET 双模式驱动让同一资源既可采集也可下发，数据双向流动。

可视化规则编排

基于图编辑引擎的拖拽式设计器连线即流程；JavaScript（GraalJS）/Groovy 脚本、Beetl 模板、路由、过滤、限流、打包等处理节点自由组合；四种转换模式（透传/SQL/脚本/插件）从简单转发到复杂加工皆能胜任。数据模拟向导四步完成设备数据仿真，没有真实设备也能调通链路。

插件化与集群

标准 SPI 插件接口打包为独立 JAR、放入 plugins/ 目录即插即用无需重启——私有协议与定制逻辑沉淀为插件资产。Akka Cluster 集群支持种子节点自动发现与弹性扩展，规则运行态经 Distributed Data 自动同步；单机/集群一键切换，从边缘网关到数据中心按需伸缩。

企业级运维与信创

监控大屏实时统计采集点位、吞吐、延迟与错误率；开放 Prometheus 指标与 OpenTelemetry 全链路追踪；一键备份恢复。双模式数据库：企业模式采用人大金仓（信创合规），轻量模式内嵌 SQLite 边缘零运维。

常见问题

采集规模上限？——4 核 8GB 单实例可稳定支撑约一万点位（视采样周期与规则复杂度），多实例线性扩展。

能跑在边缘网关上吗？——能：轻量模式单机零运维，规则随集群模式平滑上移。

协议矩阵：接得进来是第一步

可靠性是设计出来的

• 断点续传：现场侧本地缓存（LMDB 嵌入式存储），网络恢复后自动补传，弱网与孤立网络不丢数；
• 集群采集：采集节点按 Akka 集群编排，节点故障自动接管，采集任务不停摆；
• 链路可观测：每个采集通道的速率、延迟、错误计数实时呈现，异常自动告警——『断点靠人盯』成为历史；
• 插件化扩展：新协议以插件 SPI 接入，不动核心框架；GraalJS 脚本规则在安全沙箱内加工数据，改脚本不重启服务。

振动等高频信号的特征计算

对振动、声学等高频信号，平台在采集侧即完成特征值计算（有效值/峭度/峰峰值/包络谱特征），只上送特征与时序——带宽省一个数量级，分析所需的信号信息不损失。