(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210762371.8 (22)申请日 2022.06.30 (71)申请人 支付宝 （杭州） 信息技 术有限公司 地址 310013 浙江省杭州市西湖区西溪路 556号8层B段801-1 1 (72)发明人 郭志强　 (74)专利代理 机构 北京智信禾专利代理有限公 司 11637 专利代理师 金鹏 (51)Int.Cl. G06F 9/50(2006.01) (54)发明名称 数据处理方法以及装置 (57)摘要 本说明书实施例提供数据处理方法以及装 置， 其中数据处理方法应用于第一处理端， 包括： 确定若干个目标对象和目标对象各自对应的多 个处理算子， 其中， 目标对象携带针对多个处理 算子的执行序列， 每个处理算子对应一个数据队 列， 处理算子为对目标对象 的特征向量进行降维 处理的算子； 在对目标对象执行任一处理算子的 情况下， 冻结目标对象， 并将目标对象添加至任 一处理算子对应的数据队列； 从任一数据队列中 提取多个目标对象， 并将多个目标对象发送至第 二处理端， 使第二处理端对多个目标对象并发执 行任一数据队列对应的处理算子； 接收第二处理 端反馈的处理结果， 根据处理结果解冻多个目标 对象。 准确集合目标对象， 提高对目标对象执行 处理算子的效率。 权利要求书3页 说明书16页 附图6页 CN 115080241 A 2022.09.20 CN 115080241 A 1.一种数据处 理方法， 应用于第一处 理端， 所述方法包括： 确定若干个目标对象和所述目标对象各自对应的多个处理算子， 其中， 所述目标对象 携带针对所述多个处理算子的执行序列， 每个处理算子对应一个数据队列， 所述处理算子 为对所述目标对象的特 征向量进行降维处 理的算子； 在对所述目标对象执行任一处理算子的情况下， 冻结所述目标对象， 并将所述目标对 象添加至所述任一处 理算子对应的数据队列； 从任一数据队列中提取多个目标对象， 并将所述多个目标对象发送至第二处理端， 使 所述第二处 理端对所述多个目标对象并发执 行所述任一数据队列对应的处 理算子； 接收所述第二处 理端反馈的处 理结果， 根据所述处 理结果解冻所述多个目标对象。 2.根据权利要求1所述的方法， 所述目标对象为图学习算法模型中关系图的点和边， 所 述处理算子为所述图学习算法模型中对点和/或边的特 征向量进行降维处 理的算子； 所述从任一数据队列中提取多个目标对象， 并将所述多个目标对象发送至第二处理 端， 使所述第二处理端对所述多个目标对象并发执行所述任一数据队列对应的处理算子的 步骤， 包括： 从任一数据队列中提取多个点和/或边； 分别获取 所述多个点和/或边各自的特 征维度； 根据所述特 征维度， 将所述多个点和/或边 转换为矩阵格式； 将所述矩阵格式的多个点和/或边发送至第二处理端， 使所述第二处理端对所述多个 点和/或边并发执 行所述任一数据队列对应的处 理算子。 3.根据权利要求1所述的方法， 所述从任一数据队列中提取多个目标对象， 并将所述多 个目标对象发送至第二处理端， 使所述第二处理端对所述多个目标对象并发执行所述任一 数据队列对应的处 理算子的步骤， 包括： 利用多个线程依次从所述任一数据队列中提取多个目标对象， 并将所述多个目标对象 发送至第二处理端， 使所述第二处理端对至少一个线程 发送的多个目标对象并发执行所述 任一数据队列对应的处 理算子的同时， 至少另一个线程 正在发送多个目标对象。 4.根据权利要求1所述的方法， 所述确定若干个目标对象和所述目标对象对应的多个 处理算子的步骤之前， 还 包括： 针对任一目标对象， 根据运行需求， 设置该目标对象对应的多个处理算子的执行序列， 其中， 所述执 行序列中包括所述多个处 理算子的执 行顺序； 分别为所述多个处 理算子设置各自对应的数据队列。 5.根据权利要求1所述的方法， 所述接收所述第 二处理端反馈的处理结果的步骤之后， 还包括： 根据所述第二处 理端反馈的处 理结果更新所述多个目标对象的执 行状态。 6.根据权利要求1所述的方法， 所述将所述目标对象添加至所述任一处理算子对应的 数据队列的步骤， 包括： 获取所述任一处 理算子对应的预设算子标识； 根据所述预设算子标识， 在多个数据队列中查找所述预设算子标识对应的数据队列； 将所述目标对象添加至所述预设算子标识对应的数据队列。 7.一种数据处 理方法， 应用于第二处 理端， 所述方法包括：权　利　要　求　书 1/3 页 2 CN 115080241 A 2接收第一处理端发送的多个目标对象， 其中， 所述目标对象由所述第一处理端确定若 干个目标对象和所述目标对象各自对应的多个处理算子， 在对所述目标对象执行任一处理 算子的情况下， 冻 结所述目标对象， 并将所述 目标对象添加至所述任一处理算子对应的数 据队列， 从任一数据队列中提取得到， 所述 目标对象携带针对所述多个处理算子的执行序 列， 每个处理算子对应一个数据队列， 所述处理算子为对所述 目标对象的特征向量进行降 维处理的算子； 对所述多个目标对象并发执 行所述任一数据队列对应的处 理算子， 获得处 理结果； 向所述第一处理端反馈所述处理结果， 使所述第 一处理端根据 所述处理结果解冻所述 多个目标对象。 8.一种数据处 理装置， 应用于第一处 理端， 所述装置包括： 确定模块， 被配置为确定若干个目标对象和所述目标对象各自对应的多个处理算子， 其中， 所述 目标对象携带针对所述多个处理算子的执行序列， 每个处理算子对应一个数据 队列， 所述处 理算子为对所述目标对象的特 征向量进行降维处 理的算子； 冻结模块， 被配置为在对所述目标对象执行任一处理算子的情况下， 冻结所述目标对 象， 并将所述目标对象添加至所述任一处 理算子对应的数据队列； 发送模块， 被配置为从任一数据队列中提取多个目标对象， 并将所述多个目标对象发 送至第二处理端， 使 所述第二处理端对所述多个目标对象并发执行所述任一数据队列对应 的处理算子； 解冻模块， 被配置为接收所述第二处理端反馈的处理结果， 根据所述处理结果解冻所 述多个目标对象。 9.一种数据处 理装置， 应用于第二处 理端， 所述装置包括： 接收模块， 被配置为接收第 一处理端发送的多个目标对象， 其中， 所述目标对象由所述 第一处理端确定若干个目标对象和所述目标对象各自对应的多个处理算子， 在 对所述目标 对象执行任一处理算子的情况下， 冻 结所述目标对象， 并将所述 目标对象添加至所述任一 处理算子对应的数据队列， 从任一数据队列中提取得到， 所述 目标对象携带针对所述多个 处理算子的执行序列， 每个处理算子对应一个数据队列， 所述处理算子为对所述 目标对象 的特征向量进行降维处 理的算子； 处理模块， 被配置为对所述多个目标对象并发执行所述任一数据 队列对应的处理算 子， 获得处 理结果； 反馈模块， 被配置为向所述第一处理端反馈所述处理结果， 使所述第一处理端根据所 述处理结果解冻所述多个目标对象。 10.一种数据处 理系统， 所述数据处 理系统包括第一处 理端和第二处 理端； 所述第一处理端， 被配置为确定若干个目标对象和所述目标对象各自对应的多个处理 算子， 其中， 所述目标对象携带针对所述多个处理算子的执行序列， 每个处理算子对应一个 数据队列， 所述处理算子为对所述 目标对象的特征向量进行降维处理的算子； 在对所述 目 标对象执行任一处理算子的情况下， 冻 结所述目标对象， 并将所述 目标对象添加至所述任 一处理算子对应的数据队列； 从任一数据队列中提取多个目标对 象， 并将所述多个目标对 象发送至第二处理端； 接 收所述第二处理端反馈的处理结果， 根据所述处理结果解冻 所述 多个目标对象；权　利　要　求　书 2/3 页 3 CN 115080241 A 3