CN113608891B 分布式批处理系统、方法、计算机设备和存储介质 （上海浦东发展银行股份有限公司）

号2批量运行中心，用于从所述消息队列中取出所述任务信息，其中，所述当满足触发条件时执行对应的轮询机制，对批量使用quartz框架设置定时轮询任务，若当前时间符合批量计划执行上一次满足所述数据库轮询的触发条件时处理的结构化查询语判断上一次满足所述数据库轮询的触发条件时处理定时查询批量系统参数配置表的版本号和批量计划任务配多个批量调度中心同时运行时，通过quartz框架注册到多个批量运行中心同时从队列中争抢获取所述任初始化不同轮询机制的轮询信息，包括：根据批量计划任务3将所述任务信息传输至消息队列；根据所述任务信息对所述待分配作业进行多重分包处理，得到若其中，所述当满足触发条件时执行对应的轮询机制，对批量使用quartz框架设置定时轮询任务，若当前时间符合批量计划执行上一次满足所述数据库轮询的触发条件时处理的结构化查询语判断上一次满足所述数据库轮询的触发条件时处理定时查询批量系统参数配置表的版本号和批量计划任务配根据批量系统参数配置表中的轮询信息初始化不同的通过所述cron表达式中各字符串的内容修改各轮询机制之间9.一种计算机设备，包括存储器和处理器，所述存储器存4被处理器执行时实现权利要求4至8中任意一项所述的56消息队列中取出所述任务信息；根据所述任务信息对所述待分配作业进行多重分包处理，状态进行定时轮询；执行上一次满足所述数据库轮询的触发条件时处理的结构化查询语器执行所述计算机程序时实现上述任意一项实施例中所述被处理器执行时实现上述任意一项实施例中所述的[0019]图3为本发明其中一实施例的对批量作业的执行状态进行轮询的方法流程示意7[0026]图1为本发明其中一实施例的分布式批处理系统的结构框图，在其中一个实施例运行中心200用于从消息队列MQ中取出任务信息。根据任务信息对待分配作业进行多重分8[0033]在其中一个实施例中，分布式批处理系统包括多个批量调度中心100和多个批量中心100通过定时争抢触发批量任务的方式实现争抢机制；多个批量执行中心则通过争抢个批量调度中心100同时运行时，保证同一时间只有一个批量调度中心100满足触发条件。9[0037]在一些公开的实施例中，批量调度中心100和批量执行中心200均支持容器化部大批量中心的争抢机制还能够完美地适配容器化部署后便捷的横向扩展和优雅下线的功[0038]批量调度中心100和批量执行中心200通过实行争抢机制以及支持容器化部署等[0039]在其中一个实施例中，批量运行中心200还具有批量处理文件和配置化生成报表[0040]本公开还提供了一种分布式批处理方法，图2为本发明其中一实施例的分布式批间符合定时轮询的触发条件时，批量调度中心100将执行定时轮询。通过设计多种轮询机[0046]批量调度中心100还可以将未处理的待分配作业的任务信息传输至消息队列MQ[0050]批量运行中心200可以根据任务信息对待分配作业进行多重分包处理。多重分包[0052]批量运行中心200在多重分包完成后，还可以将获得的子包重新放入消息队列MQ[0057]图3为本发明其中一实施例的对批量作业的执行状态进行轮询的方法流程示意行上一次满足数据库轮询的触发条件的SQL查询语句，根据查询结果判断是否满足此次数[0062]若上一次触发条件的SQL查询语句的查询结果不为空，则判断触发满足此次数据[0063]步骤S230：判断上一次满足数据库轮询的触发条件时处[0064]在本公开的一些实施例中，文件轮询是指对某一指定路径下的对应文件进行轮存在已完成执行但尚未进行合并的子包，若存在则判断触发满足作业归并轮询的触发条[0070]图4为本发明其中一实施例的定时检查配置表版本号的方法流程示意图，在其中[0074]当集中监控平台查询发现批量系统参数配置表的版本号与上一次查询时的版本程序。存储器S22中存储的应用程序可以包括一个或一个以上的每一个对应于一组指令的令的存储器S22，上述指令可由数据库查询装置或系统S00的处理