(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211219849.9 (22)申请日 2022.10.08 (71)申请人 国网江西省电力有限公司信息通信 分公司 地址 330000 江西省南昌市青山湖区昌东 大道7077号科研通信楼821室 (72)发明人 余腾龙　胡潇　刘显明　 (74)专利代理 机构 北京众合诚成知识产权代理 有限公司 1 1246 专利代理师 王焕巧 (51)Int.Cl. G06F 16/903(2019.01) G06F 16/27(2019.01) G06F 16/2455(2019.01) G06F 16/23(2019.01) (54)发明名称 一种电网量测数据动态归集方法、 系统及存 储介质 (57)摘要 本发明公开了一种电网量测数据动态归集 方法、 系统及存储介质， 方法包括： 事件 特征预定 义， 以便识别特定事件， 其中事件特征至少包括 设备运行状态、 电能表标识， 其中特定事件至少 包括正常请求、 异常请求、 慢响应； 流式识别驱动 的事件判定； 基于事件判定结果， 完成一定时间 周期内数据冻结、 数据接入、 监测； 通过一致性模 型及唯一标识机制对各类型数据进行对齐和汇 总。 本发明能够解决对电网大批量量测数据的动 态接入、 实时同步、 常态化 监测的问题。 权利要求书2页 说明书5页 附图4页 CN 115292561 A 2022.11.04 CN 115292561 A 1.一种电网量测数据动态归集方法， 其特 征在于： 包括以下步骤： 步骤1： 事件特征预定义； 事件特征用于识别特定事件， 同时通过正则表达式和字符串 匹配制定事 件匹配规则； 步骤2： 流式识别驱动的事件判定； 根据事件匹配规则、 缓存机制和流计算模型， 及时发 现包含事件特征的数据流， 给 出相应的事 件判定结果； 步骤3： 相关操作； 根据步骤2给出的事件判定结果， 对数据进行相关操作， 包括： 数据冻 结、 数据接入和监测； 步骤4： 数据对齐及汇总； 对于接入的数据， 通过一致性模型和唯一标识机制进行验证、 对齐、 汇总和同步； 并通过一致性模型和唯一标识机制对数据进 行常态化监测， 确保数据的 有效性和完整性。 2.根据权利要求1所述的一种电网量测数据动态归集方法， 其特 征在于： 步骤1所述的事件特征预定义， 包括特定事件特征预定义和事件匹配规则制定， 具体 为： 特定事件意为数据接入过程中可能发生的事件， 事件特征用于识别特定事件； 根据智 能电网数据共享的需求以及用电采集系统的运行模型， 特定事件定义使用唯一标识符标 识， 至少包括 正常请求、 异常请求、 慢响应， 事 件特征至少包括设备运行状态、 电能表标识； 事件匹配规则采用正则表达式和字符串匹配； 根据定义好的特定事件和事件特征， 制 定事件匹配规则， 其中正常请求标识0， 异常请求标识1， 慢响应标识 2。 3.根据权利要求1所述的一种电网量测数据动态归集方法， 其特 征在于： 步骤2所述的流式识别驱动的事 件判定， 具体为： 采用事件匹配规则、 缓存机制和流计算模型对数据不间断进行特定事件判定， 采用事 件识别算法， 给出事件判定结果， 事件判定结果使用唯一标识符标识， 用于决定对数据的后 续操作； 所述事件识别算法， 输入为数据流， 输出为存放事件判定结果Set和数据相关标识符； 所述事件识别算法以匹配数据流信息与事件特征定义， 匹配成功则给出事件判定结果， 匹 配失败则加入错 误列表； 所述缓存机制， 基于多线程的多节点缓存和高效获取机制， 采用OpenTracing机制， 并 采用Hash B结果来存储缓存。 4.根据权利要求1所述的一种电网量测数据动态归集方法， 其特 征在于： 步骤3所述的相关操作， 包括数据冻结、 数据接入和监测， 具体为： 数据冻结适用于用电采集系统每15分钟冻结数据规则； 数据接入适用于满足接入条件 的数据， 采用B  Tree索引算法高速接入数据； 监测表示通过一致性模型和唯一标识机制 对 所有进行识别的数据进行常态化 监测， 确保其完整并有效。 5.根据权利要求1所述的一种电网量测数据动态归集方法， 其特 征在于： 步骤4所述的数据对齐及汇总， 包括： 数据汇总 、 归并和同步， 具体为： 对于步骤3 中进行数据接入操作的数据， 通过一致性模型和唯一标识机制， 对数据进行 汇总、 归并， 其中汇总适用于所有数据， 归并适用于同源同构数据， 通过广播方式对数据情 况进行同步； 所述的数据汇总， 包括对 事件判定结果的汇总和对同源同构数据的对齐和汇总；权　利　要　求　书 1/2 页 2 CN 115292561 A 2所述的数据同步， 通过广播方式， 更新数据标识符， 使得同步接收到常态化监测 的结 果。 6.一种电网量测数据动态归集系统， 所述归集系统用于实现权利要求1 ‑5任一项所述 的一种电网量测数据动态归集方法， 其特征在于： 包括： 特征预定义单元、 事件判定单元、 操 作单元； 特征预定义单元用于定义特定事件的事件特征， 事件特征至少包括设备运行状态、 电 能表标识， 并通过正则表达式和字符串匹配自动生成事 件匹配规则； 事件判定单元用于识别事件， 应用事件匹配规则和流计算模型实现事件识别算法， 通 过缓存机制存储并输出事件判定结果， 事件匹配过程中标识符为0的事件为正常请求事件， 直接给出事件判定结果， 标识符为 1或2的事件为异常情况， 需要加入缓存队列， 广播并进 行 2次判定； 操作单元用于完成数据的动态接入、 实时同步和常态化 监测。 7.一种计算机可读存储介质， 其特征在于： 所述的计算机可读存储介质上存储有计算 机程序， 所述的计算机程序被处 理器运行时执 行权利要求1至 5任一项所述方法的步骤。权　利　要　求　书 2/2 页 3 CN 115292561 A 3