中间件与驱动
eKuiper
厂商/来源:
EMQ / LF Edge
核心功能:
边缘侧的“SQL 引擎”。解决“只发报警数据,不发正常数据”的流量和存储痛点。
| 适用场景 | 边缘数据清洗(温度>50才上报)、异构数据合并(把 HTTP 和 MQTT 数据拼在一起)、简单的 AI 推理调度 |
| 架构支持 | 超轻量 (核心包 < 10MB)。完美运行在 OpenWrt 路由器、树莓派甚至 128MB 内存的工业网关上。 |
| 核心价值 | SQL 语法:你不需要写 C 代码来过滤数据。只需要写 SELECT temperature FROM mqtt_stream WHERE temperature > 50。 它会自动订阅 MQTT,过滤数据,然后发给云端。 |
| 对接情报 | Sink (下沉目标):支持把处理结果直接写入 InfluxDB、Kafka、或者调用 HTTP 接口控制设备。 |
| 避坑指南 | [格式严格] 1. JSON 解析失败:eKuiper 默认处理 JSON 格式。如果传感器发上来的是 Hex 字符串(如 Modbus 原始报文),SQL 无法处理。对策:先用 Telegraf 或 Neuron 解析成 JSON,或者编写 eKuiper 的 Golang 插件来解码。 2. 规则风暴:如果你在一个 1 核的网关上跑了 100 条复杂的 SQL 规则(带 Window 时间窗口聚合),CPU 会瞬间 100%。对策:边缘侧只做简单过滤,复杂聚合交给云端。 |
| 推荐搭配 | [Neuron (采集)] [EMQX (消息总线)] |