(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210577512.9 (22)申请日 2022.05.25 (71)申请人 中国联合网络通信集团有限公司 地址 100033 北京市西城区金融大街21号 (72)发明人 金连旭　孟刚　李志民　王晓宁　 阚清博　汤兆全　 (74)专利代理 机构 北京同立钧成知识产权代理 有限公司 1 1205 专利代理师 霍莉莉　臧建明 (51)Int.Cl. G06F 16/242(2019.01) G06F 16/2455(2019.01) (54)发明名称 任务调度方法、 装置、 设备及可读存 储介质 (57)摘要 本发明提供一种任务调度方法、 装置、 设备 及可读存储介质， 该方法包括： 获取预先存储的 伪SQL模板以及所有待执行任务的任务配置信 息； 根据每一待执行任务对应的任务配置信息， 从所有待执行任务中确定与当前未占用的可执 行通道数量对应的多个第一待执行任务； 针对每 一第一待执行任务， 根据对应的任务配置信息确 定至少一个待执行的伪SQL模板， 将伪SQL模板的 变量信息进行替换以得到至少一个可执行SQL语 句， 根据可执行SQL语句对集群终端中的数据库 进行查询， 获取查询结果， 该方法可以实现在执 行任务时， 能够根据预先设置的伪SQL模板自动 且快速得到可执行语句， 无需多次修改SQL语句， 提高了任务调度的效率。 权利要求书2页 说明书12页 附图5页 CN 114996293 A 2022.09.02 CN 114996293 A 1.一种任务调度方法， 其特 征在于， 所述方法包括： 获取预先存储的伪SQL模板以及所有待执行任务的任务配置信息； 所述伪SQL模板中包 含变量信息； 根据每一待执行任务对应的任务配置信 息， 从所有待执行任务中确定与当前未占用的 可执行通道数量对应的多个第一待执 行任务； 针对每一所述第一待执行任务， 根据对应的任务配置信息确定至少一个待执行的伪 SQL模板， 将所述伪SQL模板的变量信息进 行替换以得到至少一个可执行SQL语句， 将所述可 执行SQL语句发送给集群终端， 以使所述集群终端执行所述可执行SQL语句， 接收所述集群 终端发送的与所述待执 行任务对应的查询结果。 2.根据权利要求1所述的方法， 其特征在于， 所述伪SQL模板为根据业务场景设置的； 所 述伪SQL模板包括下述至少一个： 建表模板、 导入 模板、 导出模板、 稽核模板和统计模板 。 3.根据权利要求2所述的方法， 其特征在于， 所述稽核模板的属性信息包括： 稽核目标 数据、 稽核语句、 等待时间和稽核循环次数； 所述稽核模板用于 当对数据库中的数据 表进行 异步操作后， 根据所述稽核语句的结果数据和所述稽核目标数据判断所述异 步操作是否执 行完毕， 若未执行完毕， 则根据所述等待时间和稽核循环 次数进行多次稽核； 若执行完毕， 则继续执 行下一伪SQ L模板对应的可 执行SQL语句。 4.根据权利要求1所述的方法， 其特征在于， 所述任务配置信 息包括标识信 息和对应的 执行顺序信息； 根据对应的任务配置信息确定 至少一个待执 行的伪SQ L模板， 包括： 根据所述标识信息从预 先存储的伪SQ L模板中筛 选出待执 行的伪SQ L模板； 相应的， 将所述可 执行SQL语句发送给集群终端， 包括： 根据所述对应的执 行顺序信息将所述可 执行SQL语句发送给集群终端。 5.根据权利要求1所述的方法， 其特征在于， 所述任务配置信息还包括目标变量值； 将 所述伪SQ L模板的变量信息进行替换以得到 至少一个可 执行SQL语句， 包括： 将所述任务配置信息中的目标变量值替换所述伪SQL模板的变量信息以得到可执行 SQL语句。 6.根据权利要求1 ‑4任一项所述的方法， 其特征在于， 所述任务配置信息包括： 执行条 件和优先级信息； 根据每一待执行任务对应的任务配置信息， 从所有待执行任务中确定与 当前未占用的可 执行通道数量对应的多个第一待执 行任务， 包括： 根据每一待执 行任务对应的执 行条件从所有 待执行任务中确定第二待执 行任务； 确定当前 未占用的可 执行通道数量； 根据每一第 二待执行任务对应的优先级信 息， 确定与当前未占用的可执行通道数量对 应的多个第一待执 行任务。 7.根据权利要求6所述的方法， 其特征在于， 所述执行条件包括执行时间和/或依赖条 件； 根据每一待执 行任务对应的执 行条件从所有 待执行任务中确定第二待执 行任务， 包括： 获取当前时间和/或当前任务调度状态； 针对每一待执行任务， 当确定所述当前时间满足所述待执行任务对应的执行时间， 和/ 或， 所述当前任务调度状态满足所述依赖条件时， 则确定所述待执行任务为所述第二待执 行任务。 8.根据权利要求6所述的方法， 其特征在于， 所述确定当前未占用的可执行通道数量，权　利　要　求　书 1/2 页 2 CN 114996293 A 2包括： 获取日志信息， 根据所述日志信息确定当前占用的可 执行通道数量； 根据最大可执行通道数量和所述当前占用的可执行通道数量确定当前未占用的可执 行通道数量。 9.根据权利要求6所述的方法， 其特征在于， 根据每一第 二待执行任务对应的优先级信 息， 确定与当前 未占用的可 执行通道数量对应的第一待执 行任务， 包括： 按照优先级信息由高到低的顺序对所有第二待执 行任务进行排序； 根据排序结果， 筛选出预设数量的第二待执行任务， 将筛选出的预设数量的第二待执 行任务确定为第一待执 行任务； 所述预设数量 等于当前 未占用的可 执行通道数量。 10.根据权利要求9所述的方法， 其特征在于， 所述筛选出预设数量的第二待执行任务 之后， 还包括： 更新剩余的第二待执 行任务的等待次数； 相应的， 所述按照优先级信息由高到低的顺序对所有第二待执 行任务进行排序， 包括： 当存在优先级信 息相同的若干个第 二待执行任务 时， 比较所述若干个第 二待执行任务 的等待次数， 按照等待次数由高到低的顺序对所述若干个第二待执 行任务进行排序。 11.一种任务调度装置， 其特 征在于， 所述装置包括： 获取模块， 用于获取预先存储的伪SQL模板以及所有待执行任务的任务配置信息； 所述 伪SQL模板中包 含变量信息； 确定模块， 用于根据每一待执行任务对应的任务配置信息， 从所有待执行任务中确定 与当前未占用的可 执行通道数量对应的多个第一待执 行任务； 处理模块， 用于针对每一所述第一待执行任务， 根据对应的任务配置信息确定至少一 个待执行的伪SQL模板， 将所述伪SQL模板的变量信息进行替换以得到至少一个可执行SQL 语句， 将所述可执行SQL语句发送给集群终端， 以使 所述集群终端 执行所述可执行SQL语句， 接收所述 集群终端发送的与所述待执 行任务对应的查询结果。 12.一种任务调度设备， 其特 征在于， 包括： 至少一个处 理器和存 储器； 所述存储器存储计算机执 行指令； 所述至少一个处理器执行所述存储器存储的计算机执行指令， 使得所述至少一个处理 器执行如权利要求1 ‑10任一项所述的方法。 13.一种计算机可读存储介质， 其特征在于， 所述存储介质存储有计算机程序， 所述计 算机程序被处 理器执行时， 实现如权利要求1 ‑10任一项所述的方法。权　利　要　求　书 2/2 页 3 CN 114996293 A 3