(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210481248.9 (22)申请日 2022.05.05 (71)申请人 阿里巴巴 （中国） 有限公司 地址 311121 浙江省杭州市余杭区五常街 道文一西路969号3幢5层5 54室 (72)发明人 王竹凡　庄灿伟　孔伟康　邱晗　 董元元　 (74)专利代理 机构 北京智信禾专利代理有限公 司 11637 专利代理师 刘晓楠 (51)Int.Cl. G06F 9/50(2006.01) (54)发明名称 数据处理方法及装置 (57)摘要 本说明书实施例提供数据处理方法及 装置， 其中所述数据处理方法包括： 调度存储节点接收 任务处理请求， 并基于所述任务处理请求确定每 个执行存储节 点的执行状态； 所述调度存储节点 基于每个执行存储节点的执行状态确定目标执 行存储节 点， 并将所述任务处理请求转发至所述 目标执行存储节点； 所述目标执行存储节点基于 所述任务处理请求确定数据位置信息和目标处 理函数， 并根据所述数据位置信息和所述目标处 理函数获得目标业 务数据。 权利要求书2页 说明书14页 附图5页 CN 115016931 A 2022.09.06 CN 115016931 A 1.一种数据处理方法， 应用于数据存储集群， 所述数据存储集群中包含调度存储节点 和至少一个执 行存储节点， 其中， 调度存储节点接收任务处理请求， 并基于所述任务处理请求确定每个执行存储节点的 执行状态； 所述调度存储节点基于每个执行存储节点的执行状态确定目标执行存储节点， 并将所 述任务处 理请求转发至所述目标 执行存储节点； 所述目标执行存储节点基于所述任务处理请求确定数据位置信 息和目标处理函数， 并 根据所述数据位置信息和所述目标处 理函数获得目标业 务数据。 2.如权利要求1所述的方法， 所述调度存储节点基于所述任务处理请求确定每个执行 存储节点的执 行状态， 包括： 所述调度存储节点基于所述任务处理请求查询所述数据存储集群中每个执行存储节 点的当前任务负载量和节点状态信息； 或 所述调度存储节点接收所述数据存储集群中每个执行存储节点上报的当前任务负载 量和节点状态信息 。 3.如权利要求1所述的方法， 所述调度存储节点接收任务处理请求， 并基于所述任务处 理请求确定每 个执行存储节点的执 行状态， 包括： 基于所述任务处 理请求确定目标处 理函数； 在确定所述目标处理函数为预设处理函数的情况下， 基于所述任务处理请求确定所述 数据存储集群中每 个执行存储节点的执 行状态。 4.如权利要求1所述的方法， 所述目标执行存储节点基于所述任务处理请求确定数据 位置信息和目标处 理函数， 包括： 所述目标 执行存储节点解析所述任务处 理请求； 获取所述任务处 理请求中的数据位置信息和目标处 理函数。 5.如权利要求1所述的方法， 所述根据所述数据位置信息和所述目标处理函数获得目 标业务数据， 包括： 根据所述数据位置信息获取待处 理业务数据； 基于所述目标处 理函数处 理所述待处 理业务数据， 获得目标业 务数据。 6.如权利要求1所述的方法， 所述任务处理请求中包含重试二元组， 所述重试二元组 由 执行标识和重试值组成； 所述方法还 包括： 在所述调度存储节点检测到所述目标执行存储节点发生故障的情况下， 在所述数据存 储集群中确定当前 执行存储节点； 向所述当前 执行存储节点发送包 含所述重试二元组的任务处 理请求。 7.如权利要求6所述的方法， 所述在所述数据存储集群中确定当前执行存储节点之前， 还包括： 所述调度存 储节点重新获取 所述目标 执行存储节点的执 行状态； 基于重新获取 所述执行状态的获取次数增 加所述重试二元组中的重试值。 8.如权利要求6所述的方法， 所述向所述当前执行存储节点发送包含重试二元组的任权　利　要　求　书 1/2 页 2 CN 115016931 A 2务处理请求之后， 还 包括： 所述当前 执行存储节点基于所述任务处 理请求确定待 写入文件和重试二元组； 基于所述重试二元组打开所述待 写入文件。 9.如权利要求8所述的方法， 所述基于所述重试二元组打开所述待 写入文件， 包括： 确定所述待 写入文件的当前重试二元组； 在所述当前重试二元组中的当前执行标识与所述重试二元组的执行标识一致的情况 下， 比对所述当前重试二元组的当前重试值以及所述重试二元组的重试值； 在所述重试值大于所述当前重试值的情况下， 基于所述重试二元组打开所述待写入文 件。 10.如权利要求1所述的方法， 所述任务处理请求中包含重试二元组， 所述重试二元组 由执行标识和重试值组成； 所述方法还 包括： 检测到所述调度存储节点发生故障的情况下， 在所述数据存储集群中确定调度存储节 点集合； 向所述调度存储节点集合中的每个调度存储节点发送包含重试二元组的任务处理请 求。 11.如权利要求10所述的方法， 所述在所述数据存储集群中确定调度存储节点集合之 前， 还包括： 重新获取 所述调度存 储节点的调度执 行状态； 基于重新获取 所述调度执 行状态的获取次数增 加所述重试二元组的重试值。 12.一种数据处理系统， 所述数据处理系统中包含数据存储集群和数据计算集群， 其 中， 所述数据存储集群被配置为， 接收任务处理请求， 并基于所述任务处理请求确定目标 处理函数； 所述数据存储集群， 进一步被配置为， 在所述目标处理函数为预设处理函数的情况下， 对所述任务处 理请求进行处 理； 所述数据存储集群， 进一步被配置为， 在所述目标处理函数非预设处理函数的情况下， 将所述任务处 理请求转发至数据计算 集群； 所述数据计算 集群被配置为， 接收任务处 理请求， 并对所述任务处 理请求进行处 理。 13.一种计算设备， 包括存储器、 处理器及存储在存储器上并可在处理器上运行的计算 机指令， 所述处理器执行所述计算机指 令时实现权利要求 1‑11或12任意一项 所述方法的步 骤。 14.一种计算机可读存储介质， 其存储有计算机可执行指令， 该计算机指令被处理器执 行时实现权利要求1 ‑11或12任意 一项所述方法的步骤。权　利　要　求　书 2/2 页 3 CN 115016931 A 3