公开(公告)号：CN115543737A

公开(公告)日：2022-12-30

申请号：CN202211170828.2

申请日：2022-09-23

申请人： 国电南瑞科技股份有限公司 ,  国网电力科学研究院有限公司

发明人： 王玉军 ,  郑晓露 ,  张辽 ,  陈鹏 ,  赵虎 ,  郑磊 ,  范昌春 ,  崔伟业 ,  张瑞

IPC分类号： G06F11/30 ,  G06F9/48

摘要： 本发明公开了一种电力自动化系统历史数据分布式采样方法，获取采样任务，根据采样任务匹配采样执行器；根据采样的应用场景、设备类型、设备采样量测类型从实时数据缓存集群获取不同的采样测点集合；将采样测点集合平均分配给采样执行器；采样执行器从实时数据缓存集群中读取实时值；采样执行器将实时值写入历史数据存储。本发明提供的一种电力自动化系统历史数据分布式采样方法，解决了数据规模、吞吐量、可扩展性等方面的瓶颈问题，满足业务规模和数据量不断扩展的需求。

公开(公告)号：CN118363769A

公开(公告)日：2024-07-19

申请号：CN202311341698.9

申请日：2023-10-16

申请人： 国电南瑞科技股份有限公司

发明人： 张辽 ,  郑晓露 ,  王玉军 ,  马德超 ,  魏春雷 ,  张河

IPC分类号： G06F9/54 ,  G06F16/21 ,  G06F16/2455 ,  G06Q50/06

摘要： 本发明公开了一种基于消息中间件的历史量测数据在线迁移方法及系统，该方法通过读取服务器上的采样测点文件获取待查询的采样测点集合，根据查询任务量将所述采样测点集合拆分成若干个测点集合；采用多线程并发查询的方式，查询每个测点集合中每个采样测点对应的历史量测数据；将所述历史量测数据进行序列化得到序列化数据，将所述序列化数据发送至消息中间件的指定主题；消息中间件消费者订阅该指定主题对所述序列化数据进行反序列化和解析得到解析数据，将所述解析数据存入时间序列数据库；本发明通过数据在线迁移方法，能够将电网运行中的历史量测数据迁移到时序数据库TSDB中，具备较高的可行性和可靠性，对在运系统的影响较小。

公开(公告)号：CN117112212A

公开(公告)日：2023-11-24

申请号：CN202311071781.9

申请日：2023-08-24

申请人： 国电南瑞科技股份有限公司

发明人： 张河 ,  马德超 ,  高原 ,  魏春雷 ,  张辽 ,  陈兴亮 ,  符鹏

IPC分类号： G06F9/50

摘要： 本发明公开了一种分布式任务分片方法，包括以下步骤：将待处理数据拆分为N个分片，每个分片固定的数据量为X；添加分片处理数据的索引，第n个分片对应的索引为(n‑1)X～nX‑1，n∈N，n∈Z；基于分片顺序依次添加任务节点编号Task(n)和任务节点标识；建立分片、索引、任务节点编号以及任务节点标识的映射关系；当处理数据发生变化时，根据数据变化的位置改变映射关系；对每次任务节点进行健康检测，根据实际的节点资源情况对其进行调整。本发明基于电力信息数据分片的状态与执行的有序性，当分片增加、减少或者执行节点新增、删除的情况下，最小化调整分片执行方式，减小分片重新建立的连接数，提升任务执行效率。

公开(公告)号：CN114764380A

公开(公告)日：2022-07-19

申请号：CN202110055020.9

申请日：2021-01-15

申请人： 国电南瑞科技股份有限公司 ,  国电南瑞南京控制系统有限公司

发明人： 向昊 ,  赵京虎 ,  马德超 ,  魏春雷 ,  张辽

IPC分类号： G06F11/20

摘要： 本发明公开一种基于ETCD的分布式集群控制方法和装置，集群内不同节点部署的CMServer服务启动后，向ETCD服务进行抢占式事务写操作，若成功，则成为CMServer主服务；Agent进程与CMServer主服务进行连接，定期监控Agent所在节点上启动的所有服务进程状态，发送节点服务进程的状态消息和心跳消息给CMServer主服务；将服务进程的状态消息更新存储在ETCD服务中的服务状态记录中，并刷新服务状态租约时间；若CMServer主服务检测到有服务状态租约过期，则判定和更新该服务为异常状态，并根据该服务的最新状态信息判断是否进行选主操作。本发明能自动发现异常和处理异常，效率高。