摘要
本发明涉及大数据技术领域，尤其涉及基于大数据的仓储管理分析方法、系统及介质，包括异构数据实时采集、流批融合处理、AI智能决策、数字孪生验证和分级储存调度；本发明相对于现有技术采用分散式数据采集与延时批处理的方案，导致数据孤岛严重、决策依据滞后，本方案采用边缘协议转换网关与流批融合处理架构，通过MQTT统一接入工业设备实时数据流，联合DebeziumCDC捕获业务系统变更，由Kafka实现毫秒级数据集成，并借助Flink‑Spark混合引擎同步完成动态特征计算与深度模型训练；具有全要素实时映射与跨域数据协同的优势，打通设备层、业务层、环境层的信息壁垒，为仓储决策提供毫秒级鲜活的全局数据视图。
