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

龙图腾网恭喜上海致景信息科技有限公司申请的专利基于Flink的实时数据处理方法、系统、设备及存储介质获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN115907450B 。

龙图腾网通过国家知识产权局官网在2025-06-10发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202310099146.5，技术领域涉及：G06Q10/0633；该发明授权基于Flink的实时数据处理方法、系统、设备及存储介质是由姚海杰设计研发完成，并于2023-02-09向国家知识产权局提交的专利申请。

本基于Flink的实时数据处理方法、系统、设备及存储介质在说明书摘要公布了：本发明涉及一种基于Flink的实时数据处理方法、系统、设备及存储介质，其技术方案要点是：判断所有当前批次轴品种数据中是否存在与运行轴品种数据相同的轴品种数据，是则根据实时运行数据判断是否更新FlinkState中存储的与该轴品种数据对应的当前批次运行数据；否则判断HBase中存储的所有历史轴品种数据中是否存在与运行轴品种数据相同的轴品种数据，是则将该轴品种数据和HBase中存储的与该轴品种数据对应的历史运行数据写入到FlinkState中，否则根据HBase中存储的所有周期上报轴品种数据将待添加轴品种数据和实时运行数据写入到HBase中存储；本申请具有便于数据恢复，减少了HBase与FlinkState之间的交互，以提高运行效率的效果。

本发明授权基于Flink的实时数据处理方法、系统、设备及存储介质在权利要求书中公布了：1.一种基于Flink的实时数据处理方法，其特征在于，包括：S1、获取实时运行轴的实时运行数据、所述实时运行轴的运行轴品种数据、FlinkState中存储的所有当前批次轴品种数据和与所有当前批次轴品种数据一一对应的所有当前批次运行数据；S2、判断所有所述当前批次轴品种数据中是否存在与运行轴品种数据相同的轴品种数据，若是，则执行步骤S3；若否，则执行步骤S4；S3、将该轴品种数据记为第一目标轴品种数据，根据所述实时运行数据判断是否更新与第一目标轴品种数据对应的当前批次运行数据；S4、获取HBase中存储的所有历史轴品种数据，判断所有所述历史轴品种数据中是否存在与运行轴品种数据相同的轴品种数据，若是，则执行步骤S5；若否，则执行步骤S6；S5、将该轴品种数据记为第二目标轴品种数据，将所述第二目标轴品种数据和与其对应的在HBase中存储的历史运行数据写入到FlinkState中，得到与第二目标轴品种数据相同的当前批次轴品种数据和与其对应的当前批次运行数据，根据所述实时运行数据判断是否更新与第二目标轴品种数据对应的当前批次运行数据；S6、将所述运行轴品种数据记为待添加轴品种数据，获取所述HBase中存储的所有周期上报轴品种数据，根据所有所述周期上报轴品种数据将所述待添加轴品种数据和实时运行数据写入到HBase中存储；所述实时运行轴数据包括：采集时间和运行圈数；所述运行轴品种数据包括：运行轴编号和采集器编号；所述当前批次运行数据包括：第一起始时间、第一结束时间、第一起始圈数和第一结束圈数；所述历史运行数据包括：第二起始时间、第二结束时间、第二起始圈数和第二结束圈数；所述根据所述实时运行数据判断是否更新与第一目标轴品种数据对应的当前批次运行数据，包括：判断所述采集时间是否小于与第一目标轴品种数据对应的第一起始时间，若是，则将采集时间作为与第一目标轴品种数据对应的第一起始时间，将运行圈数作为与第一目标轴品种数据对应的第一起始圈数，完成更新；若否，则判断所述采集时间是否大于与第一目标轴品种数据对应的第一结束时间，若是，则将采集时间作为与第一目标轴品种数据对应的第一结束时间，将运行圈数作为与第一目标轴品种数据对应的第一结束圈数，完成更新，若否，则不更新FlinkState中存储的与第一目标轴品种数据对应的当前批次运行数据；所述根据所述实时运行数据判断是否更新与第二目标轴品种数据对应的当前批次运行数据，包括：判断所述采集时间是否小于与第二目标轴品种数据对应的第一起始时间，若是，则将采集时间作为与第二目标轴品种数据对应的第一起始时间，将运行圈数作为与第二目标轴品种数据对应的第一起始圈数，完成更新；若否，则判断所述采集时间是否大于与第二目标轴品种数据对应的第一结束时间，若是，则将采集时间作为与第二目标轴品种数据对应的第一结束时间，将运行圈数作为与第二目标轴品种数据对应的第一结束圈数，完成更新，若否，则不更新FlinkState中存储的与第二目标轴品种数据对应的当前批次运行数据；所述根据所有所述周期上报轴品种数据将所述待添加轴品种数据和实时运行数据写入到HBase中存储，包括：判断所有所述周期上报轴品种数据中是否存在与待添加轴品种数据相同的周期上报轴品种数据，若是，则将所述采集时间作为该周期上报轴品种数据对应的第三结束时间，将所述运行圈数作为该周期上报轴品种数据对应的第三结束圈数，若否，则将所述待添加轴品种数据作为周期上报轴品种数据，将所述采集时间作为该周期上报轴品种数据对应的第三开始时间，将所述运行圈数作为该周期上报轴品种数据对应的第三开始圈数。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人上海致景信息科技有限公司，其通讯地址为：200000 上海市虹口区东大名路1158号3201室；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。