一种基于Flink的设备状态实时计算方法及系统

本发明涉及设备状态监控与管理技术领域,公开了一种基于Flink的设备状态实时计算方法，包括以下步骤：S1、获取设备的实时数据，所述设备的实时数据包括设备的运行参数和外部环境数据；S2、将所述设备的实时数据传输至Flink集群进行流式数据处理，还提供一种基于Flink的设备状态实时计算系统，包括：数据采集模块，用于获取设备的实时数据，包括设备的电压、电流和温度数据以及外部环境数据。本发明通过结合深度学习、扩展卡尔曼滤波和深度强化学习，智能化地优化告警触发策略，动态调整告警阈值，提高了设备状态监控的精确和时效，并减少了误报和漏报。