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

龙图腾网获悉厦门安胜网络科技有限公司申请的专利一种基于Flink的流式数据质量监控方法及其系统获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN116126906B 。

龙图腾网通过国家知识产权局官网在2026-02-03发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202211254120.5，技术领域涉及：G06F16/2455；该发明授权一种基于Flink的流式数据质量监控方法及其系统是由许光锋;黄鹏雄;张建平;陈妙瑛;黄艺苹;蔡玲设计研发完成，并于2022-10-13向国家知识产权局提交的专利申请。

本一种基于Flink的流式数据质量监控方法及其系统在说明书摘要公布了：本发明提出了一种基于Flink的流式数据质量监控方法，包括：将预设生成的字段规则数据按照JSON的格式存储到数据库中；Flink启动任务，Flink程序读取数据库中的字段规则数据，解析JSON数据并缓存至内存中；当Flink解析完毕字段规则数据后，Flink程序开启消费消息队列的数据；Flink程序消费消息队列数据的同时，触发Flink程序启动消息队列处理数据量的监控，以进行统计当前时间处理的数据量；Flink通过FlinkSQL结合自定义算子对当前数据的情况进行分析；Flink程序对分析的当前数据情况进行统计，将统计的结果写入到数据库中。通过Flink的结合组件和设计算子可以对流式数据进行数据监控，在一定程度对流式数据质量进行保证和监控，且可以根据当前的业务情况通过自定义的算子和规则灵活改变。

本发明授权一种基于Flink的流式数据质量监控方法及其系统在权利要求书中公布了：1.一种基于Flink的流式数据质量监控方法，其特征在于，该方法包括如下步骤： S1、将预设生成的字段规则数据按照JSON的格式存储到数据库中； S2、Flink启动任务，Flink程序读取所述数据库中的所述字段规则数据，进一步解析JSON数据并缓存至内存中； S3、当Flink解析完毕所述字段规则数据后，所述Flink程序开启消费消息队列的数据； S4、所述Flink程序消费所述消息队列数据的同时，触发所述Flink程序启动所述消息队列处理数据量的监控，以进行统计当前时间处理的数据量； S5、Flink通过FlinkSQL结合自定义算子对当前数据的情况进行分析； S6、所述Flink程序对分析的当前数据情况进行统计，将统计的结果写入到所述数据库中； 其中，S4具体包括：S41、通过Flink的Metrics监控指标自定义CustomerJsonDeserialization类重写里面的initMertic方法；S42、根据Flink默认将获取信息上报的功能关系，进一步进行配置以实现Flink程序获取对应的监控信息； S5具体包括：S51、所述FlinkSQL通过Flink缓存的字段和对应的正则规则，通过不同的正则匹配来执行不同FinkSQL的语句，分析当前数据的情况；S52、所述Flink自定义的算子对常用情况及其字段的关联字段是否符合进行检测。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人厦门安胜网络科技有限公司，其通讯地址为：361008 福建省厦门市集美区软件园三期诚毅大街358号1502-5单元；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

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