任务处理方法、装置、服务器及存储介质.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113806029A(43)申请公布日2021.12.17(21)申请号202010549928.0(22)申请日2020.06.16(71)申请人北京达佳互联信息技术有限公司地址100085北京市海淀区上地西路6号1幢1层101D1-7(72)发明人钱佳(74)专利代理机构广州华进联合专利商标代理有限公司44224代理人方高明(51)Int.Cl.G06F9/48(2006.01)权利要求书2页说明书11页附图2页(54)发明名称任务处理方法、装置、服务器及存储介质(57)摘要本公开关于一种任务处理方法、装置、服务器及存储介质，方法包括：根据目标账户提交的重跑作业的元数据，确定重跑子作业，获取重跑子作业中的待提交至工作流调度系统中的目标任务的第一并发数量，以及目标滑动窗口中记录的任务的第二并发数量，根据第一并发数量和第二并发数量，确定是否将重跑子作业中的目标任务提交到工作流调度系统，从而避免用户频繁提交重跑作业，减少资源浪费。CN113806029ACN113806029A权利要求书1/2页1.一种任务处理方法，其特征在于，包括：根据目标账户提交的重跑作业的元数据，确定重跑子作业；获取所述重跑子作业中的待提交至工作流调度系统中的目标任务的第一并发数量，以及目标滑动窗口中记录的任务的第二并发数量；根据所述第一并发数量和所述第二并发数量，确定是否将所述重跑子作业中的目标任务提交到工作流调度系统。2.根据权利要求1所述的任务处理方法，其特征在于，所述根据目标账户提交的重跑作业的元数据，确定重跑子作业，包括：获取目标账户提交的重跑作业的元数据；根据所述元数据中的时间片，对所述重跑作业进行划分，确定所述重跑子作业。3.根据权利要求1所述的任务处理方法，其特征在于，所述根据所述第一并发数量和所述第二并发数量，确定是否将所述重跑子作业中的目标任务提交到工作流调度系统，包括：若所述第一并发数量和所述第二并发数量的和小于第一预设阈值，则确定将所述重跑子作业中的目标任务提交到所述工作流调度系统。4.根据权利要求3所述的任务处理方法，其特征在于，所述方法还包括：若所述第一并发数量和所述第二并发数量的和大于或等于所述第一预设阈值，则更新所述目标任务的第一等待时间；当到达所述第一等待时间时，返回执行所述根据所述第一并发数量和所述第二并发数量，确定是否将所述重跑子作业中的目标任务提交到工作流调度系统的步骤。5.根据权利要求3所述的任务处理方法，其特征在于，所述确定将所述重跑子作业中的目标任务提交到工作流调度系统，之前还包括：获取所述工作流调度系统的资源使用率；若所述工作流调度系统的资源使用率小于第二预设阈值，则确定将所述重跑子作业中的目标任务提交到所述工作流调度系统。6.根据权利要求5所述的任务处理方法，其特征在于，所述方法还包括：若所述工作流调度系统的资源使用率大于或等于所述第二预设阈值，更新所述目标任务的第二等待时间；当到达所述第二等待时间时，返回执行所述获取所述重跑子作业中的待提交至工作流调度系统中的目标任务的第一并发数量，以及目标滑动窗口中记录的任务的第二并发数量的步骤。7.根据权利要求5所述的任务处理方法，其特征在于，在所述若所述工作流调度系统的资源使用率小于第二预设阈值之后，所述确定将所述重跑子作业中的目标任务提交到所述工作流调度系统之前，还包括：获取资源管理系统的资源使用率；若所述资源管理系统的资源使用率小于第三预设阈值，则确定将所述重跑子作业中的目标任务提交到所述工作流调度系统。8.一种任务处理装置，其特征在于，包括：第一确定单元，被配置为执行根据目标账户提交的重跑作业的元数据，确定重跑子作业；2CN113806029A权利要求书2/2页获取单元，被配置为执行获取所述重跑子作业中的待提交至工作流调度系统中的目标任务的第一并发数量，以及目标滑动窗口中记录的任务的第二并发数量；第二确定单元，被配置为执行根据所述第一并发数量和所述第二并发数量，确定是否将所述重跑子作业中的目标任务提交到工作流调度系统。9.一种服务器，其特征在于，包括：处理器；用于存储所述处理器可执行指令的存储器；其中，所述处理器被配置为执行所述指令，以实现如权利要求1至9中任一项所述的任务处理方法。10.一种存储介质，当所述存储介质中的指令由服务器的处理器执行时，使得服务器能够执行如权利要求1至9中任一项所述的任务处理方法。3CN113806029A说明书1/11页任务处理方法、装置、服务器及存储介质技术领域[0001]本公开涉及计算机领域，尤其涉及任务处理方法、装置、服务器及存储介质。背景技术[0002]任务重跑表示对历史数据进行回溯的操作，级联重跑表示在对一个任务进行调度回溯历史数据后，还要把这