技术中心

ELINKS 数据入库工具

订阅 MQTT 数据,自动写入 MySQL / SQL Server 数据库

ELINKS 是老马数据开发的轻量级 MQTT 数据入库工具,专为 ELINK 网关配套设计。无需编写代码,通过简单配置即可将 ELINK 网关推送的注塑机、CNC 机床、PLC 设备数据自动写入数据库,帮助工厂快速建立生产数据存储中心。

文档修订:2026-10-14,仅表示本文整理日期,不代表软件版本或运行环境验证日期。

功能特点

  • 订阅 MQTT 数据:连接 MQTT Broker,自动订阅指定主题,实时接收网关推送的设备数据
  • 自动入库:将收到的 JSON 数据解析后写入 MySQL 或 SQL Server 数据库,支持自定义表结构映射
  • 多数据库支持:兼容 MySQL、SQL Server,覆盖常见工厂信息化环境
  • 免编程配置:通过配置文件设置数据库连接、MQTT 地址、主题订阅和字段映射,无需二次开发
  • 断线重连:MQTT 或数据库连接断开后自动尝试重连;中断期间的数据能否恢复,需结合网关缓存、MQTT 会话和数据库写入配置验证,不能仅凭重连判断数据完整性
  • Windows 运行:支持 Windows 系统,可注册为系统服务后台运行

适用场景

场景 说明
已有 MES/ERP 系统 数据直接入库,MES 系统读取数据库即可获取设备数据
自建数据看板 数据落库后用 Excel、Power BI 或自研系统做可视化
历史数据留存 SPC 过程数据按模次存储,支持品质追溯查询
调机记录归档 工艺参数变更数据自动入库,形成完整调机日志

开始前先确认

  1. 确认设备采用的注塑机网关、CNC 网关或 PLC 网关,并明确需要入库的主题与字段。
  2. 先用调试工具订阅实际 MQTT 报文;注塑机报文可对照数据字典与 JSON 示例。
  3. 按安装包文档配置目标数据库和字段映射,先用测试表验证字段值与写入结果,再接入业务系统。
  4. 对断线恢复、重复消息和写入失败分别检查处理结果,将已验证的行为列入项目交付说明。

配置说明

ELINKS 通过 config.json 文件配置。下面展示连接信息示例;配置项和字段映射方式请对照安装包文档,地址、主题和数据库账号应替换为实际配置:

{
  "mqtt": {
    "broker": "mqtt://127.0.0.1:1883",
    "topics": ["prefix/+/spc", "prefix/+/realtime"]
  },
  "database": {
    "type": "mysql",
    "host": "127.0.0.1",
    "port": 3306,
    "name": "factory_db",
    "user": "root",
    "password": "your_password"
  }
}

下载

ELINKS 安装包:elinks.zip

运行环境和安装步骤以安装包文档为准。请先在目标 Windows 环境试运行,确认 MQTT 收数与数据库写入结果。

如需技术支持或定制开发,请联系我们,提供网关型号、主题样例、目标数据库类型和需要入库的字段。设备选型见产品中心,联调工具见常用工具下载。