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

龙图腾网获悉广州亚信技术有限公司申请的专利一种实时数据处理分布式数仓的实现方法获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN120578719B 。

龙图腾网通过国家知识产权局官网在2025-12-02发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202511072939.3，技术领域涉及：G06F16/27；该发明授权一种实时数据处理分布式数仓的实现方法是由张百军;王立冬;梅珂夫设计研发完成，并于2025-08-01向国家知识产权局提交的专利申请。

本一种实时数据处理分布式数仓的实现方法在说明书摘要公布了：本申请公开一种实时数据处理分布式数仓的实现方法，涉及数据处理技术领域，该方法为：事务管理器向数据分片接收器分发task任务；数据分片接收器将消费信息发送给事务管理器；数据分片接收器先将消费数据的key键码，发送给数据分片写入器，将消费数据发送给数据分片写入器；数据分片写入器基于消费数据及key，确定写入信息；数据分片写入器将写入信息发送给事务管理器；事务管理器向数据版本管理器发送通知消息；数据版本管理器进行数据版本发布，获得发布信息；数据版本管理器将发布信息发送给事务管理器；事务管理器基于消费信息、写入信息和发布信息，更新task的事务状态。基于该方法能实现分布式数仓的秒级数据可见。

本发明授权一种实时数据处理分布式数仓的实现方法在权利要求书中公布了：1.一种实时数据处理分布式数仓的实现方法，其特征在于，应用于包含事务管理器、数据分片接收器、数据分片写入器以及数据版本管理器的数据仓库管理系统中，所述方法包括： 所述事务管理器向所述数据分片接收器分发task，以使得所述数据分片接收器在处理任一task时，还有另一个task排队等待处理；所述task用于从指定消息缓存系统中消费一秒数据；其中，所述事务管理器首次分发所述task时，每个所述数据分片接收器将对应分发两个所述task，当所述事务管理器收到所述数据分片接收器发送的消费信息后，再向所述数据分片接收器发送新task； 所述数据分片接收器将所述task的消费信息发送给所述事务管理器； 所述数据分片接收器先将处理所述task所得消费数据的key，发送给所述数据分片写入器，后将所述消费数据发送给所述数据分片写入器； 所述数据分片写入器基于所述消费数据以及对应的key，确定所述task的写入信息；所述写入信息基于所述消费数据的落盘结果所确定，所述落盘结果为基于预先加载到内存中的与所述key对应的磁盘数据与所述消费数据之间的归并排序结果，对所述消费数据进行数据落盘所得； 所述数据分片写入器将所述写入信息发送给所述事务管理器； 所述事务管理器基于所述写入信息，向所述数据版本管理器发送对应的通知消息； 所述数据版本管理器响应所述通知消息，进行数据版本发布，以获得所述task的发布信息； 所述数据版本管理器将所述发布信息发送给所述事务管理器； 所述事务管理器基于所述task的消费信息、写入信息以及发布信息，实时更新所述task的事务状态。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人广州亚信技术有限公司，其通讯地址为：511455 广东省广州市南沙区黄阁镇金茂中二街1号601、602、611房；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

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