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

龙图腾网恭喜天津金城银行股份有限公司申请的专利数据入湖的处理方法、管理系统、终端设备和存储介质获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN118838973B 。

龙图腾网通过国家知识产权局官网在2025-03-18发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202411319895.5，技术领域涉及：G06F16/28；该发明授权数据入湖的处理方法、管理系统、终端设备和存储介质是由李尊健;赵禛设计研发完成，并于2024-09-23向国家知识产权局提交的专利申请。

本数据入湖的处理方法、管理系统、终端设备和存储介质在说明书摘要公布了：本申请涉及数据处理技术领域，公开了一种数据入湖的处理方法、管理系统、终端设备和存储介质；该方法包括采集数据库中的业务数据，并监听变更事件；所述变更事件为所述数据库的数据日志中数据结构变更记录的事件；对所述业务数据和所述变更事件进行分流处理，分别得到主消息和变更消息；将所述变更消息经协处理器处理后与所述主消息进行消费写入数据湖。本申请能够提高整个数据库的数据写入数据湖的同步时效性。

本发明授权数据入湖的处理方法、管理系统、终端设备和存储介质在权利要求书中公布了：1.一种数据入湖的处理方法，其特征在于，包括：采集数据库中的业务数据，并监听变更事件；所述变更事件为所述数据库的数据日志中数据结构变更记录的事件；对所述业务数据和所述变更事件进行分流处理，分别得到主消息和变更消息；所述对所述业务数据和所述变更事件进行分流处理，分别得到主消息和变更消息，包括：对所述业务数据和所述变更事件进行分流，分别得到主数据流和侧输出流；所述主数据流包括所述业务数据和所述变更事件；所述侧输出流包括所述变更事件；对所述主数据流进行处理得到所述主消息；对所述侧输出流进行处理得到所述变更消息；将所述变更消息经协处理器处理后与所述主消息进行消费写入数据湖；所述将所述变更消息经协处理器处理后与所述主消息进行消费写入数据湖，包括：当所述主消息经消息队列进行消费写入时，若没有捕获到所述变更事件，则直接将所述主消息写入所述数据湖；若捕获到变更事件，则暂停消费所述主消息的数据流，并刷出缓存数据；在所述缓存数据刷出完毕后，继续等待所述消息队列中暂停消费时的变更事件与转换任务事件进行匹配处理；其中，所述变更消息经所述协处理器处理得到所述转换任务事件；所述转换任务事件包括创建、删除和或变更ETL任务；在匹配成功后，恢复消费所述主消息的数据流，以继续推送所述消息队列中的下一个主消息进行消费写入数据湖；所述变更消息经协处理器处理，包括：所述协处理器捕获所述变更消息，并对所述变更消息进行处理得到变更操作信息；所述协处理器在接收到所述缓存数据刷出完毕信号后，根据所述变更操作信息对所述数据湖进行变更操作，以更新数据湖的数据结构；所述协处理器在监测所述数据湖的数据结构完成更新后，根据所述变更操作信息产生所述转换任务事件。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人天津金城银行股份有限公司，其通讯地址为：300450 天津市滨海新区自贸试验区(中心商务区)融义路1352号宝信大厦22-23层；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。