一种并行处理系统
    1.
    发明公开

    公开(公告)号:CN109508354A

    公开(公告)日:2019-03-22

    申请号:CN201811115764.X

    申请日:2018-09-25

    Abstract: 本发明提供了一种并行处理系统,能够根据模型实现并行采集数据的实时高效并行处理,并写入实时库。本发明架构主要包括分组并行采集,基于kafka的高性能总线,scada处理集群,模型服务及实时库集群。利用kafka分组、复制,弹性架构等技术实现了scada集群的天然负载均衡,scada集群依据模型信息对分组并行采集数据进行实时高速处理,模型服务采用完整数据对等服务集群模式,通过Haproxy实现软件负载均衡,使得scada集群可以动态、均衡获取模型信息,实时库采用redis集群,实现实时数据的高效写入。

    一种支持动态扩展的电网监控系统

    公开(公告)号:CN112260398A

    公开(公告)日:2021-01-22

    申请号:CN202010989326.7

    申请日:2020-09-18

    Abstract: 本发明公开了一种支持动态扩展的电网监控系统,包括:终端设备从电网设备采集电网运行信息并转换为数据量;前置服务收集终端设备采集的数据并发送给SCADA服务;SCADA服务接收前置服务上送的数据进行处理,并将处理后的数据存储到实时库中;配置库存储配置数据;前置服务、SCADA服务通过消息总线进行通信,消息总线将前置服务与SCADA服务解耦,使得前置服务或SCADA服务的重新启动不影响SCADA服务或前置服务;当终端服务数据分批接入时,后接入数据通过增加前置服务和SCADA服务来处理,正在运行的前置和SCADA服务不受影响。通过将前置服务和SCADA服务解耦,使得二者之一重新启动时不会相应另一个服务,提高了电网监控系统的稳定性。

    一种支持动态扩展的电网监控系统

    公开(公告)号:CN112260398B

    公开(公告)日:2024-05-28

    申请号:CN202010989326.7

    申请日:2020-09-18

    Abstract: 本发明公开了一种支持动态扩展的电网监控系统,包括:终端设备从电网设备采集电网运行信息并转换为数据量;前置服务收集终端设备采集的数据并发送给SCADA服务;SCADA服务接收前置服务上送的数据进行处理,并将处理后的数据存储到实时库中;配置库存储配置数据;前置服务、SCADA服务通过消息总线进行通信,消息总线将前置服务与SCADA服务解耦,使得前置服务或SCADA服务的重新启动不影响SCADA服务或前置服务;当终端服务数据分批接入时,后接入数据通过增加前置服务和SCADA服务来处理,正在运行的前置和SCADA服务不受影响。通过将前置服务和SCADA服务解耦,使得二者之一重新启动时不会相应另一个服务,提高了电网监控系统的稳定性。

    一种配电网系统海量数据通讯处理方法及系统

    公开(公告)号:CN105245579A

    公开(公告)日:2016-01-13

    申请号:CN201510589862.7

    申请日:2015-09-16

    CPC classification number: H04L67/1002 H04L41/0246 H04L67/2828

    Abstract: 本发明涉及一种配电网系统海量数据通讯处理方法及系统,该方法包括:节点管理服务从配置库中读取全部配置信息;根据配置信息,分别启动规约链路服务、规约处理服务、数据处理服务及数据分发服务,并根据预设匹配规则,对所述规约链路服务和规约处理服务进行匹配;数据上行时,数据源依次经过规约链路服务、规约处理服务及数据处理服务处理后存入内存数据池,最后根据数据订阅信息,由数据分发服务转发至应用;数据下行时,应用发送的指令信息由数据分发服务器发送至内存数据池,再经规约处理服务处理通过规约链路服务发送至对应数据源。本发明的方法提升了单独通讯节点的通讯能力,通讯节点内部扩展性强,提高了通讯节点通讯的可靠性。

    一种配电网系统海量数据通讯处理方法及系统

    公开(公告)号:CN105245579B

    公开(公告)日:2018-08-03

    申请号:CN201510589862.7

    申请日:2015-09-16

    Abstract: 本发明涉及种配电网系统海量数据通讯处理方法及系统,该方法包括:节点管理服务从配置库中读取全部配置信息;根据配置信息,分别启动规约链路服务、规约处理服务、数据处理服务及数据分发服务,并根据预设匹配规则,对所述规约链路服务和规约处理服务进行匹配;数据上行时,数据源依次经过规约链路服务、规约处理服务及数据处理服务处理后存入内存数据池,最后根据数据订阅信息,由数据分发服务转发至应用;数据下行时,应用发送的指令信息由数据分发服务器发送至内存数据池,再经规约处理服务处理通过规约链路服务发送至对应数据源。本发明的方法提升了单独通讯节点的通讯能力,通讯节点内部扩展性强,提高了通讯节点通讯的可靠性。

    一种分布式监控数据传输系统

    公开(公告)号:CN105207352A

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

    申请号:CN201510536837.2

    申请日:2015-08-27

    Abstract: 本发明涉及一种分布式监控数据传输系统。所述分布式监控数据传输系统包括一个远程监控中心,至少一个前置机和若干个数据采集装置。其中,每个前置机连接至少两个数据采集装置,所述系统中采用ZeroMQ技术中的PUB-SUB模式,分别在数据采集装置中设置ZeroMQ_PUB套接字,在前置机中设置ZeroMQ_PUB和ZeroMQ_SUB套接字,在远程监控中心中设置ZeroMQ_SUB套接字。由于设备采用分布式布局方式,待监测的数据不受地理约束,本发明实现了数据的传输不受地理条件约束,即便设备采用分布式布局的方式,获取的数据的方位不确定,也可以准确的采集到数据。

    一种基于MapReduce的监控数据优先预取处理方法

    公开(公告)号:CN104331464A

    公开(公告)日:2015-02-04

    申请号:CN201410604052.X

    申请日:2014-10-31

    CPC classification number: G06F9/5038 G06F9/4843

    Abstract: 本发明涉及一种基于MapReduce的监控数据优先预取处理方法,属于软件工程技术领域。本发明在原有电网监控系统的基础上改变客户\服务器模式,采用MapReduce对监控数据量进行处理,通过对资源数据的预取,将数据集经过节点预选找到空闲节点作为候选工作计算节点,再通过任务预选,预先选出待预取的map任务,综合前两个预选完成数据的优先预选,提高了系统的运行效率,并且利用该方法可以实现方便、灵活的拓展,而不需要对原有的系统进行改造,在使用的便利性上也有了很大的进步。

    一种电网监控系统实时数据库的数据同步方法

    公开(公告)号:CN104331425A

    公开(公告)日:2015-02-04

    申请号:CN201410557105.7

    申请日:2014-10-20

    CPC classification number: G06F16/27

    Abstract: 本发明涉及一种电网监控系统实时数据库的数据同步方法,属于数据库研究技术领域。本发明通过配置需要同步的实时库名称及其所属主机名,在系统初启动时,主机先将自身指定实时库的内容完全恢复给备机,完成第一次的主备机数据同步,当主机有新数据被写入而发生改变后,将检测到的新入库数据实时复制给备机,完成同步。本发明解决了分布在不同设备的数据同步,且本发明中备机不接受直接写入操作,保证了数据完全与主机一致。同时,由于备机不需要写入实时数据,则备机上的业务处理程序也不需要实际运行,降低了备机的资源占用以及主备机业务处理程序同时出现异常的可能性。

Patent Agency Ranking