(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211066443.1 (22)申请日 2022.09.01 (71)申请人 广州南方智能技 术有限公司 地址 510665 广东省广州市天河区思成路 39号1楼A区 (72)发明人 陶超　林军　莫振浩　徐丹龙　 钟金明　张倩斯　廖天兰　余子明　 石运财　蔡卫国　 (74)专利代理 机构 广州市越秀区哲力专利商标 事务所(普通 合伙) 44288 专利代理师 孙柳 (51)Int.Cl. G06F 9/48(2006.01) G06N 20/00(2019.01) (54)发明名称 一种算法程序的自动化调度系统、 方法及存 储介质 (57)摘要 本发明公开了一种算法任务的自动化调度 系统， 包括客户端， 用于提供可视化界面， 以获取 算法流程图； 管理节点集群， 用于对客户端上传 的算法流程图并对算法流程图进行解析以得出 每个算法任务的输入输出数据及执行顺序， 并按 照执行顺序依次将每个算法任务的输入输出数 据下发给对应计算节点集群； 以及接收计算节点 集群反馈回的执行结果； 计算节点集群， 用于接 收管理节点集群下发的对应算法任务的输入输 出数据匹配对应算法引擎并通过对应算法引擎 调用对应程序代码执行。 本发明能够实现算法程 序的自动调用， 用户无需熟悉 每个算法的程序代 码即可快速完成任务的处理， 具有操作方便等特 点。 本发明还公开了一种算法任务的自动化调度 方法及存 储介质。 权利要求书2页 说明书7页 附图3页 CN 115454595 A 2022.12.09 CN 115454595 A 1.一种算法任务的自动化调度系统， 其特 征在于， 包括： 客户端， 用于提供可视化界面， 以获取用户构建的算法流程图； 所述算法流程图包括一 个作业项目的所有算法任务、 每个算法任务的输入输出数据以及每个算法任务的执行顺 序； 管理节点集群， 与所述客户端通信连接， 用于对所述客户端上传的算法流程图并对所 述算法流程图进 行解析以得出每个算法任务的输入输出数据及执行顺序， 并按照执行顺序 依次将每个算法任务的输入输出数据下发给对应计算节点集群； 以及接收所述计算节点集 群反馈回的执 行结果； 直到所有的算法任务执 行完毕后得 出作业项目的输出 结果； 计算节点集群， 与所述管理节点集群通信连接， 用于接收所述管理节点集群下发的对 应算法任务的输入输出数据匹配对应算法引擎并通过对应算法引擎调用对应程序代码执 行。 2.根据权利要求1所述的算法任务的自动化调度系统， 其特征在于， 包括： 所述算法流 程图采用有向无环图的形式表示， 并且有向无环图的节点表示每 个算法任务。 3.根据权利要求2所述的算法任务的自动 化调度系统， 其特征在于， 所述客户端提供的 可视化界面包括组件区和操作区； 其中， 所述组件区， 用于显示算法任务组件， 每个算法任 务组件均与算法库中的对应算法任务的程序代码相匹配； 所述操作区， 用于显示用户通过 拖拽的方式从组件区选择的对应的算法任务组件所 形成的有向无环图。 4.根据权利要求1所述的算法任务的自动 化调度系统， 其特征在于， 所述管理节点集群 包括主管理节点和备用管理节 点； 其中， 所述主 管理节点与客户端通信连接， 用于获取所述 客户端上传的算法流程图并对所述算法流程图进 行解析， 以及将解析得出的每个算法流程 图的输入输出 数据按照执 行顺序存 储于队列中； 所述备用管理节点， 用于当所述主管理节点正常工作时， 处于休眠状态， 当所述主管理 节点存在故障时， 从休眠状态退 出并替换 所述主管理节点称为 新的主管理节点； 所述备用管理节点有一个或多个， 并且当所述备用管理节点有多个时， 通过选举的方 式从多个备用管理节点中选择一个备用管理节点 替换存在故障的主管理节点。 5.根据权利要求4所述的算法任务的自动 化调度系统， 其特征在于， 所述计算节点包括 若干个计算节点； 所述主管理节点， 用于在按照执行顺序调用对应算法任务的输入输出数 据后， 对对应算法任务的输入输出数据进行分组， 以及将分组后的输入输出数据下发给对 应的计算节点； 所述主管理节点， 还用于接收每个计算节点反馈回的执行结果并将若干个执行结果进 行整合以得 出对应算法任务的输出 结果； 每个计算节点， 还用于定时向所述主管理节点发送心跳连接， 以使得所述主管理节点 更新对应 计算节点的可用状态。 6.一种算法任务的自动化调度方法， 其特 征在于， 所述自动化调度方法包括： 获取步骤： 获取算法流程图； 所述算法流程图包括一个作业项目的所有算法任务、 每个 算法任务的输入输出 数据以及每 个算法任务的执 行顺序； 处理步骤： 对所述算法流程图进行解析以得出每个算法任务的输入输出数据和执行顺 序， 并按照执行顺序依次根据每个算法任务的输入输出数据匹配对应算法引擎并通过对应 算法引擎调用对应程序代码执行； 以及直到所有算法任务执行完毕后， 得出作业项目的输权　利　要　求　书 1/2 页 2 CN 115454595 A 2出结果。 7.根据权利要求6所述的算法任务的自动 化调度方法， 其特征在于， 所述处理步骤还包 括： 解析步骤： 对所述算法流程图进行解析以得出每个算法任务的输入输出数据和执行顺 序； 存储步骤： 按照执 行顺序将每 个算法任务的输入输出 数据依次存 储于队列中； 调用步骤： 从队列中依次取出每个算法任务的输入输出数据， 并将每个算法任务的输 入输出数据分配对应的计算节点， 从而使得所述计算节点匹配得出对应算法引擎并通过对 应算法引擎调用对应程序 代码执行； 以及获取所述计算节点反馈回的执行结果得出对应算 法任务的输出 结果。 8.根据权利要求7所述的算法任务的自动 化调度方法， 其特征在于， 所述调用步骤还包 括： 从队列中依次取出每个算法任务的输入输出数据后 将对应算法任务的输入输出数据分 组， 并根据每组输入输出数据分配给对应的计算节点， 以使得每个计算节点根据分配的输 入输出数据从算法库中匹配得出对应算法程序并执行， 以及接收每个计算节点反馈的执行 结果并整合后得 出对应算法任务的输出 结果。 9.根据权利要求8所述的算法任务的自动化调度方法， 其特征在于， 还包括： 定时检测 步骤： 定时获取每 个计算节点上传的运行状态并计时更新每 个计算节点的可用状态。 10.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于： 所述计算机程序 为自动化调度程序， 所述自动化调度程序被处理器执行时实现如权利要求6 ‑9中任意一项 所述的一种算法任务的自动化调度方法的步骤。权　利　要　求　书 2/2 页 3 CN 115454595 A 3