(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211213119.8 (22)申请日 2022.09.29 (71)申请人 建信金融科技有限责任公司 地址 200120 上海市浦东 新区中国(上海) 自由贸易试验区银城路99号12层、 15 层 (72)发明人 张小宁　黄冲　黄日钊　庄少博　 (74)专利代理 机构 北京品源专利代理有限公司 11332 专利代理师 岳晓萍 (51)Int.Cl. H04L 67/10(2022.01) H04L 67/568(2022.01) H04L 67/60(2022.01) G06F 9/50(2006.01)G06F 9/48(2006.01) G06F 9/54(2006.01) (54)发明名称 数据处理方法、 装置、 设备及存 储介质 (57)摘要 本申请提供一种数据处理方法、 装置、 设备 及存储介质。 涉及大数据数据分析技术领域。 该 方法包括： 基于网关集群接收各业务子系统发送 的业务请求， 并对业务请求处理后发送至数据加 工集群； 基于数据加工集群接收处理后的业务请 求， 并在各计算节点获取到相应的业务请求时， 基于控制节点确定各计算节点所对应的处理属 性， 以使控制节点基于处理属性调整各计算节点 所对应的数据处理量； 基于数据展示子系统将接 收到的与业务请求相对应的目标处理结果反馈 至相应的客户端并展示， 解决了现有技术中对请 求数据进行平均分配， 导致数据分配效果差， 降 低数据处理效率的问题， 实现提高业务请求分配 的合理性， 减少资源浪费， 达到提高数据处理效 率和性能的效果。 权利要求书2页 说明书13页 附图5页 CN 115442373 A 2022.12.06 CN 115442373 A 1.一种数据处 理方法， 其特 征在于， 包括： 基于网关集群接收各业务子系统发送的业务请求， 并对所述业务请求处理后发送至所 述数据加工集群； 基于所述数据加工集群接收处理后的业务请求， 并在各计算节点获取到相应的业务请 求时， 基于控制节点确定各计算节点所对应的处理属 性， 以使控制节点基于所述处理属 性 调整各计算节点所对应的数据处 理量； 基于数据展示子系统将接收到的与业务请求相对应的目标处理结果反馈至相应的客 户端并展示。 2.根据权利要求1所述的方法， 其特征在于， 所述基于网关集群接收各业务子系统发送 的业务请求， 并对所述 业务请求处 理后发送至所述数据加工集群， 包括： 在接收到各业务子系统发送的业务请求 时， 基于所述网关集群对所述业务请求进行解 析， 得到解析后的业 务请求； 若对所述业务请求的鉴权处理结果为通过， 则将解析后的业务请求发送至所述数据加 工集群。 3.根据权利要求1所述的方法， 其特征在于， 在将所述业务请求发送至所述数据加工集 群之前， 还 包括： 将所述业务请求加入消息队列中， 以使所述数据加工集群确定从所述消息队列中获取 相应的业 务请求。 4.根据权利要求1所述的方法， 其特征在于， 所述在各计算节点获取到相应的业务请求 时， 基于控制节点确定各计算节点所对应的处 理属性， 包括： 基于各计算节点从消息队列中获取相应的业 务请求； 对于与各计算节点相对应的控制节点， 确定当前计算节点所关联的各业务请求所对应 的交易类型， 以及各交易类型 所对应的业 务请求的请求数量； 对于各计算节点的交易类型和相应的请求数量， 确定相应 计算节点的处 理属性。 5.根据权利要求4所述的方法， 其特征在于， 所述处理属性包括预设时长内的预估处理 时长， 所述对于各计算节点的交易类型和相应的请求数量， 确定相应计算节点的处理属性， 包括： 对于各计算节点， 周期性的根据当前计算节点所关联的交易类型的交易处理时长， 并 根据各交易处理 时长和各 交易类型所对应的请求数量， 确定所述当前计算节点对业务请求 处理完成时的预估处 理时长。 6.根据权利要求5所述的方法， 其特征在于， 在得到各计算节点所对应的预估处理时长 之后， 还包括： 对于各计算节点， 根据所述当前计算节点在当前周期内的业务请求处理量、 预估处理 时长以及周期时长， 确定所述当前计算节点的处 理效率； 将所述处理效率和所述预估处理时长发送至控制节点， 以使所述控制节点基于所述处 理效率调整各计算节点所对应的数据处 理量。 7.根据权利要求6所述的方法， 其特 征在于， 还 包括： 在所述控制节点接收到各计算节点的处理效率和相应的预估处理时长之后， 根据 各预 估处理时长确定参 考加载时长；权　利　要　求　书 1/2 页 2 CN 115442373 A 2根据各计算节点所对应的至少一个预估处理时长和所述参考加载时长， 确定预估加载 时长方差； 根据所述预估加载时长方差， 确定待更新计算节点。 8.根据权利要求7所述的方法， 其特征在于， 所述根据各计算节点所对应的至少一个预 估处理时长和所述 参考加载时长， 确定预估加载时长方差， 包括： 获取与当前计算节点相对应的至少一个预估处理时长， 并分别确定所述至少一个预估 处理时长与所述 参考加载时长 差值的平方， 得到所述当前计算节点的第一处 理值； 对各计算节点的第一处 理值求和， 得到第二处 理值； 基于所述第二处 理值和所述计算节点的数量， 确定所述预估加载时长方差 。 9.根据权利要求7所述的方法， 其特征在于， 所述根据所述预估加载时长方差， 确定待 更新计算节点， 包括： 当所述预估加载时长方差大于预设加载时长方差， 则确定所述待更新计算节点。 10.根据权利要求9所述的方法， 其特 征在于， 所述确定所述待更新计算节点， 包括： 获取各计算节点所对应的第 一处理值， 并将第 一处理值小于第 一预设处理阈值的计算 节点， 作为所述待更新计算节点。 11.根据权利要求10所述的方法， 其特征在于， 所述控制节点基于所述处理属性调 整各 计算节点所对应的数据处 理量， 包括： 基于所述控制节点将所述待更新计算节点所对应的业 务请求发送至目标计算节点； 其中， 所述目标计算节点 为第一处 理值大于第二预设处 理阈值的计算节点。 12.一种数据处 理装置， 其特 征在于， 包括： 业务请求接收模块， 用于基于网关集群接收各业务子系统发送的业务请求， 并对所述 业务请求处 理后发送至所述数据加工集群； 处理属性确定模块， 用于基于所述数据加工集群接收处理后的业务请求， 并在各计算 节点获取到相应的业务请求时， 基于控制节点确定各计算节点所对应的处理属 性， 以使控 制节点基于所述处 理属性调整各计算节点所对应的数据处 理量； 目标处理结果反馈模块， 用于基于数据展示子系统将接收到的与业务请求相对应的目 标处理结果反馈 至相应的客户端并展示。 13.一种电子设备， 其特 征在于， 包括： 处 理器， 以及与所述处 理器通信连接的存 储器； 所述存储器存储计算机执 行指令； 所述处理器执行所述存储器存储的计算机执行指令， 以实现如权利要求1 ‑11中任一项 所述的数据处 理方法。 14.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质中存储有计算机 执行指令， 所述计算机执行指 令被处理器执行时用于实现如权利要求 1‑11中任一项 所述的 方法。 15.一种计算机程序产品， 其特征在于， 包括计算机程序， 该计算机程序被处理器执行 时实现权利要求1 ‑11中任一项所述的数据处 理方法。权　利　要　求　书 2/2 页 3 CN 115442373 A 3