(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211084842.0 (22)申请日 2022.09.06 (71)申请人 中国移动通信集团广东有限公司 地址 510000 广东省广州市天河区珠 江西 路11号 申请人 广东电网有限责任公司广州供电局 　 中国南方电网有限责任公司 (72)发明人 凌雨诗　王莉　汤淇捷　王维　 刘鹏　孙磊　王浩　王敏　陈永涛　 朱海龙　 (74)专利代理 机构 北京三巨人知识产权代理事 务所(普通 合伙) 16024 专利代理师 付春霞 (51)Int.Cl. G06F 9/50(2006.01)G06F 9/54(2006.01) G06Q 50/06(2012.01) (54)发明名称 一种电网数据解耦方法 (57)摘要 本发明公开一种电网数据解耦 方法， 涉及数 据处理领域。 该电网数据解耦方法包括电网数据 解耦装置和数据解耦 方法， 所述电网数据解耦装 置包括数据输入单元、 数据处理单元和解耦单 元， 所述数据解耦方法包括获取数据、 基于预设 的拆分规则， 对获取的数据进行拆分、 发送数据 至分布式消息队列、 通过资源调度策略对消息队 列进行管 理、 对消息队列中的拆分数据进行时序 校正。 该电网数据解耦 方法在有限的硬件资源条 件下， 大规模部署的业务终端出现投递的数据量 超出主站常规处理能力的情况时， 能够缓解数据 集中处理压力， 保证主站的处理及时， 数据处理 更快， 处理效率高， 保证电网数据解耦装置的使 用效果好。 权利要求书2页 说明书4页 附图2页 CN 115373855 A 2022.11.22 CN 115373855 A 1.一种电网数据解耦方法， 包括电网数据解耦装置(1)和数据解耦方法， 其特 征在于： 所述电网数据解耦装置(1)包括： 数据输入单 元(101)， 设置 于所述电网数据解耦装置(1)的内部； 数据处理单元(102)， 设置于所述电网数据解耦装置(1)的内部并与数据输入单元 (101)相连； 解耦单元(103)， 设置于所述电网数据解耦装置(1)的内部并与数据处理单元(102)相 连； 所述数据解耦方法包括： 获取数据(S1)； 基于预设的拆分规则， 对获取的数据进行拆分(S2)； 发送数据至分布式消息队列(S3)； 通过资源调度策略对消息队列进行 管理(S4)； 对消息队列中的拆分数据进行时序校正(S5)。 2.根据权利要求1所述的一种电网数据解耦方法， 其特征在于： 通过对数据中不同类型 数据的不同路径的执行周期进行分析， 基于数据的执行速率， 在获取 的数据的不同执行速 率的区域插 入解耦单 元(103)进行缓存解耦。 3.根据权利要求1所述的一种电网数据解耦方法， 其特征在于： 基于数据的类型， 每个 数据包具有一个数据标识， 该数据标识用于表征该数据包的类型， 使数据按照其数据标识 的特征， 拆分为多路可以各自独立执行 的进程， 根据数据标识和预设的各数据通道的通道 标识之间的对应关系， 确定每个数据包对应的目标数据通道， 根据通道标识和数据标识， 为 拆分的数据包按 预设的对应关系分配数据通道， 并将数据包通过该数据通道分别发送至分 布式消息队列中排队发送。 4.根据权利要求1所述的一种电网数据解耦方法， 其特征在于： 按容量调度方式， 为不 同的业务终端分配预设的容量， 容量存放在资源池 里， 当有多余的容量资源， 共享出来并按 先排队在使用的原则， 供消息队列中其 他业务终端的数据使用。 5.根据权利要求1所述的一种电网数据解耦方法， 其特征在于： 按优先级加权算法对消 息队列进行管理， 通过统计消息队列中的排列数据的执行节点任务并非数量、 任务完成进 度、 时间段内CPU负载情况和内存剩 余量信息， 若数量、 任务完成进度、 时间段内CPU负载情 况和内存剩余量均达到阈值， 为对应的数据分配一个权重值， 用以区分数据 处理的优先等 级， 权重值较大 的数据作业被视为比较重要的任务， 其能够执行任务的数量和优先程度都 比权重小的数据作业要 多。 6.根据权利要求5所述的一种电网数据解耦方法， 其特征在于： 根据部分已经完成的任 务， 来评估该作业所属任务在系统运行所消 耗的时间， 并优先运行结束时间最晚任务的后 备任务， 以通过预计任务结束时间来判断是否针对该任务启动后备任务， 预估的任务剩余 时间比任务的进度值更能反映出不同作业运行任务之 间的快慢程度， 即可控制后备任务上 限值， 进而限定后备任务的最大值， 以避免后备任务的数量过多而影响对新作业的响应能 力。 7.根据权利要求1所述的一种电网数据解耦方法， 其特征在于： 预先记录原始数据中各 个拆分数据的初始 时序， 基于该初始 时序， 核对该分布式消息队列中的各拆分数据的当前权　利　要　求　书 1/2 页 2 CN 115373855 A 2时序， 进行时序矫正， 且在拆分数据的当前时序与初始时序不一致时， 按初始时序更新该拆 分数据的当前时序， 以维持各拆分数据在该分布式消息队列中的当前时序与初始时序的一 致性， 该分布式消息队列中的拆分数据按照其加载于该分布式消息队列中的当前时序进 行 排序， 形成该 数据发送序列表， 以保证数据处 理之后能够可靠 重组。权　利　要　求　书 2/2 页 3 CN 115373855 A 3