数据处理方法以及装置.pdf

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