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

龙图腾网获悉中国建设银行股份有限公司;建信金融科技有限责任公司申请的专利一种多源数据处理方法、装置及可读存储介质获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN117009391B 。

龙图腾网通过国家知识产权局官网在2025-11-07发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202310994649.9，技术领域涉及：G06F16/2455；该发明授权一种多源数据处理方法、装置及可读存储介质是由刘高;王杰明;张鹏;刘毓灵;张丽媛;吴婧琦;迟骋设计研发完成，并于2023-08-08向国家知识产权局提交的专利申请。

本一种多源数据处理方法、装置及可读存储介质在说明书摘要公布了：本发明实施例涉及流数据处理技术领域，公开了一种多源数据处理方法、装置及可读存储介质。通过将多源实时流数据信息同批量数据进行整合，并设置延迟时间接收第二数据源延迟的流数据信息，解决了现有技术中对多源数据进行实时流处理时存在数据延迟以及数据乱序的技术问题，最大程度地保证了实时流计算结果数据和业务生产数据的一致性，确保了数据的完整性。

本发明授权一种多源数据处理方法、装置及可读存储介质在权利要求书中公布了：1.一种多源数据处理方法，其特征在于，所述多源数据处理方法包括： 获取第一数据源和第二数据源的实时流数据信息，并将所述实时流数据信息送入第一分布式消息队列中； 对所述第一分布式消息队列中的所述实时流数据信息进行清洗，并将清洗后的所述实时流数据信息送入第二分布式消息队列中； 将所述第二分布式消息队列中的所述实时流数据信息送入基于列的分布式数据库中，并与所述分布式数据库中的批量数据信息进行整合，得到关联维表数据信息； 对所述第二分布式消息队列中的所述实时流数据信息、所述关联维表数据信息进行流计算处理，并将处理结果送入第三分布式消息队列待用； 在对所述第二分布式消息队列中的所述实时流数据信息、所述关联维表数据信息进行流计算处理时，获取所述第二数据源延迟第一预设时长内的延迟流数据信息； 对所述延迟流数据信息进行流计算处理，并将处理结果送入所述第三分布式消息队列待用； 所述第一预设时长的确定方法包括： 获取预设时段内的所述第一数据源和所述第二数据源所对应的批量数据的时间戳差值； 确定所述第一数据源和所述第二数据源的时间戳差值在T时长内的数据信息的占比大于预设百分比，则T时长为所述第一预设时长； 在对所述第二分布式消息队列中的所述实时流数据信息、所述关联维表数据信息进行流计算处理之前，所述多源数据处理方法还包括： 设置第二预设时长，并在第二实时流数据信息以所述第二预设时长延迟到达所述第二分布式消息队列之后触发流计算开始执行； 其中，所述第一分布式消息队列为kafka队列的原始层；所述第二分布式消息队列为kafka队列的标准层；所述第三分布式消息队列为kafka队列的访问层。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人中国建设银行股份有限公司;建信金融科技有限责任公司，其通讯地址为：100033 北京市西城区金融大街25号；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

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