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

    公开(公告)号:CN105652232A

    公开(公告)日:2016-06-08

    申请号:CN201511020777.5

    申请日:2015-12-30

    IPC分类号: G01R35/04

    CPC分类号: G01R35/04

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

    基于主从模式的一厂多站有序用电控制系统及方法

    公开(公告)号:CN105680563A

    公开(公告)日:2016-06-15

    申请号:CN201511027986.2

    申请日:2015-12-30

    IPC分类号: H02J13/00 H02J3/00

    摘要: 本发明公开了基于主从模式的一厂多站有序用电控制系统及方法,包括:主站,负责将主终端控制模型下发给主终端;主终端,作为主控制节点,负责接收主站下发的主终端控制模型,并将主终端控制模型转发给从终端;同时接收从终端上传的采集数据;从终端,为小型负荷控制终端,主站不需要对从终端进行管理;从终端通过相应的控制模块与被控设备连接;从终端接入采集模块,实现厂区负荷的分散式采集,并将负荷数据上传至主终端;从终端具备继电器控制功能,在中短距离实现多路继电器控制,当实际投控时,从终端的被控设备根据控制轮次序列实现跳闸。实现在一个厂区内的面向统一限电指标的分站式控制,满足大范围厂区的负荷精细化控制需求。

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

    公开(公告)号:CN105652232B

    公开(公告)日:2018-04-06

    申请号:CN201511020777.5

    申请日:2015-12-30

    IPC分类号: G01R35/04

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

    一种适用于用电信息大数据计算的MapReduce作业依赖控制方法

    公开(公告)号:CN105184452A

    公开(公告)日:2015-12-23

    申请号:CN201510501437.8

    申请日:2015-08-14

    IPC分类号: G06Q10/06 G06Q50/06 G06F17/30

    摘要: 本发明公开了一种适用于用电信息大数据计算的MapReduce作业依赖控制方法,包括:获取计算服务所需的业务数据,形成数据文件;主节点动态分发计算服务,从节点负责MapReduce计算服务的执行;从节点读取计算服务所需要的用电信息数据;对作业间的数据依赖关系进行管理;作业依赖控制引擎按照指定的作业依赖关系,对作业进行执行和提交;数据处理单元完成用电信息大数据计算,得到业务数据,并将数据回写至应用系统的业务数据库。解决复杂用电大数据计算服务的作业依赖关系,满足在较短时间内完成用电信息大数据复杂计算的业务需求。能够及时高效地处理海量用电信息数据的复杂计算,为营销业务的开展提供可靠的数据支撑。

    基于迁移均衡策略的用电信息分布式文件存储方法与装置

    公开(公告)号:CN105183371A

    公开(公告)日:2015-12-23

    申请号:CN201510502666.1

    申请日:2015-08-14

    IPC分类号: G06F3/06 G06F17/30

    CPC分类号: Y02D10/45

    摘要: 本发明公开了基于迁移均衡策略的用电信息分布式文件存储方法与装置,数据采集模块将原始数据帧进行解析得到原始数据,以文件形式存入本地磁盘模块,将原始数据帧上传至关系数据库和MongoDB数据库;检测本地磁盘模块中文件的信息,选择是否将文件上传至数据存储模块;MongoDB数据库采用迁移均衡策略通过路由在mongos获取分片所在的节点负载,从数据量和负载两方面实现均衡;大数据管理引擎定时监测未进行数据转存计算的文件信息,将文件从MongoDB数据库提取,以时间为标签;将从MongoDB数据库提取到的文件数据转化为数据字符流,计算得到业务数据;最后进行数据持久化。实现用电信息大数据的高效存储,满足用电信息采集系统用电大数据存储容量、存储速率需求。