买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉中船重工(武汉)凌久高科有限公司申请的专利一种基于Flinkx的能源设备流式数据质量检测方法获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN115935148B 。

龙图腾网通过国家知识产权局官网在2025-11-21发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202211536623.1，技术领域涉及：G06F18/15；该发明授权一种基于Flinkx的能源设备流式数据质量检测方法是由范俊甫;杨志祥;郭朝霞;刘鑫;谢倩;皮辉设计研发完成，并于2022-12-01向国家知识产权局提交的专利申请。

本一种基于Flinkx的能源设备流式数据质量检测方法在说明书摘要公布了：本发明适用于Flinkx数据同步领域，提供一种基于Flinkx的能源设备流式数据质量检测方法，本发明方法首先初始化Flinkxjob任务，并构建source读取端读取待质检数据，然后创建规则引擎处理端处理待质检数据，然后通过sink写入端写入校验结果流数据和统计结果流数据；本发明基于Flinkx流批一体计算框架，对能源管控实时流数据高效处理，保证数据高吞吐、低延迟和一致性；且基于Flinkx提供checkpoint机制，实现数据断电续传，极大提高数据处理效率，避免数据重复处理；另外，本发明的规则引擎处理端采用Rete算法正向推理快速校验待质检的数据，保证数据在高吞吐、低延迟下，校验的稳定性。

本发明授权一种基于Flinkx的能源设备流式数据质量检测方法在权利要求书中公布了：1.一种基于Flinkx的能源设备流式数据质量检测方法，其特征在于，所方法包括下述步骤： 步骤S1、创建一个Flinkxjob任务并进行初始化任务配置； 步骤S2、创建一个source读取端，通过source读取端从kafka消息队列中读取能源设备的待质检数据； 步骤S3、创建一个ruleSolve规则引擎处理端，根据预先设置的质检规则对所述待质检数据进行质量校验并输出校验结果流和统计结果流； 步骤S4、创建两个sink写入端，其中一个sink写入端接收到校验结果流后写入存储介质，另一个sink写入端接收到统计结果流后写入存储介质； 所述步骤S1具体过程如下：创建一个Flinkxjob任务，解析FlinkxJob脚本获取reader插件详细配置、writer插件详细配置、setting信息，然后初始化任务配置，其中初始化任务配置包括开启checkpoint机制、配置切分键、配置readerChannel并发度以及配置writerChannel并发度； 其中当开启checkpoint机制后，Flinkxjob任务通过checkpoint机制实现断点续传，具体将source读取端上一次消费kafka消息队列中待质检数据的偏移量通知下一次任务source读取端实现断电续传； 当配置readerChannel并发度后，FlinkxJob任务根据readerChannel并发度值大小，触发多个source读取端并发读取待质检数据； 当配置writerChannel并发度后，FlinkxJob任务根据writerChannel并发度值大小，触发多个sink写入端并发写入校验结果流和统计结果流； 所述步骤S3中，ruleSolve规则引擎处理端的质检规则包括虚拟字段规则和质量检测规则，所述虚拟字段规则为还未绑定待质检数据的字段的规则，所述质量检测规则为已经绑定待质检数据的字段的规则；ruleSolve规则引擎处理端根据所述质检规则构建一个Rete网络，通过Rete算法正向推理快速校验待质检数据，并输出校验结果流和统计结果流至sink写入端； 其中所述校验结果流包含正确和错误数据，统计结果流包含待检查数据总数、待检查规则总数、每个规则质检错误数据总数。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人中船重工(武汉)凌久高科有限公司，其通讯地址为：430000 湖北省武汉市洪山区关山街珞瑜路718号；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

以上内容由龙图腾AI智能生成。