一种任务处理方法和装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113760522A(43)申请公布日2021.12.07(21)申请号202011025394.8(22)申请日2020.09.25(71)申请人北京沃东天骏信息技术有限公司地址100176北京市北京经济技术开发区科创十一街18号院2号楼4层A402室申请人北京京东世纪贸易有限公司(72)发明人李晓静(74)专利代理机构中原信达知识产权代理有限责任公司11219代理人王志远赵迪(51)Int.Cl.G06F9/50(2006.01)G06F9/54(2006.01)权利要求书2页说明书13页附图3页(54)发明名称一种任务处理方法和装置(57)摘要本发明公开了一种任务处理方法和装置，涉及计算机技术领域。该方法的一具体实施方式包括：接收定时任务；获取定时任务队列的存储路径，根据所述存储路径将所述定时任务存入所述定时任务队列；当基于预设频率检测到所述定时任务队列中的定时任务到达执行时间时，从负载有任务执行队列的设备集合中，根据设备状态信息识别出目标设备；将达到执行时间的定时任务从所述定时任务队列转存入所述目标设备中的任务执行队列，以处理该定时任务。该实施方式能够通过该统一方法实现定时任务的处理，容易维护，且更加便于集群场景下的部署，同时，多种队列的设置有利于解决容灾问题、扩容问题、重试机制的缺失问题。CN113760522ACN113760522A权利要求书1/2页1.一种任务处理方法，其特征在于，包括：接收定时任务；获取定时任务队列的存储路径，根据所述存储路径将所述定时任务存入所述定时任务队列；当基于预设频率检测到所述定时任务队列中的定时任务到达执行时间时，从负载有任务执行队列的设备集合中，根据设备状态信息识别出目标设备；将达到执行时间的定时任务从所述定时任务队列转存入所述目标设备中的任务执行队列，以处理该定时任务；其中，对于同一时间戳，所述定时任务队列的个数为一个，所述任务执行队列的个数为至少一个。2.根据权利要求1所述的方法，其特征在于，所述根据所述存储路径将所述定时任务存入所述定时任务队列，包括：根据所述定时任务预计的执行时间、任务数据生成所述定时任务的第一任务消息；基于所述执行时间，将所述第一任务消息存入所述存储路径指示的定时任务队列中，使得所述定时任务队列中的定时任务按照各自的执行时间从先到后的顺序有序排列。3.根据权利要求1所述的方法，其特征在于，所述从负载有任务执行队列的设备集合中，根据设备状态信息识别出目标设备，包括：获取所述设备集合中各设备的设备状态信息；所述设备状态信息至少包括：设备的处理量阈值、设备上负载的所有任务执行队列中的已有任务总量；计算得到所示已有任务总量与所述处理量阈值的商值，将所述商值低于第二阈值的设备，作为所述目标设备。4.根据权利要求2所述的方法，其特征在于，所述将达到执行时间的定时任务从所述定时任务队列转存入所述目标设备中的任务执行队列，包括：从所述定时任务队列中取出所述达到执行时间的定时任务的第一任务消息，提取该第一任务消息中的任务数据，并为该任务添加任务执行状态信息；根据所述任务数据和所述任务执行状态信息，生成所述达到执行时间的定时任务的第二任务消息；其中，将所述任务执行状态信息的初始值设置为未执行；从所述目标设备上负载的任务执行队列中，选出一目标任务执行队列，将所述第二任务消息存入所述目标任务执行队列。5.根据权利要求4所述的方法，其特征在于，所述从所述目标设备上负载的任务执行队列中，选出一目标任务执行队列，包括：获取所述目标设备上负载的各任务执行队列中的队列已有任务量；将队列已有任务量小于第三阈值的任务执行队列，作为待选队列；基于预设算法从所述待选队列中选出一目标任务执行队列。6.根据权利要求4所述的方法，其特征在于，在所述处理该定时任务之后，还包括：当处理定时任务失败，将所述处理失败的定时任务从所述任务执行队列转存入重试队列，以对该处理失败的定时任务进行重试处理。7.根据权利要求6所述的方法，其特征在于，所述将所述处理失败的定时任务从所述任务执行队列转存入重试队列，包括：从所述任务执行队列中取出所述处理失败的定时任务的第二任务消息，提取该第二任2CN113760522A权利要求书2/2页务消息中的任务数据、任务执行状态信息，并将所述任务执行状态信息更新为失败一次；根据所述任务数据和所述更新后的任务执行状态信息，生成所述处理失败的定时任务的第三任务消息；将所述第三任务消息存入所述重试队列。8.根据权利要求7所述的方法，其特征在于，在对该处理失败的定时任务进行重试处理之后，还包括：当重试处理失败一次，将该任务的任务执行状态信息中的失败次数自增更新一次；当重试队列中任务的失败次数达到次数阈值，将该任务的第三