一种基于流处理的电能计量装置在线异常诊断方法及系统

摘要

本发明公开了一种基于流处理的电能计量装置在线异常诊断方法及系统；步骤：计量异常分析数据获取步骤：从用电信息采集系统的数据库中获取异常分析所需的数据；逻辑链生成步骤：生成多种单一异常诊断逻辑链；流处理控制步骤：对单一异常诊断逻辑链处理，将结果存储到流处理状态存储模块中；根据流处理状态存储模块中更新的各流处理工作节点的负载状态信息，均衡的向流处理工作节点分配处理任务；流处理工作步骤：完成对电能计量装置的单一异常诊断，实现多个流处理工作节点的并行处理；异常关联诊断步骤：进行关联诊断，生成计量异常诊断结果和运维建议，并发送给用电信息采集系统；实现了对电能计量装置的快速在线异常诊断。

主权项

一种基于流处理的电能计量装置在线异常诊断方法，其特征是，包括如下步骤：步骤(1)：计量异常分析数据获取步骤：根据从计量异常诊断规则库中获取的单一异常诊断规则对用电信息采集系统中待抽取的数据进行配置，从用电信息采集系统的数据库中获取异常分析所需的数据，存入计量异常分析数据库；步骤(2)：逻辑链生成步骤：根据单一异常诊断规则生成多种单一异常诊断逻辑链；步骤(3)：流处理控制步骤：接收逻辑链生成步骤提交的单一异常诊断逻辑链，对单一异常诊断逻辑链做序列化处理，根据序列化处理产生的逻辑块，为单一异常诊断逻辑链分配处理任务，并将处理结果存储到流处理状态存储模块中；还根据流处理状态存储模块中更新的各流处理工作节点的负载状态信息，均衡的向流处理工作节点分配处理任务；步骤(4)：流处理工作步骤：运行单一异常诊断逻辑链中的各项处理任务，实时地将各流处理工作节点的负载状态信息存储到流处理状态存储模块中，完成对电能计量装置的单一异常诊断，实现多个流处理工作节点的并行处理；步骤(5)：异常关联诊断步骤：在单一异常诊断结果的基础上，进行进一步的关联诊断，生成计量异常诊断结果和运维建议，并发送给用电信息采集系统。