(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210807292.4 (22)申请日 2022.07.07 (71)申请人 北京百度网讯科技有限公司 地址 100085 北京市海淀区上地十街10号 百度大厦2层 (72)发明人 高俊亚　刘桐仁　刘伟　 (74)专利代理 机构 中科专利商标代理有限责任 公司 11021 专利代理师 鄢功军 (51)Int.Cl. G06F 9/54(2006.01) G06F 9/50(2006.01) (54)发明名称 数据处理方法、 装置、 设备以及存 储介质 (57)摘要 本公开提供了一种数据处理方法、 装置、 设 备以及存储介质， 涉及计算机技术领域， 尤其涉 及信息检索技术领域。 具体实现方案为： 接收来 自上游算子节 点的远程服务请求； 解析远程服务 请求， 得到待处理数据； 将待处理数据发送至计 算服务器； 接收来自计算服务器针对待处理数据 的计算结果； 根据计算结果和待处理数据， 生成 目标数据； 以及将目标数据发送至与上游算子节 点对应的下游算子节点。 权利要求书2页 说明书10页 附图7页 CN 115145750 A 2022.10.04 CN 115145750 A 1.一种数据处 理方法， 包括： 接收来自上游算子节点的远程 服务请求； 解析所述远程 服务请求， 得到待处 理数据； 将所述待处 理数据发送至计算 服务器； 接收来自所述计算 服务器针对所述待处 理数据的计算结果； 根据所述计算结果和所述待处 理数据， 生成目标 数据； 以及 将所述目标 数据发送至与所述上游算子节点对应的下游算子节点。 2.根据权利要求1所述的方法， 其中， 所述将所述待处 理数据发送至计算 服务器， 包括： 获取与所述远程 服务请求对应的公共请求字段； 根据所述待处 理数据和所述公共请求字段， 生成目标请求； 以及 将所述目标请求发送至所述计算 服务器。 3.根据权利要求2所述的方法， 其中， 所述将所述目标请求发送至所述计算服务器， 包 括： 在一级队列未写满的情况 下， 将目标请求写入所述 一级队列； 在所述一级队列写满的情况下， 将所述目标请求写入二级队列， 并定期将所述二级队 列中的请求迁移至所述 一级队列中； 以及 分别将所述 一级队列中的每 个请求发送至所述计算 服务器； 其中， 所述一级队列用于存储正在发送中的请求， 所述二级队列表征用于存储等待发 送的请求。 4.根据权利要求2所述的方法， 还 包括： 将所述目标请求和与所述目标请求对应的重试次数写入延迟消息队列； 针对所述延迟消息队列中的每个待处理请求， 确定与 所述待处理请求对应的计算结果 是否已被完全接收以及与所述待处 理请求对应的重试次数 是否大于 0； 以及 在确定与所述待处理请求对应的计算结果未被完全接收且与所述待处理请求对应的 重试次数大于0的情况下， 将所述待处理请求 发送至所述计算服务器， 并将所述重试次数减 1。 5.根据权利要求4所述的方法， 其中， 所述解析所述远程服务请求， 得到待处理数据， 包 括： 获取所述根据与所述远程 服务请求对应的预设字段路径； 以及 确定所述远程 服务请求中与所述预设字段路径匹配的对应字段， 作为待处 理数据。 6.根据权利要求5所述的方法， 还 包括： 确定所述远程服务请求中与 所述预设字段路径匹配的对应字段的总数量， 作为目标数 量； 在接收到所述计算结果的情况 下， 将所述目标 数量减去已接收到的计算结果的数量， 得到待接收数量； 在确定所述待接收数量 为0的情况 下， 确定所述计算结果已被完全接收； 以及 在确定所述待接收数量大于 0的情况下， 确定所述计算结果未被完全接收。 7.根据权利要求6所述的方法， 其中， 所述根据所述计算结果和所述待处理数据， 生成 目标数据， 包括：权　利　要　求　书 1/2 页 2 CN 115145750 A 2在确定所述计算结果被完全接收的情况下， 将完全接收的计算结果添加至所述待处理 数据， 得到所述目标 数据； 以及 在确定所述目标请求对应的重试次数为0的情况下， 将已接收到的计算结果添加至所 述待处理数据， 得到所述目标 数据。 8.一种数据处 理装置， 包括： 第一接收模块， 用于 接收来自上游算子节点的远程 服务请求； 解析模块， 用于解析 所述远程 服务请求， 得到待处 理数据； 第一发送模块， 用于将所述待处 理数据发送至计算 服务器； 第二接收模块， 用于 接收来自所述计算 服务器针对所述待处 理数据的计算结果； 生成模块， 用于根据所述计算结果和所述待处 理数据， 生成目标 数据； 以及 第二发送模块， 用于将所述目标数据发送至与所述上游算子节点对应的下游算子节 点。 9.一种电子设备， 包括： 至少一个处 理器； 以及 与所述至少一个处 理器通信连接的存 储器； 其中， 所述存储器存储有可被所述至少一个处理器执行的指令， 所述指令被所述至少一个处 理器执行， 以使所述至少一个处 理器能够执 行权利要求1 ‑7中任一项所述的方法。 10.一种存储有计算机指令的非瞬时计算机可读存储介质， 其中， 所述计算机指令用于 使所述计算机执 行根据权利要求1 ‑7中任一项所述的方法。 11.一种计算机程序产品， 包括计算机程序/指令， 其特征在于， 该计算机程序/指令被 处理器执行时实现权利要求1 ‑7中任一项所述方法的步骤。权　利　要　求　书 2/2 页 3 CN 115145750 A 3