(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211209312.4 (22)申请日 2022.09.30 (71)申请人 拉卡拉支付股份有限公司 地址 100094 北京市海淀区北清路中关村 壹号D1座12层 (72)发明人 关振宇　朱家强　郑为锋　 (74)专利代理 机构 北京智宇 正信知识产权代理 事务所(普通 合伙) 11876 专利代理师 李明卓 (51)Int.Cl. G06F 9/50(2006.01) G06F 8/41(2018.01) (54)发明名称 聚合处理方法、 装置、 系统、 设备、 存储介质 及程序产品 (57)摘要 本公开实施例公开了一种聚合处理方法、 装 置、 系统、 设备、 存储介质及程序产品， 所述方法 包括： 接收目标聚合操作命令， 当确定所述目标 聚合操作命令为跨机房聚合操作命令时， 将所述 目标聚合操作命令分解为两个或多个目标操作 子命令； 将所述目标操作子命令发送给与所述目 标操作子命令对应机房的对应计算节 点； 响应于 接收到所有机房总计算节点发送的目标操作预 聚合子结果， 对于所述目标操作预聚合子结果进 行聚合操作， 得到聚合结果。 该技术方案可以大 大降低需要在机房间传输的数据量， 这样不仅会 提高机房间数据传输的速率， 也能够有效提升机 房间网络的使用率。 权利要求书2页 说明书14页 附图4页 CN 115509755 A 2022.12.23 CN 115509755 A 1.一种聚合处 理方法， 适用于处 理器， 包括： 接收目标聚合操作命令， 当确定所述目标聚合操作命令为跨机房 聚合操作命令时， 将 所述目标聚合操作命令分解 为两个或多个目标操作子命令； 将所述目标操作子命令发送给与 所述目标操作子命令对应机房的对应计算节点， 以使 所述计算节点执行所述目标操作子命令生成目标操作子结果 发送给机房总计算节点， 以在 机房总计算节点处对于所述目标操作子结果进行 预聚合， 得到目标操作预聚合子结果； 响应于接收到所有机房总计算节点发送的目标操作预聚合子结果， 对于所述目标操作 预聚合子结果进行聚合操作， 得到聚合结果。 2.根据权利要求1所述的方法， 所述接收目标聚合操作命令之后， 还 包括： 对于所述目标聚合操作命令进行解析， 确定所述目标聚合操作命令是否为跨机房聚合 操作命令 。 3.根据权利要求2所述的方法， 所述对于所述目标聚合操作命令进行解析， 确定所述目 标聚合操作命令是否为 跨机房聚合操作命令， 包括： 对于所述目标聚合操作命令进行数据源解析， 确定所述目标聚合操作命令是否为跨机 房聚合操作命令 。 4.根据权利要求3所述的方法， 所述对于所述目标聚合操作命令进行数据源解析， 确定 所述目标聚合操作命令是否为 跨机房聚合操作命令， 包括： 确定所述目标聚合操作命令对应的目标操作子命令的数据源； 当所述数据源中至少有两个不同时， 确定所述目标聚合操作命令为跨机房聚合操作命 令。 5.一种聚合处 理方法， 适用于计算节点， 包括： 接收目标操作子命令； 执行所述目标操作子命令， 生成目标操作子结果； 将所述目标操作子结果发送给同机房总计算节点。 6.一种聚合处 理方法， 适用于 机房总计算节点， 包括： 接收同机房计算节点发送的目标操作子结果； 确定是否已接收完成同机房所有计算节点的目标操作子结果； 当确定已接收完成同机房所有计算节点的目标操作子结果 时， 对于所述目标操作子结 果进行预聚合， 得到目标操作预聚合子结果， 并将所述 目标操作预聚合子结果发送给处理 器。 7.一种聚合处 理方法， 适用于包括处 理器、 计算节点和总计算节点的系统， 包括： 处理器接收目标聚合操作命令， 当确定所述目标聚合操作命令为跨机房聚合操作命令 时， 将所述 目标聚合操作命令分解为两个或多个目标操作子命令； 将所述 目标操作子命令 发送给与所述目标操作子命令对应机房的对应 计算节点； 计算节点接收目标操作子命令； 执行所述目标操作子命令， 生成目标操作子结果； 将所 述目标操作子结果发送给同机房总计算节点； 总计算节点接收同机房计算节点发送的目标操作子结果； 确定是否已接收完成同机房 所有计算节点的目标操作子结果； 当确定已接收完成同机房所有计算节点的目标操作子结 果时， 对于所述目标操作子结果进行预聚合， 得到目标操作预聚合子结果， 并将所述目标操权　利　要　求　书 1/2 页 2 CN 115509755 A 2作预聚合子结果发送给处 理器； 处理器响应于接收到所有机房总计算节点发送的目标操作预聚合子结果， 对于所述目 标操作预聚合子结果进行聚合操作， 得到聚合结果。 8.一种聚合处 理装置， 适用于处 理器， 包括： 分解模块， 被配置为接收目标聚合操作命令， 当确定所述目标聚合操作命令为跨机房 聚合操作命令时， 将所述目标聚合操作命令分解 为两个或多个目标操作子命令； 第一发送模块， 被配置为将所述目标操作子命令发送给与所述目标操作子命令对应机 房的对应计算节点， 以使 所述计算节点执行所述目标操作子命令生成目标操作子结果发送 给机房总计算节点， 以在机房总计算节点处对于所述 目标操作子结果进行预聚合， 得到目 标操作预聚合子结果； 聚合模块， 被配置为响应于接收到所有机房总计算节点发送的目标操作预聚合子结 果， 对于所述目标操作预聚合子结果进行聚合操作， 得到聚合结果。 9.一种聚合处 理装置， 适用于计算节点， 包括： 第一接收模块， 被 配置为接收目标操作子命令； 执行模块， 被 配置为执 行所述目标操作子命令， 生成目标操作子结果； 第二发送模块， 被 配置为将所述目标操作子结果发送给同机房总计算节点。 10.一种聚合处 理装置， 适用于 机房总计算节点， 包括： 第二接收模块， 被 配置为接收同机房计算节点发送的目标操作子结果； 确定模块， 被 配置为确定是否已接收完成同机房所有计算节点的目标操作子结果； 预聚合模块， 被配置为当确定已接收完成同机房所有计算节点的目标操作子结果时， 对于所述 目标操作子结果进行预聚合， 得到目标操作预聚合子结果， 并将所述目标操作预 聚合子结果发送给处 理器。权　利　要　求　书 2/2 页 3 CN 115509755 A 3