(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210979574.2 (22)申请日 2022.08.16 (71)申请人 成都长城开发科技股份有限公司 地址 611731 四川省成 都市高新区天全路 99号 (72)发明人 覃有仪　吕杰勤　 (74)专利代理 机构 成都九鼎天元知识产权代理 有限公司 51214 专利代理师 罗强 (51)Int.Cl. G06F 16/215(2019.01) G06F 16/25(2019.01) G06F 40/226(2020.01) G06F 9/455(2006.01) G06F 9/54(2006.01) (54)发明名称 一种基于内存和表达式的实时计量数据校 验方法及系统 (57)摘要 本发明提供了一种基于内存和表达式的实 时计量数据校验 方法及系统， 其特征在于， 包括： 将采集的计量设备数据存入消息队列； 在JVM内 存中启动实时校验服务， 获取消息队列的数据， 解析出数据对应的设备号， 并基于设备号从数据 库中获取对应的校验规则， 对数据进行校验， 再 根据校验结果将计量设备数据分类存入数据库 中。 本发明将实时校验与基于算数表达式的规则 配置进行有效的结合， 既极大的提升了校验速 度， 又支持非常灵活的增加、 减少、 修改校验规 则。 权利要求书1页 说明书8页 附图1页 CN 115422172 A 2022.12.02 CN 115422172 A 1.一种基于内存和表达式的实时计量数据校验方法， 其特 征在于， 包括： 将采集的计量设备 数据存入消息队列； 在JVM内存中启动实时校验服务， 获取消息队列的数据， 解析出数据对应的设备号， 并 基于设备号从数据库中获取对应的校验规则， 对数据进行校验， 再根据校验结果将计量设 备数据分类存 入数据库中。 2.根据权利要求1所述的基于 内存和表达 式的实时计量数据校验方法， 其特征在于， 所 述数据库存 储有多条校验所需的校验规则， 且可根据需求进行配置 。 3.根据权利要求1或2所述的基于内存和表达式的实时计量数据校验方法， 其特征在 于， 所述校验规则包含规则内容和作用域， 规则内容用于校验 数据， 作用域表明适用该规则 的计量设备类型或设备号； 其中， 作用域 为空表示所有计量设备均需遵守该规则。 4.根据权利要求1所述的基于 内存和表达 式的实时计量数据校验方法， 其特征在于， 所 述规则内容分为算术表达式规则与逻辑表达式规则， 算术表达式规则用于判断数据之 间的 关系， 包含各数据间的关系， 也包含数据与自身统计数据的关系； 逻辑表达式规则用于判断 数据的正确与错 误。 5.根据权利要求1所述的基于 内存和表达 式的实时计量数据校验方法， 其特征在于， 所 述校验规则包括简单校验规则， 对同一条消息内部数据进行校验， 用于判断某项参数是否 在设定的范围内或是否为空以及两个数据项之间的大小关系。 6.根据权利要求4所述的基于 内存和表达 式的实时计量数据校验方法， 其特征在于， 所 述校验规则包括中等复杂度校验规则， 用于判断两个消息中数据项的关系。 7.根据权利要求4所述的基于 内存和表达 式的实时计量数据校验方法， 其特征在于， 所 述校验规则还 包括复杂校验规则， 以历史 统计数据作为支撑， 校验计量数据是否参数突变。 8.根据权利要求6所述的基于 内存和表达 式的实时计量数据校验方法， 其特征在于， 对 于简单校验规则、 中等复杂度校验规则， 直接通过实时校验服务完成计量数据校验； 对于复 杂校验规则， 则 在JVM空间中由实时校验主线程与实时校验子线程共同完成数据校验， 实时 校验子线程首次启动时从数据库中加载历史统计数据， 提供给实时校验服务主线程， 实时 校验主线程执行校验过程， 实时校验子线程 根据校验后的数据实时更新相关数据。 9.一种基于内存和表达式的实时计量数据校验系统， 其特 征在于， 包括： 采集源头， 用于采集计量设备的计量数据； 消息队列， 用于存放计量数据； 实时校验模块， 运行在JVM内存中， 实时获取消息队列中的计量数据， 并调用数据库中 的校验规则对计量数据进行 校验， 将校验结果发送至数据库； 数据库， 用于存放计量数据的校验结果以及配置和存放校验规则。 10.根据权利要求9所述的基于内存和表达式的实时计量数据校验系统， 其特征在于， 还包括实时校验子模块， 运行在JVM内存中， 从数据库中加载历史统计数据， 供实时校验模 块调用进行计量数据的校验， 并根据校验后的数据实时更新相关数据。权　利　要　求　书 1/1 页 2 CN 115422172 A 2一种基于内存和表达式的实时计量数据校验方 法及系统 技术领域 [0001]本发明涉及数据校验领域， 特别涉及一种基于内存和表达式的实时计量数据校验 方法及系统 背景技术 [0002]当前随着物联网技术的发展， 公共设施服务商(电网公司， 自来水公司， 天然气公 司)都在陆续采用新型的智能计量设备， 用于为用户提供更好的服务， 同时降低自身的损 耗， 这就需要采集大量的智能电表计量数据， 但是计量数据整体特征是传输环节链路较长， 同时还有一些不规范 的操作， 用户的一些不规范行为， 导致在整个数据链路上各个环节都 可能产生异常的数据； 常见的错 误数据主 要包含以下几种类别： [0003]1、 设备内部错误； 2、 采集编解码错误， 3、 用户异常行为(如试图窃电， 短路， 高压， 忘关开关等)； 在计量行业内， 传统的异常数据校验实现方式主要是离线校验， 通过状态 区 分数据是否已经通过校验， 具体流程如下： 1.统一将数据先存到一个数据库 表中， 存储时采 用一个字段用于捕获该表的变化； 2.使用定时器任务采用各种规则进行校验， 将校验结果 进行标记。 [0004]传统的方法劣势为： 1.性能瓶颈： 同一张表同时存在插入Insert， 读取Read， 更新 Update等三种操作， Insert操作提升速度的方式为减少索引， 而Read， Update需要增加索引 提高查询 速度， 其本身速度无法同时优化， 在设备数量较大 的情况下， 如上千万级别设备， 需要非常大的硬件资源才能达到性能指标。 2.无法充分利用IO， CPU， 由于定时调度， 其处理 存在间歇性， 其形状如一根根尖刺， 对计算资源机器不友好。 传统的方法优势： 由于使离线 计算， 校验所用数据视图更广泛， 可以充分利用结构化语句进 行判断， 即单个校验规则可以 是较复杂的规则。 发明内容 [0005]针对现有技术中存在的问题， 提供了一种基于内存和表达式的实时计量数据校验 方法及系统， 既能提升数据校验的速度， 又能支持类似于 离线校验的复杂规则的配置 。 [0006]本发明采用的技术方案如下： 一种基于内存和表达式的实时计量数据校验方法， 包括： [0007]将采集的计量设备 数据存入消息队列； [0008]在JVM内存中启动实时校验服务， 获取消息队列的数据， 解析出数据对应的设备 号， 并基于 设备号从数据库中获取对应的校验规则， 对数据进 行校验， 再根据校验结果将 计 量设备数据分类存 入数据库中。 [0009]进一步的， 所述数据库存 储有多条校验所需的校验规则， 且可根据需求进行配置 。 [0010]进一步的， 所述校验规则包含规则内容和 作用域， 规则内容用于校验数据， 作用域 表明适用该规则的计量设备类型或设备号； 其中， 作用域为空表示所有计量设备均需遵守 该规则。说　明　书 1/8 页 3 CN 115422172 A 3