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

龙图腾网获悉阿里巴巴(中国)有限公司申请的专利一种基于流式计算的数据处理方法及装置获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN116436933B 。

龙图腾网通过国家知识产权局官网在2026-03-31发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202310299741.3，技术领域涉及：H04L67/1097；该发明授权一种基于流式计算的数据处理方法及装置是由张鹏;周凯波设计研发完成，并于2023-03-20向国家知识产权局提交的专利申请。

本一种基于流式计算的数据处理方法及装置在说明书摘要公布了：本申请提供了一种基于流式计算的数据处理方法及装置。待流式计算节点的本地存储器中的存储空间的利用率小于第一预设阈值的情况下，流式计算节点再从数据源获取待计算的流式数据，根据流式计算任务中指定的计算方式对待计算的流式数据计算，在流式计算节点的本地存储器中存储计算结果，由于流式计算节点的本地存储器的存储空间的利用率小于第一预设阈值，也即，流式计算节点的本地存储器中具有足够的空闲的存储空间，如此，在流式计算节点的本地存储器中能够成功存储计算结果，不会由于存储失败而不断尝试在流式计算节点的本地存储器存储计算结果，进而不会由于多次无法成功存储而出现流式计算节点宕机或死机等情况。

本发明授权一种基于流式计算的数据处理方法及装置在权利要求书中公布了：1.一种基于流式计算的数据处理方法，其特征在于，应用于流式计算集群中的多个流式计算节点中的一个流式计算节点，所述方法包括： 在流式计算节点对流式数据处理的场景中，检测流式计算节点的本地存储器的存储空间的利用率是否大于或等于第一预设阈值； 在流式计算节点的本地存储器的存储空间的利用率大于或等于第一预设阈值的情况下，确定所述场景对处理时效性的容忍度是否高于或等于预设容忍度； 在所述场景对处理时效性的容忍度高于或等于预设容忍度的情况下，中断从数据源获取待计算的流式数据，数据源用于存储待计算的流式数据，数据源中的流式数据用于被流式计算节点通过流式计算任务中指定的计算方式计算；待之后在流式计算节点的本地存储器的存储空间的利用率小于第一预设阈值的情况下，再从数据源获取待计算的流式数据，根据流式计算任务中指定的计算方式对待计算的流式数据计算，在流式计算节点的本地存储器中存储计算结果； 在所述场景对处理时效性的容忍度低于预设容忍度的情况下，向流式计算集群中的控制节点提交分配请求，分配请求用于请求为流式计算节点的本地存储器分配更多的存储空间；在控制节点根据分配请求为流式计算节点的本地存储器分配更多的存储空间的情况下，从数据源获取待计算的流式数据，根据流式计算任务中指定的计算方式对待计算的流式数据计算，在分配的存储空间中存储计算结果。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人阿里巴巴(中国)有限公司，其通讯地址为：310012 浙江省杭州市余杭区五常街道文一西路969号3幢5层554室；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

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