浪潮云信息技术股份公司王文宇获国家专利权
买专利卖专利找龙图腾,真高效! 查专利查商标用IPTOP,全免费!专利年费监控用IP管家,真方便!
龙图腾网获悉浪潮云信息技术股份公司申请的专利分布式数据回传方法及装置、介质、设备获国家发明授权专利权,本发明授权专利权由国家知识产权局授予,授权公告号为:CN119094605B 。
龙图腾网通过国家知识产权局官网在2025-09-19发布的发明授权授权公告中获悉:该发明授权的专利申请号/专利号为:202411195781.4,技术领域涉及:H04L67/55;该发明授权分布式数据回传方法及装置、介质、设备是由王文宇;李腾飞;刘祖圣;马顺安;陈尧设计研发完成,并于2024-08-29向国家知识产权局提交的专利申请。
本分布式数据回传方法及装置、介质、设备在说明书摘要公布了:本发明提供一种分布式数据回传方法及装置、介质、设备。该方法包括:通过数据采集服务采集模型数据并保存到数据库中;通过数据推送服务根据定时任务执行信息生成数据推送任务,将数据推送任务添加到线程队列中,将数据表信息添加到阻塞队列中;通过线程池中的至少一个线程并行执行线程队列中的至少一个数据推送任务;根据每一个线程取出的数据表信息,获取数据库中对应的数据表;通过数据推送服务确定增量数据,将增量数据进行封装,得到推送消息,将推送消息发送至Kafka集群中;通过数据接收服务从Kafka集群中拉取推送消息,将增量数据保存到数据湖中,向Kafka集群提交拉取偏移量。本发明实施例提供了一种高效、可靠、安全的模型数据回传方案。
本发明授权分布式数据回传方法及装置、介质、设备在权利要求书中公布了:1.一种分布式数据回传方法,其特征在于,包括: 通过数据采集服务采集大模型产生的模型数据,并将所述模型数据保存到与所述数据采集服务连接的数据库中;其中,所述数据库为分布式云中心的本地数据库; 通过数据推送服务根据预先配置的定时任务执行信息,生成数据推送任务,将所述数据推送任务添加到线程池的线程队列中,将所述模型数据在所述数据库中的数据表信息添加到阻塞队列中;通过所述线程池中的至少一个线程并行执行所述线程队列中的至少一个数据推送任务,每一个线程负责将所述阻塞队列中对应的数据表信息取出; 通过所述数据推送服务建立与所述数据库之间的连接通道,根据每一个线程取出的数据表信息,通过该连接通道获取所述数据库中对应的数据表,并关闭所述连接通道; 通过所述数据推送服务确定所述数据表中的增量数据,将所述增量数据进行封装,得到推送消息,并将所述推送消息发送至Kafka集群中; 通过订阅相应主题的数据接收服务从所述Kafka集群中拉取所述推送消息,将拉取到的所述推送消息中的增量数据保存到数据湖中,并向所述Kafka集群提交自己的拉取偏移量。
如需购买、转让、实施、许可或投资类似专利技术,可联系本专利的申请人或专利权人浪潮云信息技术股份公司,其通讯地址为:250100 山东省济南市高新区浪潮路1036号浪潮科技园S01号楼;或者联系龙图腾网官方客服,联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。
以上内容由龙图腾AI智能生成。
1、本报告根据公开、合法渠道获得相关数据和信息,力求客观、公正,但并不保证数据的最终完整性和准确性。
2、报告中的分析和结论仅反映本公司于发布本报告当日的职业理解,仅供参考使用,不能作为本公司承担任何法律责任的依据或者凭证。

皖公网安备 34010402703815号
请提出您的宝贵建议,有机会获取IP积分或其他奖励