一种任务调度方法、装置、服务器及存储介质.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN114237852A(43)申请公布日2022.03.25(21)申请号202111565419.8(22)申请日2021.12.20(71)申请人中国平安财产保险股份有限公司地址518000广东省深圳市福田区益田路5033号平安金融中心12、13、38、39、40层(72)发明人吴永晖(74)专利代理机构广州三环专利商标代理有限公司44202代理人陈倩倩(51)Int.Cl.G06F9/48(2006.01)权利要求书2页说明书14页附图5页(54)发明名称一种任务调度方法、装置、服务器及存储介质(57)摘要本申请涉及数据处理领域，公开了一种任务调度方法、装置、服务器及存储介质，包括：当在任务操作界面上检测触发指令时，基于触发指令确定目标任务集合；对各个目标任务进行分片，得到多个子任务集合；将各个子任务集合推送给设备集群中所包括的多个执行设备，以使各个执行设备执行子任务集合中的目标任务，根据执行情况确定各自的任务状态；获取各个执行设备的任务状态，当检测到存在异常的异常执行设备时，根据任务状态从设备集群中选择目标执行设备，并将异常执行设备对应的子任务集合推送给目标执行设备。以实现灵活的任务触发，并提高任务处理的可靠性以及效率。本申请涉及区块链技术，如可将上述数据写入区块链中，以用于任务调度等场景。CN114237852ACN114237852A权利要求书1/2页1.一种任务调度方法，其特征在于，包括：当在任务操作界面上检测到与触发任务相关联的触发指令时，基于所述触发指令确定目标任务集合，所述目标任务集合包括多个目标任务；对所述目标任务集合中的各个目标任务进行分片处理，得到多个子任务集合，每个子任务集合包括一个或多个目标任务；按照预设推送规则将各个子任务集合推送给设备集群中所包括的多个执行设备，以使各个执行设备执行所接收到的子任务集合中的目标任务，并根据所述各个执行设备的执行情况确定各自的任务状态；获取所述各个执行设备的任务状态，当检测到所述设备集群中存在异常的异常执行设备时，根据所述任务状态从所述设备集群中选择目标执行设备，并将所述异常执行设备对应的子任务集合推送给所述目标执行设备。2.根据权利要求1所述的方法，其特征在于，所述当检测到所述设备集群中存在异常的异常执行设备时，根据所述任务状态从所述设备集群中选择目标执行设备之前，还包括：针对所述设备集群中任一执行设备，按照预设时间间隔向所述任一执行设备发送信号探测请求，以请求所述任一执行设备返回目标数据；确定是否在预设时间段内接收到所述任一执行设备发送的所述目标数据；若未接收到所述目标数据，则将所述任一执行设备确定为异常执行设备。3.根据权利要求1所述的方法，其特征在于，所述根据所述任务状态从所述设备集群中选择目标执行设备，包括：从所述设备集群中确定任务状态为目标任务状态的初始执行设备，得到初始执行设备集合，所述初始执行设备集合包括一个或多个初始执行设备；分别获取各个初始执行设备的空闲负载量，根据所述空闲负载量从所述初始执行设备集合中确定目标执行设备。4.根据权利要求3所述的方法，其特征在于，所述根据所述空闲负载量从所述初始执行设备集合中确定目标执行设备，包括：确定所述异常执行设备对应的子任务集合的任务总数据量；从所述初始执行设备集合中确定空闲负载量大于或等于所述任务总数据量的候选执行设备，得到候选执行设备集合，所述候选执行设备集合包括一个或多个候选执行设备；从所述候选执行设备集合中选择目标执行设备。5.根据权利要求1所述的方法，其特征在于，所述设备集群中执行设备的设备数量为M，所述子任务集合的数量为N；所述按照预设推送规则将各个子任务集合推送给设备集群中的执行设备，包括：当所述N小于或等于所述M时，从所述设备集群中为所述各个子任务集合选择一个执行设备，并将所述各个子任务集合推送给对应的执行设备，所述各个子任务集合对应的执行设备不同；当所述N大于所述M时，从所述多个子任务集合中选择M个子任务集合，将所述M个子任务集合中的每个子任务集合推送给所述设备集群中的一个执行设备，并在获取到执行设备的任务状态为目标任务状态时，将N‑M个子任务集合中的一个子任务集合推送给任务状态为目标任务状态的执行设备。2CN114237852A权利要求书2/2页6.根据权利要求5所述的方法，其特征在于，所述从所述多个子任务集合中选择M个子任务集合，包括：获取各个子任务集合对应的参考任务时间，任一参考任务时间包括：所述任一子任务集合的所有目标任务对应的任务时间中最早任务时间或最晚任务时间；按照参考任务时间从大到小的顺序依次对所述多个子任务集合进行排序，得到任务集合排序结果；从所述任务集合排序结果中选择位于前M位的子任务集合。7.根