1.本技术涉及任务管理技术,尤其涉及一种任务状态管理方法、任务管理系统和任务调用系统。
背景技术:
2.随着大数据的发展,一个企业需要处理的数据规模也不断的扩大,需要处理的任务也越来越多,该任务指的是为达成某种目的而执行的操作,例如,获取月报报表数据需要执行数据etl(extract-transform-load)处理任务。面对如此庞大的任务量,高效的任务管理方法是保证任务井然有序的执行的前提,也是提高员工工作效率的有效手段。
3.一个企业通常由多个部门组成,各部门都有不同的任务需要处理,所以各部门都会有单独的任务调度系统,通过任务调度系统可以对自己部门的任务进行有效的管理。
4.但是各部门使用的任务调度系统都相互独立,部门间的任务状态都无法相互获取,容易形成信息孤岛。然而,一个部门往往需要连接多个部门的信息才能解决该部门的日常运作,即多个部门的任务存在任务依赖,例如,部门a的任务与部门b的任务存在任务依赖,当部门a的数据处理完成后,部门b无法了解部门a何时完成的,或者,部门a的数据处理任务发生异常,部门b也无法得知,会造成部门b的任务一直等待,无法执行,所以信息孤岛的形成,使得部门间的任务依赖无法实现。
技术实现要素:
5.本技术提供一种任务状态管理方法、任务管理系统和任务调用系统,用以解决企业部门之间由于信息孤岛无法实现任务依赖的问题。
6.第一方面,本技术提供一种任务状态管理的方法,应用于任务管理系统,包括:
7.收集各任务调用系统的任务状态信息,所述任务状态信息包括:任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态,所述任务执行状态包括:执行中、执行成功或者执行失败;
8.接收目标任务调用系统发送的任务状态查询消息,所述任务状态查询消息中包括待查询任务的任务归属项目和任务名称;
9.根据所述任务状态查询消息和收集到的任务状态信息,查询得到所述待查询任务的任务状态信息;
10.向所述目标任务调用系统返回任务状态查询消息对应的响应消息,所述任务状态查询消息的响应消息中包括所述待查询任务的任务状态信息。
11.可选的,所述收集各任务调度系统的任务状态信息,包括:
12.在所述任务调用系统执行任务之前,接收所述任务调用系统发送的任务开始状态信息,所述任务开始状态信息包括所述任务归属项目、所述任务名称和任务开始时间;
13.向所述任务调用系统返回所述任务开始状态信息对应的第一响应消息;
14.在所述任务调用系统执行所述任务完成时,接收所述任务调用系统发送的任务结
束状态信息,所述任务结束状态信息包括所述任务归属项目、所述任务名称、所述任务开始时间、所述任务结束时间和所述任务执行状态;
15.向所述任务调用系统返回所述任务结束状态信息对应的第二响应消息。
16.可选的,还包括:
17.接收第一任务调用系统发送的任务预警配置信息,所述任务预警配置信息包括任务归属项目、任务名称、责任人邮箱地址、任务是否监控和任务预警阈值;
18.向所述第一任务调用系统返回所述任务预警配置信息对应的第三响应消息;
19.当所述任务预警配置参数指示了对任务进行监控时,则对所述任务的状态进行监控。
20.可选的,还包括:
21.接收所述第一任务调用系统发送的任务预警状态查询消息,所述任务预警状态查询消息包括所述任务归属项目和所述任务名称;
22.向所述第一任务调用系统返回所述任务预警状态查询消息对应的第四响应消息。
23.可选的,所述对所述任务的状态进行监控,包括:
24.每隔预设时间对所述任务的状态进行检测;
25.所述对所述任务的状态进行监控之后,还包括:
26.如果所述任务结束时间在所述任务预警阈值之后,或者,如果未检测到所述任务的状态信息,将所述任务的异常信息发送给所述责任人邮箱地址对应的邮箱,其中,所述任务预警阈值为一个时间点。
27.可选的,所述任务管理系统通过springboot框架提供应用程序接口api,通过所述api与所述各任务调用系统进行数据传输。
28.可选的,所述第一响应消息和所述第二响应消息都包括接口返回状态码、接口返回错误信息和接口返回结果,其中,当调用接口不成功时,所述接口返回结果为空值,所述接口返回状态码的值用于指示接口调用不成功,所述接口错误信息的值用于指示接口调用错误原因;
29.当调用接口成功时,所述第一响应消息中的接口返回状态码的值用于指示接口调用成功,所述接口错误信息为空值,所述接口返回结果的值用于指示保存成功;
30.当调用接口成功时,所述第二响应消息中的接口返回状态码的值用于指示接口调用成功,所述接口错误信息为空值,所述接口返回结果的值用于指示更新成功。
31.可选的,所述第三响应消息包括接口返回状态码、接口返回错误信息和接口返回结果,当接口调用不成功时,所述接口返回结果为空值,所述接口返回状态码的值用于指示接口调用不成功,所述接口错误信息的值用于指示接口调用错误原因;
32.当接口调用成功时,所述第三响应消息中的接口返回状态码的值用于指示接口调用成功,所述接口错误信息为空值,所述接口返回结果的值为“保存成功”。
33.可选的,所述第四响应消息包括接口返回状态码、接口返回错误信息和接口返回结果,当接口调用不成功时,所述接口返回结果为空值,所述接口返回状态码的值用于指示接口调用不成功,所述接口错误信息的值用于指示接口调用错误原因;
34.当接口调用成功时,所述第四响应消息中的接口返回状态码的值用于指示接口调用成功,所述接口错误信息为空值,所述接口返回结果包括所述责任人邮箱地址、所述任务
是否监控和所述任务预警阈值的值。
35.第二方面,本技术提供一种任务状态管理的方法,应用于任务调用系统,包括:
36.所述任务调用系统将任务状态信息发送给任务管理系统,所述任务状态信息包括:任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态,所述任务执行状态包括:执行中、执行成功或者执行失败;
37.所述任务调用系统将任务状态查询信息发送给所述任务管理系统,所述任务状态查询消息中包括待查询任务的任务归属项目和任务名称;
38.接收所述任务管理系统返回的所述任务状态查询信息对应的响应消息,所述任务状态查询消息的响应消息中包括所述待查询任务的任务状态信息。
39.可选的,所述任务调用系统将任务状态信息发送给任务管理系统,包括:
40.在所述任务调用系统执行任务之前,向所述任务管理系统发送任务开始状态信息,所述任务开始状态信息包括所述任务归属项目、所述任务名称和任务开始时间;
41.接收所述任务管理系统返回的所述任务开始状态信息对应的第一响应消息;
42.在所述任务调用系统执行所述任务完成时,向所述任务管理系统发送任务结束状态信息,所述任务结束状态信息包括所述任务归属项目、所述任务名称、所述任务开始时间、所述任务结束时间和所述任务执行状态;
43.接收所述任务管理系统返回的所述任务结束状态信息对应的第一响应消息。
44.可选的,还包括:
45.所述任务调用系统将任务预警配置信息发送给所述任务管理系统,所述任务预警配置信息包括任务归属项目、任务名称、责任人邮箱地址、任务是否监控和任务预警阈值;
46.接收所述任务管理系统返回的所述任务预警配置信息对应的第三响应消息。
47.可选的,还包括:
48.所述任务调用系统将任务预警状态查询信息发送给所述任务管理系统,所述任务预警状态查询信息包括所述任务归属项目和所述任务名称;
49.接收所述任务管理系统返回的所述任务预警状态查询信息对应的第四响应消息。
50.可选的,所述任务调用系统通过应用程序接口api与所述任务管理系统进行数据传输,所述api是所述任务管理系统通过springboot框架提供的api。
51.第四方面,本技术提供一种任务管理系统,包括:
52.收集模块:用于收集各任务调用系统的任务状态信息,所述任务状态信息包括:任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态,所述任务执行状态包括:执行中、执行成功或者执行失败;
53.接收模块:用于接收目标任务调用系统发送的任务状态查询消息,所述任务状态查询消息中包括待查询任务的任务归属项目和任务名称;
54.查询模块:用于根据所述任务状态查询消息和收集到的任务状态信息,查询得到所述待查询任务的任务状态信息;
55.发送模块:用于向所述目标任务调用系统返回任务状态查询消息对应的响应消息,所述任务状态查询消息的响应消息中包括所述待查询任务的任务状态信息。
56.第五方面,本技术提供一种任务调用系统,包括:
57.第一发送模块:用于任务调用系统将任务状态信息发送给任务管理系统,所述任
务状态信息包括:任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态,所述任务执行状态包括:执行中、执行成功或者执行失败;
58.第二发送模块:用于所述任务调用系统将任务状态查询信息发送给所述任务管理系统,所述任务状态查询消息中包括待查询任务的任务归属项目和任务名称;
59.接收模块:用于接收所述任务管理系统返回的所述任务状态查询信息对应的响应消息,所述任务状态查询消息的响应消息中包括所述待查询任务的任务状态信息。
60.第六方面,本技术提供一种系统,包括:至少一个处理器、存储器、收发器;
61.所述处理器控制所述收发器的接收动作和发送动作;
62.所述存储器存储计算机执行指令;
63.所述至少一个处理器执行所述存储器存储的计算机执行指令,使得所述至少一个处理器用于实现第一方面或者第二方面所述的方法。
64.第七方面,本技术提供一种计算机可读存储介质,所述计算机可读存储介质中存储有计算机执行指令,所述计算机执行指令被处理器执行时实现如第一方面或者第二方面所述的方法。
65.第八方面,本技术提供一种计算机程序产品,包括计算机程序,所述计算机程序被处理器执行时,实现如本技术第一方面或者第二方面所述的方法。
66.本技术提供的一种任务状态管理方法、任务管理系统和任务调用系统,通过收集各个部门通过各任务调用系统的任务状态信息,当部门之间存在任务依赖时,任务管理系统接收到目标任务调用系统发送的任务状态查询消息,任务管理系统根据该任务状态查询消息和收集到的任务状态信息,查询得到待查询任务的任务状态信息,并将该任务状态查询信息对应的响应消息,返回给目标任务调用系统,该响应消息中包括待查询任务的任务状态信息,目标任务调用系统根据该响应信息可以了解到该任务的任务状态,使得目标调用系统可以根据查询到的任务状态信息执行与本部门中与该任务存在依赖关系的任务,即当该任务执行完成,与该任务存在依赖关系的任务就可以开始执行,实现了部门之间的任务依赖,各部门完成各自任务的效率有所提高。
附图说明
67.此处的附图被并入说明书中并构成本说明书的一部分,示出了符合本技术的实施例,并与说明书一起用于解释本技术的原理。
68.图1为任务依赖关系的示意图;
69.图2为本技术适用的一种应用场景的示意图;
70.图3为本技术实施例一提供的一种任务状态管理的方法的流程示意图;
71.图4为本技术实施例二提供的一种对任务状态监控的方法的流程示意图;
72.图5为本技术实施例三提供的一种对任务状态管理的方法的流程示意图;
73.图6为本技术实施例四提供的一种任务状态管理的方法的信令流程图;
74.图7为本技术实施例五提供的一种任务管理系统的结构示意图;
75.图8为本技术实施例六提供的一种任务调用系统的结构示意图;
76.图9为本发明实施例七提供的一种服务器的结构示意图。
77.通过上述附图,已示出本技术明确的实施例,后文中将有更详细的描述。这些附图
和文字描述并不是为了通过任何方式限制本技术构思的范围,而是通过参考特定实施例为本领域技术人员说明本技术的概念。
具体实施方式
78.这里将详细地对示例性实施例进行说明,其示例表示在附图中。下面的描述涉及附图时,除非另有表示,不同附图中的相同数字表示相同或相似的要素。以下示例性实施例中所描述的实施方式并不代表与本技术相一致的所有实施方式。相反,它们仅是与如所附权利要求书中所详述的、本技术的一些方面相一致的装置和方法的例子。
79.一个企业通常由多个部门组成,各部门都有不同的任务需要处理,所以各部门都会有单独的任务调度系统,通过任务调度系统可以对自己部门的任务的运行进行有效的管理,但是各部门使用的任务调度系统都相互独立,部门间的任务状态都无法相互获取,容易形成信息孤岛。然而,一个部门往往需要连接多个部门的信息才能解决该部门的日常运作,即多个部门的任务存在任务依赖,所以信息孤岛的形成,会导致部门间的任务以来无法实现,这样就大大影响了各个部门的工作效率。
80.针对现有技术中的上述问题,本技术提供一种任务状态管理方法和系统,任务管理系统收集各部门通过各自的任务调用系统发送的任务状态信息,该任务状态信息用于目标任务调用系统查询与本部门的任务存在任务依赖关系的其他部门的任务的任务状态信息,使得使用该目标调用系统的负责人可以根据查询到的任务状态信息安排与本部门中与该任务存在依赖关系的任务执行,即当该任务执行完成,与该任务存在依赖关系的任务就可以开始执行,实现了部门之间的任务依赖。
81.下面对本技术所涉及的名词进行解释:
82.任务:指为达成某种目的而执行的某种操作,例如,某部门为了获取月报报表数据,需要执行数据etl处理任务,即为数据抽取-转换-加载处理。
83.任务调度:是指根据一定的约束规定,将计算资源分配给符合条件的任务使用,在分配过程中,既可以将多个任务并行处理,即多个任务同时执行,也可以将多个任务串行处理,即多个任务中,只能执行完一个任务再执行下一个任务。
84.任务调度系统:任务调度系统负责一个任务何时运行,何时结束以及正确的处理任务之间的依赖关系。
85.任务依赖关系:只有当前面一个或者多个任务完成后,才能完成下一个任务,例如,如图1所示,任务b和任务c依赖于任务a,任务d依赖用于任务b,任务e依赖于任务d和任务c,即只有前面的任务执行完成,依赖前面任务的任务才能执行。
86.任务状态:是指在整个任务生命周期中,任意时间点对应的任务的执行状态,任务状态一般包括任务未执行、任务开始执行、任务执行中、任务执行结束,其中,任务执行结束有包括“任务执行成功”和“任务执行失败”两种状态。
87.调用api接口的get方式:api(application programming interface)是应用程序接口,该方式是通过访问一个网址,该网址是接口提供方提供的,需要传递的参数直接在网址上设置,即直接设置对应参数的值,例如:http://localhost:8080/monitor/email=test@sina.com&monitortime=05:00&monito rable=1,其中email、monitortime和monitorable为传递的参数,等号后面为其参数对应的值。接口提供方在设置接口时,也可
以将其设置为对用户来说简单的显示方式,即访问一个网址时,提供一个输入框,用户在输入框中设置需要传递的参数即可,或者,如上述举例,用户可以直接通过设置一个链接中的参数而达到调用接口的目的。
88.调用api接口的post方式:访问一个网址,该网址是接口提供方提供的,需要传递的参数在post方式提供的一个“容器”中,可以理解为,该网址是固定的接口链接,其参数需要在post方式提供的固定的代码模板中,去设置需要传递的参数。接口提供方在设置接口时,也可以将其设置为对用户来说简单的显示方式,即访问一个网址时,提供一个输入框,用户在输入框中设置需要传递的参数即可,这种实现方式与get方式一样,或者,如上述提到的,用户可以直接将一个脚本代码中的接口链接修改为接口提供方提供的固定的网址,并且修改“容器”部分来设置里面的参数而达到调用接口的目的。
89.图2为本技术适用的一种应用场景的示意图。如图2所示,终端设备201可以接收到任务管理系统发送的任务异常信息,终端设备201、服务器202、服务器203、服务器204和服务器205之间通过互联网进行信息交互。服务器202、服务器203和服务器204均为运行各部门使用的任务调用系统的服务器,服务器205为运行任务管理系统的服务器,该任务调用系统是各部门用来管理部门内部的任务的执行,该任务管理系统用来管理所有部门任务的任务状态,各任务调用系统均可以向任务管理系统发送任务状态信息,也可以向任务管理系统查询需要的任务状态信息。这里以任务管理系统对任务的任务状态进行监控为例,终端设备201为任务责任人所使用的设备,当任务出现异常时,终端设备201接收到服务器205发送的任务异常消息。可以理解,服务器202、服务器203、服务器204的数量均可以为多个,即任务调用系统均可用为多个,图中未示出。
90.另外,本技术实施例对终端设备201的类型不作限定,可以为手机、平板电脑、台式电脑等安装app的电子设备。
91.下面以具体地实施例对本技术的技术方案以及本技术的技术方案如何解决上述技术问题进行详细说明。下面这几个具体的实施例可以独立存在,也可以相互结合,对于相同或相似的概念或过程可能在某些实施例中不再赘述。下面将结合附图,对本技术的实施例进行描述。
92.参考图3,图3为本技术实施例一提供的一种任务状态管理的方法的流程示意图,该方法可以由任务管理系统执行,该方法包括如下步骤。
93.s301、收集各任务调用系统的任务状态信息。
94.该任务状态信息包括:任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态,其中,任务执行状态包括:执行中、执行成功或者执行失败,该参数的值可以用数值1表示执行成功,用数值0表示执行中,用数值2表示执行失败,也可以用表示该任务执行状态的信息,例如“执行中”、“执行成功”或者“执行失败”。任务开始时间和任务结束时间均为一个时间点,例如,为2008-12-13 18:58:23,任务执行时长是根据任务开始时间和任务结束时间计算得到,即为任务开始时间到任务结束时间所间隔的时长,单位为秒。任务类型为执行任务的引擎,即为控制该任务执行的主程序,例如python或者hive。任务归属项目可以为一个企业中各个部门的名称,也可以是部门中各项目组的名称,任务名称可以为了达成某种目的而执行的操作的名称,也可以是该目的的名称,本实施例对比不做限制。
95.任务管理系统通过springboot框架提供应用程序接口api,springboot是一个微服务开发框架,可以使用它快速的搭建起一个系统,即任务管理系统是使用springboot框架进行开发的,springboot框架可以直接以jar包的形式在java环境中独立运行。通过该应用程序接口api使用get方式与各任务调用系统进行数据传输,当然,也可以通过post的方式与各任务调用系统进行数据传输,这两种方式的实现方式可以为上述在介绍api接口调用方式时提到的所有的实现方式,这里不再赘述,以下对任务管理系统与各任务调用系统进行数据传输的方法也不再一一说明。
96.具体收集任务状态信息如下:
97.在各任务调用系统执行任务之前,任务管理系统接收到任务调用系统发送的任务开始状态信息,该任务开始状态信息包括任务类型、任务归属项目、任务名称和任务开始时间。任务管理系统接收到该任务开始状态信息后,向任务调用系统返回任务开始状态信息对应的第一响应消息。
98.在任务调用系统执行该任务完成时,任务管理系统接收到任务调用系统发送的任务结束状态信息,任务结束状态信息包括任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间和任务执行状态。任务管理系统接收到该任务结束信息后,向任务调用系统返回任务结束状态信息对应的第二响应消息。
99.示例性的,上述第一响应消息和第二响应消息均包括接口返回状态码、接口返回错误信息和接口返回结果,当任务调用系统调用接口不成功时,第一响应消息和第二响应消息中的接口返回结果均为空值,接口返回状态码的值均用于指示接口调用不成功,该值可以为表示接口调用不成功的数值,例如500,可选的,该值还可以为接口调用不成功的信息,例如“接口调用失败”等。接口错误信息的值均用于指示接口调用错误原因,该值可以为接口调用错误原因信息,例如发送任务状态信息时少了某个参数,则此时接口返回错误信息为“缺少参数”。
100.当任务调用系统调用接口成功时,即收集任务状态信息成功,第一响应消息中的接口返回状态码的值用于指示接口调用成功,该值可以为指示接口调用成功的信息,例如“接口调用成功”,还可以为指示接口调用成功的数值,例如200,接口错误信息为空值,接口返回结果的值用于指示保存成功,该值可以为指示保存成功的信息,例如,“保存成功”,也可以为指示保存成功的数值,例如300。第二响应消息中的接口返回状态码的值用于指示接口调用成功,该值可以为指示接口调用成功的信息,例如“接口调用成功”,还可以为指示接口调用成功的数值,例如200,接口错误信息为空值,接口返回结果的值用于指示更新成功,该值可以为指示更新成功的信息,例如,“更新成功”,也可以为指示更新成功的数值,例如100。
101.示例性的,任务管理系统收集到任务状态信息后,将该任务状态信息以表格的形式存储于任务管理系统的数据库中,任务状态信息表的属性包括:任务类型、任务归属、任务名称、任务开始时间、任务结束时间、任务执行时长(秒)和任务执行状态(执行中、执行成功、执行失败)。
102.s302、接收目标任务调用系统发送的任务状态查询消息。
103.该任务状态查询消息中包括待查询任务的任务归属项目和任务名称。通常,该待查询任务为目标任务调用系统中的任务存在任务依赖关系的任务,目标任务调用系统是为
了完成任务依赖而进行查询操作。可以理解,即使不存在任务依赖关系,目标任务调用系统也可以根据自己的需求查询该待查询任务的任务状态,该目标调用系统可以为多个任务调用系统中的任意一个任务调用系统。
104.s303、根据任务状态查询消息和收集到的任务状态信息,查询得到待查询任务的任务状态信息。
105.任务管理系统根据任务状态查询信息中的任务归属项目和任务名称,在数据库的任务状态信息表中查询待查询任务的任务状态信息,查询得到待查询任务的任务状态信息。
106.s304、向目标任务调用系统返回任务状态查询消息对应的响应消息。
107.当任务管理系统查询得到该待查询任务的任务状态信息后,任务管理系统会向目标任务调用系统返回任务状态查询消息对应的响应消息,该响应消息中包括待查询任务的任务状态信息,即包括任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态。
108.需要说明的是,当任务执行状态为执行中时,说明任务未执行完成,任务结束时间、任务执行时长均为空值。当任务执行状态为执行失败时,有可能任务未开始执行,也可能任务执行过程中被中断,当任务未开始执行时,任务开始时间、任务结束时间、任务执行时长均为空值,当任务执行过程中被中断,任务开始时间、任务结束时间、任务执行时长均有对应的数值,但是该任务执行状态显示为执行失败。
109.该任务状态查询消息对应的响应消息,用于提示该目标任务调用系统,该查询任务的任务状态,目标任务调用系统可以根据任务状态决定是否执行与本部门中与该待查询任务存在依赖关系的任务,即当待查询任务执行完成,与该任务存在依赖关系的任务就可以开始执行。
110.本实施例中,任务管理系统收集各部门通过各自的任务调用系统发送的任务状态信息,该任务状态信息用于将各部门任务的任务状态集中到任务管理系统中。当目标调用系统有需要查询的任务状态时,任务管理系统会接收到目标调用系统发送的任务状态查询信息,并且根据该任务状态查询信息查询得到的待查询任务的任务状态信息,然后向目标任务调用系统返回响应消息,使得该目标任务调用系统获取到查询的任务的任务状态,当该任务执行完成,与该任务存在依赖关系的任务就可以开始执行,实现了部门之间的任务依赖。
111.为了避免任务在执行过程中出现异常时,该任务的负责人没有及时发现异常,而耽误了与该任务存在依赖关系的任务的执行,浪费了双方的时间,可以在任务管理系统收集各任务调用系统发送的任务状态信息后,任务管理系统可以根据任务调用系统的需求,对任务的状态进行监控,下面通过实施例二对任务状态的监控进行说明。
112.参考图4,图4为本技术实施例二提供的一种对任务状态监控的方法的流程示意图,本实施例在实施例一的基础上,任务管理系统已收集到各任务调用系统发送的任务状态信息,并且以第一任务调用系统需要对待查询任务的任务预警状态信息进行查询为例,该方法可以由任务管理系统执行,该方法包括如下步骤。
113.s401、接收第一任务调用系统发送的任务预警配置信息。
114.该任务预警配置信息包括任务类型、任务归属项目、任务名称、责任人邮箱地址、
任务是否监控和任务预警阈值,可选的,“责任人邮箱地址”参数也可以为“责任人的联系电话”,当为“责任人的联系电话”时,任务管理系统就会以短信的方式向责任人发送消息,任务预警阈值为任务预警阈值为一个时间点,例如2008-8-13 18:58:23。
115.本实施例对于“任务是否监控”的值表示的含义不作限定,当该值为1时,表示需要对该任务进行监控,当该值为0时,表示不需要对该任务进行监控,该值用于任务管理系统确认是否对该任务进行监控,当然,上述1和0也可以替换为true和false,或者使用更多的比特位表示“任务是否监控”的值的含义。
116.当第一任务调用系统需要对本部门的任务进行监控,或者需要对与本部门的任务存在依赖关系的任务进行监控时,任务管理系统会接收到第一任务调用系统发送的任务预警配置信息,任务预警配置信息中的“任务是否监控”参数用于指示任务调用系统对相应的任务进行监控。该第一任务调用系统可以为所有的任务调用系统。
117.示例性的,任务管理系统接收到任务预警配置信息后,将该任务预警配置信息以表格的形式存储于任务管理系统的数据库中,任务预警配置信息表的属性包括:任务类型、任务归属、任务名称、责任人邮箱地址、任务是否监控、任务预警阈值、创建时间和更新时间。
118.s402、向第一任务调用系统返回任务预警配置信息对应的第三响应消息。
119.任务管理系统接收到任务预警配置信息后,任务管理系统向第一任务调用系统返回第三响应消息,该第三响应消息包括接口返回状态码、接口返回错误信息和接口返回结果,当接口调用不成功时,接口返回结果为空值,接口返回状态码用于指示接口调用不成功,接口错误信息用于指示接口调用错误原因。
120.当接口调用成功时,第三响应消息中的接口返回状态码的值用于指示接口调用成功,接口错误信息为空值,接口返回结果的值用于指示保存成功。
121.上述第一响应消息、第二响应消息和第三响应消息的取值的说明可以可以参考实施例一中的步骤s301,这里不再赘述。
122.s403、当任务预警配置参数指示了对任务进行监控时,则对任务的状态进行监控。
123.任务管理系统根据任务预警配置信息中的“任务是否监控”参数,确认是否触发预警机制,即当“任务是否监控”参数的值指示了需要对任务进行监控时,则对任务的状态进行监控,具体实现如下:
124.任务管理系统每隔预设时间对该任务的状态进行检测,例如,每隔10分钟对该任务的状态进行检测,实际上是将该任务的任务状态信息中的任务结束时间,与任务预警阈值进行对比,如果任务结束时间在任务预警阈值之后,说明该任务执行超时了,即该任务没有在预设的时间内执行完成,或者,未检测到任务的状态信息,说明任务并没有执行,则任务管理系统将任务的异常信息发送给责任人邮箱地址对应的邮箱,或者当任务预警配置信息中的“责任人邮箱地址”参数为“责任人联系电话”,则将任务的异常信息以短信的信息发送给对应的号码,负责人在其使用的终端设备上查看该任务的异常信息。该任务的异常信息可以为“任务名称为a的任务,执行超时,请及时处理”,或者“任务名称为b的任务,未正常执行,请及时处理”,也可以为任何一种可以表示任务执行超时或者任务未正常执行的异常的语言描述,本实施例对此不作限定。
125.在另外一种可能的实现方式中,如果任务管理系统还未收集到各任务调用系统发
送的任务状态信息,第一任务调用系统在发送任务预警配置信息时,当前“任务是否监控”参数的值未指示任务管理系统对任务进行监控,目的是为了避免任务管理系统在对任务进行监控时未检测到该任务的任务状态,会发送邮件或者短信给负责人,造成干扰。所以任务管理系统成功收集到各任务调用系统发送的任务状态信息后,第一任务调用系统可以再次调用任务管理系统的接口,修改“任务是否监控”参数的值,指示任务管理系统对任务进行监控。
126.任务在被监控过程中,第一任务调用系统可以向任务管理系统查询该任务的预警状态信息,可以理解,该第一任务调用系统可以为多个任务调用系统中的任意一个任务调用系统。
127.s404、接收第一任务调用系统发送的任务预警状态查询消息。
128.任务管理系统可以接收到第一任务调用系统发送的待查询任务的任务预警状态查询信息,该任务预警状态查询消息包括任务归属项目和任务名称。
129.s405、向第一任务调用系统返回任务预警状态查询消息对应的第四响应消息。
130.第四响应消息包括接口返回状态码、接口返回错误信息和接口返回结果,当接口调用不成功时,接口返回结果为空值,接口返回状态码的值用于指示接口调用不成功,接口错误信息的值用于指示接口调用错误原因。
131.当接口调用成功时,第四响应消息中的接口返回状态码的值用于指示接口调用成功,接口错误信息为空值,接口返回结果包括责任人邮箱地址、任务是否监控和任务预警阈值的值,该第四响应消息用于提示查询该任务预警状态信息的任务调用系统待查询任务的监控情况,如果任务并没有被监控,即“任务是否监控”的值未指示任务管理系统对该任务进行监控,可以根据该责任人邮箱地址自行通知责任人,为了避免任务执行出现异常未能及时发现,通知责任人对该任务进行添加任务监控,也可以从“任务预警阈值”了解该任务正常执行完成的时间。
132.上述第一响应消息、第二响应消息和第三响应消息的取值的说明可以参考实施例一中的步骤s301,这里不再赘述。
133.本实施例中,任务管理系统接收到第一任务调用系统发送的任务预警配置信息,当任务预警配置信息的参数指示了对任务进行监控时,则对该任务的状态进行监控,这样就可以及时得知任务在执行过程中的任务状态,并通知到该任务的负责人,对异常的任务进行处理,使得各部门之间的工作效率得到提升。第一任务调用系统还对待查询任务的任务预警状态信息进行查询,可以获取到该任务的监控情况,获取到与本部门的任务存在任务依赖的任务状态信息,才能使得本部门的任务可以及时执行,实现部门之间的任务依赖。
134.下面是本技术提供的应用于任务调用系统的一种任务状态管理的方法。
135.参考图5,图5为本技术实施例三提供的一种对任务状态管理的方法的流程示意图,该方法可以由任务调用系统执行,该方法包括如下步骤。
136.s501、任务调用系统将任务状态信息发送给任务管理系统。
137.该任务状态信息包括:任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态,任务执行状态包括:执行中、执行成功或者执行失败,该任务状态信息中各个参数的说明可以参考实施例一中的步骤s301,这里不再赘述。
138.任务调用系统通过应用程序接口api与任务管理系统进行数据传输,该api任务管
理系统通过springboot框架提供的api。调用该应用程序接口api可以使用get方式,当然,也可以使用post方式,这两种方式的实现方式可以为上述在介绍api接口调用方式时提到的所有的实现方式,这里不再赘述,以下各任务调用系统向任务管理系统发送信息的方式也不再一一说明。
139.具体发送的任务状态信息如下:
140.在任务调用系统执行任务之前,向任务管理系统发送任务开始状态信息,任务开始状态信息包括任务归属项目、任务名称和任务开始时间。
141.接收任务管理系统返回的任务开始状态信息对应的第一响应消息。
142.在任务调用系统执行任务完成时,向任务管理系统发送任务结束状态信息,任务结束状态信息包括任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间和任务执行状态。
143.接收任务管理系统返回的任务结束状态信息对应的第二响应消息。
144.对于接口调用成功和接口调用不成功时,上述第一响应消息和第二响应消息中的参数的说明可以参考实施例一中的步骤s301,这里不再赘述。
145.s502、任务调用系统将任务状态查询信息发送给任务管理系统。
146.该任务状态查询消息中包括待查询任务的任务归属项目和任务名称。当该任务调用系统需要查询与该任务调用系统中的任务存在任务依赖关系的任务或者需要查询任意一个任务的任务状态时,将任务状态查询信息发送给任务管理系统。
147.s503、接收任务管理系统返回的任务状态查询信息对应的响应消息。
148.当任务管理系统查询得到该待查询任务的任务状态信息后,该任务调用系统接收到任务管理系统返回的任务状态查询消息对应的响应消息,该响应消息中包括待查询任务的任务状态信息,即包括任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态。其中,对任务状态信息中的参数的说明,可以参考是实施例一种的步骤s304,这里不再赘述。
149.可选的,该任务调用系统还可以将任务预警配置信息发送给任务管理系统,该任务预警配置信息中的参数用于指示任务管理系统是否对该任务进行监控,可以理解,该任务调用系统可以为多个任务调用系统中的任意一个任务调用系统。
150.任务预警配置信息包括任务归属项目、任务名称、责任人邮箱地址、任务是否监控和任务预警阈值,在发送该任务预警配置信息的时候,当对“任务是否监控”的值设置为指示任务管理系统对该任务进行监控时,还可以设置“任务预警阈值”的值,该值用于对任务进行监控时,作为任务管理系统是否发出任务异常信息的参照值,具体实现可以参考实施例二中的步骤s403。
151.将任务预警配置信息发送给任务管理系统后,即可接收任务管理系统返回的任务预警配置信息对应的第三响应消息,该第三响应消息包括接口返回状态码、接口返回错误信息和接口返回结果。对于接口调用成功和接口调用不成功时,第三响应消息中的参数的说明可以参考是实施例二种的步骤s402,这里不再赘述。
152.任务管理系统在对任务的状态进行监控时,当任务出现异常时,该责任人邮箱地址对应的邮箱会接收到该任务的异常信息,责任人可以在其使用的终端设备上查看该异常信息。
153.可选的,当任务调用系统需要对待查询任务的任务预警状态信息进行查询时,还可以向任务管理系统发送任务预警状态查询信息,该任务预警状态查询信息包括任务归属项目和任务名称,用于指示任务管理系统对该任务的任务预警状态信息进行查询。
154.该任务调用系统向任务管理系统发送任务预警状态查询信息后,任务管理系统返回第四响应消息,该第四响应消息包括接口返回状态码、接口返回错误信息和接口返回结果,对于接口调用成功和接口调用不成功时,第三响应消息中的参数的说明可以参考是实施例二种的步骤s405,这里不再赘述。
155.本实施例中,任务调用系统向任务管理系统发送任务状态信息,该任务状态信息用于将各个部门的任务的任务状态集中到任务管理系统中,使得该任务调用系统将任务状态查询信息发送给任务管理系统,当任务管理系统根据任务状态信息查询得到该待查询任务的任务状态信息后,向该任务调用系统返回的任务状态查询消息对应的响应消息,使得该任务调用系统获取到该任务的任务状态,当该任务执行完成,与该任务存在依赖关系的任务就可以开始执行,实现了部门之间的任务依赖。
156.参考图6,图6为本技术实施例四提供的一种任务状态管理的方法的信令流程图,本实施例在实施例一至实施例三的基础上,详细描述设备之间的交互过程,本实施例以一个任务调用系统与任务管理系统进行交互,且该任务调用系统对与该任务调用系统中的任务存在依赖关系的任务进行任务预警配置和任务预警查询为例进行说明,如图6所示,本实施例的方法包括如下步骤。
157.s601、任务调用系统记录任务状态信息。
158.任务状态信息均包括任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态,任务执行状态包括:执行中、执行成功或者执行失败。
159.s602、任务调用系统发送任务状态信息给任务管理系统。
160.任务调用系统向任务管理系统发送信息的方法是通过使用get方式或者使用post方式,调用任务管理系统通过springboot框架提供的api接口,以下不再一一说明。
161.该步骤中包括:
162.在任务调用系统执行任务之前,向任务管理系统发送任务开始状态信息,该任务开始状态信息包括任务归属项目、任务名称和任务开始时间。
163.在任务调用系统执行任务完成时,向任务管理系统发送任务结束状态信息,任务结束状态信息包括任务归属项目、任务名称、任务开始时间、任务结束时间和任务执行状态。
164.s603、任务管理系统发送任务状态信息对应的响应消息给任务调用系统a。
165.该步骤中包括:
166.向任务调用系统返回任务开始状态信息对应的第一响应消息。
167.向任务调用系统返回任务结束状态信息对应的第二响应消息。
168.第一响应消息和第二响应消息都包括接口返回状态码、接口返回错误信息和接口返回结果,当接口调用成功时,第一响应消息中的接口返回结果的值用于指示保存成功,第二响应消息中的接口返回结果的值用于指示更新成功。
169.对于接口调用成功和接口调用不成功时,第一响应消息和第二响应消息中的其他
参数的说明可以参考实施例一中的步骤s301,这里不再赘述。
170.s604、任务管理系统收集到各任务调用系统的任务状态信息。
171.s605、任务调用系统记录待查询任务的任务状态查询消息。
172.任务状态查询消息包括待查询任务的任务归属项目和任务名称。
173.s606、任务调用系统向任务管理系统发送待查询任务的任务状态查询消息。
174.s607、根据任务状态查询消息和收集到的任务状态信息,查询得到待查询任务的任务状态信息。
175.s608、任务管理系统向任务调用系统返回任务状态查询消息对应的响应消息。
176.任务状态查询消息的响应消息中包括待查询任务的任务状态信息。
177.s609、任务调用系统记录需要监控的任务的任务预警配置信息。
178.任务预警配置信息包括任务类型、任务归属项目、任务名称、责任人邮箱地址、任务是否监控和任务预警阈值。
179.s610、任务调用系统向任务管理系统发送任务预警配置信息。
180.s611、任务管理系统向任务调用系统返回任务预警配置信息对应的第三响应消息。
181.第三响应消息包括接口返回状态码、接口返回错误信息和接口返回结果。当接口调用成功时,第三响应消息中的接口返回结果的值用于指示保存成功。
182.对于接口调用成功和接口调用不成功时,第三响应消息中的其他参数的说明可以参考是实施例二种的步骤s402,这里不再赘述。
183.s612、任务管理系统每隔预设时间对需要监控的任务的任务状态进行检测。
184.当任务预警配置信息中的参数,即“任务是否监控”的值,指示了对任务进行监控时,任务管理系统每隔预设时间对需要监控的任务的任务状态进行检测。
185.s613、如果任务结束时间在任务预警阈值之后,任务管理系统向终端设备发送任务的异常信息。
186.或者,如果未检测到任务的状态信息,任务管理系统向终端设备发送任务的异常信息。
187.可选的,可以以邮件的形式给责任人邮箱地址对应的邮箱发送异常信息,即任务管理系统向责任人的终端设备发送邮件,当然,如果任务预警配置信息中的“责任人邮箱地址”参数为“责任人的联系电话”,任务管理系统也可以以短信的形式发送给到负责人的终端设备。
188.s614、任务调用系统记录需要查询的任务的任务预警状态查询信息。
189.该任务预警状态查询消息包括任务归属项目和任务名称。
190.s615、任务调用系统向任务管理系统发送任务预警状态查询信息。
191.s616、任务管理系统向任务调用系统返回任务预警状态查询信息对应的第四响应消息。
192.第四响应消息包括接口返回状态码、接口返回错误信息和接口返回结果。当接口调用成功时,第四响应消息中的接口返回结果中包括责任人邮箱地址、任务是否监控和任务预警阈值的值。
193.对于接口调用成功和接口调用不成功时,第四响应消息中的其他参数的说明可以
参考是实施例二种的步骤s405,这里不再赘述
194.本实施例的具体实现方式可参照实施例一至实施例三中相关的步骤,通过收集各任务调用系统的任务状态信息,该任务状态信息用于将各个部门的任务的任务状态集中到任务管理系统中,使得目标任务调用系统将任务状态查询信息发送给任务管理系统,任务管理系统根据任务状态信息进行查询后得到该待查询任务的任务状态信息,然后向目标任务调用系统返回的任务状态查询消息对应的响应消息,使得使用该目标任务调用系统的负责人了解到该任务的任务状态。任务管理系统还接收到第一任务调用系统发送的任务预警配置信息,当任务预警配置信息的参数指示了对任务进行监控时,则对该任务的状态进行监控,这样就可以及时得知任务在执行过程中的任务状态,并通知到该任务的负责人,对异常的任务进行处理,使得各部门之间的工作效率得到提升。第一任务调用系统还对待查询任务的任务预警状态信息进行查询,可以及时了解该任务的监控情况,获取到与本部门的任务存在任务依赖的任务状态信息,使得本部门的任务可以及时执行,实现了部门之间的任务依赖。
195.参考图7,图7为本技术实施例五提供的一种任务管理系统的结构示意图。如图7所示,该任务管理系统70包括:收集模块701,接收模块702,查询模块703和发送模块704。
196.收集模块701:用于收集各任务调用系统的任务状态信息,任务状态信息包括:任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态,任务执行状态包括:执行中、执行成功或者执行失败。
197.接收模块702:用于接收目标任务调用系统发送的任务状态查询消息,任务状态查询消息中包括待查询任务的任务归属项目和任务名称。
198.查询模块703:用于根据任务状态查询消息和收集到的任务状态信息,查询得到待查询任务的任务状态信息。
199.发送模块704:用于向目标任务调用系统返回任务状态查询消息对应的响应消息,任务状态查询消息的响应消息中包括待查询任务的任务状态信息。
200.可选的,收集模块701还用于:
201.在任务调用系统执行任务之前,接收任务调用系统发送的任务开始状态信息,任务开始状态信息包括任务类型、任务归属项目、任务名称和任务开始时间。向任务调用系统返回任务开始状态信息对应的第一响应消息。
202.在任务调用系统执行任务完成时,接收任务调用系统发送的任务结束状态信息,任务结束状态信息包括任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间和任务执行状态。向任务调用系统返回任务结束状态信息对应的第二响应消息。
203.可选的,还包括:
204.接收第一任务调用系统发送的任务预警配置信息,任务预警配置信息包括任务类型、任务归属项目、任务名称、责任人邮箱地址、任务是否监控和任务预警阈值。
205.向第一任务调用系统返回任务预警配置信息对应的第三响应消息。
206.当任务预警配置信息中的参数指示了对任务进行监控时,则对任务的状态进行监控。
207.可选的,还包括:
208.接收第一任务调用系统发送的任务预警状态查询消息,任务预警状态查询消息包
括任务归属项目和任务名称。
209.向第一任务调用系统返回任务预警状态查询消息对应的第四响应消息。
210.可选的,对任务的状态进行监控,包括:每隔预设时间对任务的状态进行检测。
211.对任务的状态进行监控之后,还包括:
212.如果任务结束时间在任务预警阈值之后,或者,如果未检测到任务的状态信息,将任务的异常信息发送给责任人邮箱地址对应的邮箱,其中,任务预警阈值为一个时间点。
213.可选的,任务管理系统通过springboot框架提供应用程序接口api,通过api与各任务调用系统进行数据传输。
214.可选的,第一响应消息和第二响应消息都包括接口返回状态码、接口返回错误信息和接口返回结果,其中,当调用接口不成功时,接口返回结果为空值,接口返回状态码的值用于指示接口调用不成功,接口错误信息的值用于指示接口调用错误原因。
215.当调用接口成功时,第一响应消息中的接口返回状态码的值用于指示接口调用成功,接口错误信息为空值,接口返回结果的值用于指示保存成功。
216.当调用接口成功时,第二响应消息中的接口返回状态码的值用于指示接口调用成功,接口错误信息为空值,接口返回结果的值用于指示更新成功。
217.可选的,第三响应消息包括接口返回状态码、接口返回错误信息和接口返回结果,当接口调用不成功时,接口返回结果为空值,接口返回状态码的值用于指示接口调用不成功,接口错误信息的值用于指示接口调用错误原因。
218.当接口调用成功时,第三响应消息中的接口返回状态码的值用于指示接口调用成功,接口错误信息为空值,接口返回结果的值用于指示保存成功。
219.可选的,第四响应消息包括接口返回状态码、接口返回错误信息和接口返回结果,当接口调用不成功时,接口返回结果的值用于指示接口调用不成功,接口错误信息的值用于指示接口调用错误原因。
220.当接口调用成功时,第四响应消息中的接口返回状态码的值用于指示接口调用成功,接口错误信息为空值,接口返回结果包括责任人邮箱地址、任务是否监控和任务预警阈值的值。
221.本实施例的任务管理系统,可用于执行实施例一或者实施例二的一种任务状态管理的方法步骤,具体实现方式和技术效果类似,这里不再赘述。
222.参考图8,图8为本技术实施例六提供的一种任务调用系统的结构示意图。如图8所示,该任务调用系统80包括:第一发送模块801,第二发送模块802,接收模块803。
223.第一发送模块801:用于任务调用系统将任务状态信息发送给任务管理系统,任务状态信息包括:任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态,任务执行状态包括:执行中、执行成功或者执行失败。
224.第二发送模块802:用于任务调用系统将任务状态查询信息发送给任务管理系统,任务状态查询消息中包括待查询任务的任务归属项目和任务名称。
225.接收模块803:用于接收任务管理系统返回的任务状态查询信息对应的响应消息,任务状态查询消息的响应消息中包括待查询任务的任务状态信息。
226.可选的,第一发送模块801还用于:
227.在任务调用系统执行任务之前,向任务管理系统发送任务开始状态信息,任务开
始状态信息包括任务归属项目、任务名称和任务开始时间。接收任务管理系统返回的任务开始状态信息对应的第一响应消息。
228.在任务调用系统执行任务完成时,向任务管理系统发送任务结束状态信息,任务结束状态信息包括任务归属项目、任务名称、任务开始时间、任务结束时间和任务执行状态。接收任务管理系统返回的任务结束状态信息对应的第二响应消息。
229.可选的,还包括:任务调用系统将任务预警配置信息发送给任务管理系统,任务预警配置信息包括任务归属项目、任务名称、责任人邮箱地址、任务是否监控和任务预警阈值。
230.接收任务管理系统返回的任务预警配置信息对应的第三响应消息。
231.可选的,还包括:任务调用系统将任务预警状态查询信息发送给任务管理系统,任务预警状态查询信息包括任务归属项目和任务名称。
232.接收任务管理系统返回的任务预警状态查询信息对应的第四响应消息。
233.可选的,任务调用系统通过应用程序接口api与任务管理系统进行传输数据,api是任务管理系统通过springboot框架提供的api。
234.本实施例的任务调用系统,可用于执行实施例三的一种任务状态管理的方法步骤,具体实现方式和技术效果类似,这里不再赘述。
235.图9为本发明实施例七提供的一种系统的结构示意图,如图9所示,该系统90包括:处理器901、存储器902,收发器903,存储器902用于存储指令,收发器903用于和其他设备通信,处理器901用于执行存储器中存储的指令,以使系统90执行如实施例一至实施例四任一项的一种任务状态管理的方法步骤,具体实现方式和技术效果类似,这里不再赘述。
236.本发明实施例八提供一种计算机可读存储介质,计算机可读存储介质中存储有计算机执行指令,计算机执行指令被处理器执行时用于实现如上述实施例一至实施例四任一项的一种任务状态管理的方法步骤,具体实现方式和技术效果类似,这里不再赘述。
237.本发明实施例九提供一种计算机程序产品,包括计算机程序,计算机程序被处理器执行时,实现如上述实施例一至实施例四任一项的一种任务状态管理的方法步骤,具体实现方式和技术效果类似,这里不再赘述。
238.本领域技术人员在考虑说明书及实践这里公开的发明后,将容易想到本技术的其它实施方案。本技术旨在涵盖本技术的任何变型、用途或者适应性变化,这些变型、用途或者适应性变化遵循本技术的一般性原理并包括本技术未公开的本技术领域中的公知常识或惯用技术手段。说明书和实施例仅被视为示例性的,本技术的真正范围和精神由下面的权利要求书指出。
239.应当理解的是,本技术并不局限于上面已经描述并在附图中示出的精确结构,并且可以在不脱离其范围进行各种修改和改变。本技术的范围仅由所附的权利要求书来限制。
技术特征:
1.一种任务状态管理的方法,其特征在于,应用于任务管理系统,包括:收集各任务调用系统的任务状态信息,所述任务状态信息包括:任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态,所述任务执行状态包括:执行中、执行成功或者执行失败;接收目标任务调用系统发送的任务状态查询消息,所述任务状态查询消息中包括待查询任务的任务归属项目和任务名称;根据所述任务状态查询消息和收集到的任务状态信息,查询得到所述待查询任务的任务状态信息;向所述目标任务调用系统返回任务状态查询消息对应的响应消息,所述任务状态查询消息的响应消息中包括所述待查询任务的任务状态信息。2.根据权利要求1所述的方法,其特征在于,所述收集各任务调度系统的任务状态信息,包括:在所述任务调用系统执行任务之前,接收所述任务调用系统发送的任务开始状态信息,所述任务开始状态信息包括所述任务类型、所述任务归属项目、所述任务名称和任务开始时间;向所述任务调用系统返回所述任务开始状态信息对应的第一响应消息;在所述任务调用系统执行所述任务完成时,接收所述任务调用系统发送的任务结束状态信息,所述任务结束状态信息包括所述任务类型、所述任务归属项目、所述任务名称、所述任务开始时间、所述任务结束时间和所述任务执行状态;向所述任务调用系统返回所述任务结束状态信息对应的第二响应消息。3.根据权利要求1所述的方法,其特征在于,还包括:接收第一任务调用系统发送的任务预警配置信息,所述任务预警配置信息包括任务类型、任务归属项目、任务名称、责任人邮箱地址、任务是否监控和任务预警阈值;向所述第一任务调用系统返回所述任务预警配置信息对应的第三响应消息;当所述任务预警配置信息中的参数指示了对任务进行监控时,则对所述任务的状态进行监控。4.根据权利要求3所述的方法,其特征在于,还包括:接收所述第一任务调用系统发送的任务预警状态查询消息,所述任务预警状态查询消息包括所述任务归属项目和所述任务名称;向所述第一任务调用系统返回所述任务预警状态查询消息对应的第四响应消息。5.根据权利要求3所述的方法,其特征在于,所述对所述任务的状态进行监控,包括:每隔预设时间对所述任务的状态进行检测;所述对所述任务的状态进行监控之后,还包括:如果所述任务结束时间在所述任务预警阈值之后,或者,如果未检测到所述任务的状态信息,将所述任务的异常信息发送给所述责任人邮箱地址对应的邮箱,其中,所述任务预警阈值为一个时间点。6.根据权利要求1-5任一项所述的方法,其特征在于,所述任务管理系统通过springboot框架提供应用程序接口api,通过所述api与所述各任务调用系统进行数据传输。
7.根据权利要求2所述的方法,其特征在于,所述第一响应消息和所述第二响应消息都包括接口返回状态码、接口返回错误信息和接口返回结果,其中,当调用接口不成功时,所述接口返回结果为空值,所述接口返回状态码的值用于指示接口调用不成功,所述接口错误信息的值用于指示接口调用错误原因;当调用接口成功时,所述第一响应消息中的接口返回状态码的值用于指示接口调用成功,所述接口错误信息为空值,所述接口返回结果的值用于指示保存成功;当调用接口成功时,所述第二响应消息中的接口返回状态码的值用于指示接口调用成功,所述接口错误信息为空值,所述接口返回结果的值用于指示更新成功。8.根据权利要求3所述的方法,其特征在于,所述第三响应消息包括接口返回状态码、接口返回错误信息和接口返回结果,当接口调用不成功时,所述接口返回结果为空值,所述接口返回状态码的值用于指示接口调用不成功,所述接口错误信息的值用于指示接口调用错误原因;当接口调用成功时,所述第三响应消息中的接口返回状态码的值用于指示接口调用成功,所述接口错误信息为空值,所述接口返回结果的值用于指示保存成功。9.根据权利要求4所述的方法,其特征在于,所述第四响应消息包括接口返回状态码、接口返回错误信息和接口返回结果,当接口调用不成功时,所述接口返回结果为空值,所述接口返回状态码的值用于指示接口调用不成功,所述接口错误信息的值用于指示接口调用错误原因;当接口调用成功时,所述第四响应消息中的接口返回状态码的值用于指示接口调用成功,所述接口错误信息为空值,所述接口返回结果包括所述责任人邮箱地址、所述任务是否监控和所述任务预警阈值的值。10.一种任务状态管理的方法,其特征在于,应用于任务调用系统,包括:所述任务调用系统将任务状态信息发送给任务管理系统,所述任务状态信息包括:任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态,所述任务执行状态包括:执行中、执行成功或者执行失败;所述任务调用系统将任务状态查询信息发送给所述任务管理系统,所述任务状态查询消息中包括待查询任务的任务归属项目和任务名称;接收所述任务管理系统返回的所述任务状态查询信息对应的响应消息,所述任务状态查询消息的响应消息中包括所述待查询任务的任务状态信息。11.根据权利要求10所述的方法,其特征在于,所述任务调用系统将任务状态信息发送给任务管理系统,包括:在所述任务调用系统执行任务之前,向所述任务管理系统发送任务开始状态信息,所述任务开始状态信息包括所述任务归属项目、所述任务名称和任务开始时间;接收所述任务管理系统返回的所述任务开始状态信息对应的第一响应消息;在所述任务调用系统执行所述任务完成时,向所述任务管理系统发送任务结束状态信息,所述任务结束状态信息包括所述任务归属项目、所述任务名称、所述任务开始时间、所述任务结束时间和所述任务执行状态;接收所述任务管理系统返回的所述任务结束状态信息对应的第二响应消息。12.根据权利要求10所述的方法,其特征在于,还包括:
所述任务调用系统将任务预警配置信息发送给所述任务管理系统,所述任务预警配置信息包括任务归属项目、任务名称、责任人邮箱地址、任务是否监控和任务预警阈值;接收所述任务管理系统返回的所述任务预警配置信息对应的第三响应消息。13.根据权利要求12所述的方法,其特征在于,还包括:所述任务调用系统将任务预警状态查询信息发送给所述任务管理系统,所述任务预警状态查询信息包括所述任务归属项目和所述任务名称;接收所述任务管理系统返回的所述任务预警状态查询信息对应的第四响应消息。14.根据权利要求10-13任一项所述的方法,其特征在于,所述任务调用系统通过应用程序接口api与所述任务管理系统进行数据传输,所述api是所述任务管理系统通过springboot框架提供的api。15.一种任务管理系统,其特征在于,包括:收集模块:用于收集各任务调用系统的任务状态信息,所述任务状态信息包括:任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态,所述任务执行状态包括:执行中、执行成功或者执行失败;接收模块:用于接收目标任务调用系统发送的任务状态查询消息,所述任务状态查询消息中包括待查询任务的任务归属项目和任务名称;查询模块:用于根据所述任务状态查询消息和收集到的任务状态信息,查询得到所述待查询任务的任务状态信息;发送模块:用于向所述目标任务调用系统返回任务状态查询消息对应的响应消息,所述任务状态查询消息的响应消息中包括所述待查询任务的任务状态信息。16.一种任务调用系统,其特征在于,包括:第一发送模块:用于任务调用系统将任务状态信息发送给任务管理系统,所述任务状态信息包括:任务类型、任务归属项目、任务名称、任务开始时间、任务结束时间、任务执行时长和任务执行状态,所述任务执行状态包括:执行中、执行成功或者执行失败;第二发送模块:用于所述任务调用系统将任务状态查询信息发送给所述任务管理系统,所述任务状态查询消息中包括待查询任务的任务归属项目和任务名称;接收模块:用于接收所述任务管理系统返回的所述任务状态查询信息对应的响应消息,所述任务状态查询消息的响应消息中包括所述待查询任务的任务状态信息。
技术总结
本申请提供一种任务状态管理方法、任务管理系统和任务调用系统,任务管理系统收集各部门通过各自的任务调用系统发送的任务状态信息,该任务状态信息用于将各个部门的任务的任务状态集中到任务管理系统中。当目标调用系统有需要查询的任务状态时,任务管理系统会接收到目标调用系统发送的任务状态查询信息,并且根据该任务状态查询信息查询得到的待查询任务的任务状态信息,然后向目标任务调用系统返回响应消息,使得该目标任务调用系统获取到查询的任务的任务状态,当该任务执行完成,与该任务存在依赖关系的任务就可以开始执行,实现了部门之间的任务依赖。了部门之间的任务依赖。了部门之间的任务依赖。
技术研发人员:丁宪 李卓
受保护的技术使用者:中国建设银行股份有限公司
技术研发日:2021.12.02
技术公布日:2022/3/8