一种多源异构数据处理方法

本发明提供的一种多源异构数据处理方法，通过可扩展协议转换模块实现设备数据标准化，基于Flink流引擎与WarpStream组件构建混合处理管道，通过Checkpoint机制保障状态一致性，并采用动态并行度调整策略应对数据流量波动，混合使用多阶段数据融合策略，实现生产数据的深度挖掘和高效处理，从而降低数据融合误差率，降低异常检测漏检率。