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

龙图腾网获悉中国平安财产保险股份有限公司申请的专利基于Flink的实时报表生成方法与系统获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN115168472B 。

龙图腾网通过国家知识产权局官网在2025-11-21发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202210873540.5，技术领域涉及：G06F16/25；该发明授权基于Flink的实时报表生成方法与系统是由解培佩设计研发完成，并于2022-07-22向国家知识产权局提交的专利申请。

本基于Flink的实时报表生成方法与系统在说明书摘要公布了：本申请属于大数据实时计算技术领域，涉及一种基于Flink的实时报表生成方法，包括：当Flink作业产生的实时数据流时，传输实时数据流至Kafka业务系统；将Kafka业务系统接收的实时数据流写入Kafka业务系统的磁盘结构；通过ETL提取磁盘结构中的实时数据流到临时中间层进行转换处理，产生实时清单数据；发送实时清单数据至Druid数据库；当检测到数据查询操作时，识别数据查询操作的类型，根据确定的数据查询操作的类型产生对应的操作指令，根据操作指令提取Druid数据库中的Druid引擎生成实时报表；推送实时报表至前端平台。本申请还提供一种基于Flink的实时报表生成系统、计算机设备及其存储介质。

本发明授权基于Flink的实时报表生成方法与系统在权利要求书中公布了：1.一种基于Flink的实时报表生成方法，其特征在于，所述方法包括下述步骤： 当Flink作业产生的实时数据流时，传输实时数据流至Kafka业务系统； 将Kafka业务系统接收的实时数据流写入Kafka业务系统的磁盘结构中； 通过ETL提取磁盘结构中的实时数据流到临时中间层进行转换处理，并产生实时清单数据； 发送实时清单数据至Druid数据库； 当检测到数据查询操作时，识别数据查询操作的类型，根据确定的数据查询操作的类型产生对应的操作指令，根据操作指令提取Druid数据库中的Druid引擎生成实时报表； 推送实时报表至前端平台； 所述通过ETL提取磁盘结构中的实时数据流到临时中间层进行转换处理，并产生实时清单数据的步骤之后，所述方法还包括： 将实时清单数据通过Flume数据管道传输至hive数据仓库进行存储备份; 当Flink作业时发生故障时，通过hive工具查询hive数据仓库中备份的实时清单数据与Kafka业务系统产生的实时清单数据中的不同，并获取目标清单数据； 回补目标清单数据至Druid数据库中； 所述将实时清单数据通过Flume数据管道传输至hive数据仓库进行存储备份的步骤包括： 接收实时清单数据，并将接收的实时清单数据以Flume传输一个或多个铺道引导； 存储Flume传输后的实时清单数据值hive数据仓库。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人中国平安财产保险股份有限公司，其通讯地址为：518000 广东省深圳市福田区益田路5033号平安金融中心12、13、38、39、40层；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

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