开源 · Apache NiFi · 2026
用 Apache NiFi 把机器数据送进 Power BI
- 问题
- 很多工厂每月一次在 Excel 里手工计算 OEE：等数字变差时，已经没人记得发生了什么，而且每个班组长记录停机的方式都不一样。
- 我做了什么
- 一个使用虚构数据的完整数据管道：三台模拟机器通过 MQTT 发布运行或停机状态、停机原因以及良品和不良品数量。Apache NiFi 2 读取消息，按模式校验 JSON，执行业务规则，从 PostgreSQL 主数据表补充班次和机器名称后写入数据库。错误消息进入错误队列，并注明原因。
- 结果
- 按机器和班次的 OEE（可用率 × 性能 × 质量）、按原因的停机时间和废品率，都由 SQL 视图直接提供给 Power BI。只需一条
docker compose up命令，约两分钟即可启动；测试中 12,960 条历史消息无一丢失。附带 JSON 格式的 NiFi 流程模板，以及 NiFi 扩展指南：背压、队列优先级以及何时需要集群。
Apache NiFi 2 · MQTT · PostgreSQL · Power BI · Python · Docker
相关服务: 工厂 Power BI：OEE、停机与废品
如果你的团队有重复不断的工作，或者数据对不上，告诉我: info@arcedatalab.com