任务处理方法、装置、计算机设备和存储介质与流程

1.本技术涉及大数据技术领域，特别是涉及一种任务处理方法、装置、计算机设备、存储介质和计算机程序产品。


背景技术：

2.随着计算机技术的发展，计算机成为了任务处理的重要工具。随着计算机需要处理的任务量的增多，如何高效地进行任务处理，成为了越来越重要的研究方向。
3.传统技术中，针对金融系统中的任务，通常是直接将任务发送至计算机，由该计算机进行任务的处理；但是，在面对任务众多的情况时，通过该技术进行任务处理时容易出现任务处理失败的情况，导致任务处理的成功率较低。


技术实现要素：

4.基于此，有必要针对上述技术问题，提供一种能够提高任务处理的成功率的任务处理方法、装置、计算机设备、计算机可读存储介质和计算机程序产品。
5.第一方面，本技术提供了一种任务处理方法。所述方法包括：
6.获取金融系统中的任务实例之间的任务依赖信息；
7.根据所述任务实例之间的任务依赖信息，确定出所述任务实例的处理顺序；
8.根据所述任务实例的处理顺序，从所述任务实例中，确定出第一任务实例；
9.将与所述第一任务实例对应的处理指令，发送至对应的任务处理端；所述任务处理端用于根据所述处理指令，对获取到的所述第一任务实例进行处理，并将得到的处理结果反馈至所述终端；
10.在所述处理结果表示处理成功的情况下，根据所述任务实例的处理顺序，从所述任务实例中，确定出第二任务实例，作为第一任务实例，并跳转至所述将与所述第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与所述任务实例对应的处理指令均发送至对应的任务处理端；所述第二任务实例为所述第一任务实例的下一任务实例。
11.在其中一个实施例中，所述获取金融系统中的任务实例之间的任务依赖信息，包括：
12.获取金融系统中的任务实例，以及所述任务实例之间的任务依赖信息；
13.在将与所述第一任务实例对应的处理指令，发送至对应的任务处理端之前，还包括：
14.将所述任务实例存储至任务实例数据库中；所述任务处理端用于从所述任务实例数据库中获取所述任务实例。
15.在其中一个实施例中，所述获取金融系统中的任务实例，以及所述任务实例之间的任务依赖信息，包括：
16.获取金融系统中的待生成任务实例的任务定义信息、任务依赖信息和任务分片信
息；
17.根据所述任务定义信息、所述任务依赖信息和所述任务分片信息，生成任务实例，并确定出所述任务实例之间的任务依赖信息。
18.在其中一个实施例中，所述根据所述任务定义信息、所述任务依赖信息和所述任务分片信息，生成任务实例，并确定出所述任务实例之间的任务依赖信息，包括：
19.根据所述任务定义信息，生成初始任务实例；
20.根据所述任务分片信息，对所述初始任务实例进行分解处理，得到任务实例；
21.根据所述任务依赖信息，确定出所述任务实例之间的任务依赖信息。
22.在其中一个实施例中，在将与所述第一任务实例对应的处理指令，发送至对应的任务处理端之前，还包括：
23.从多个任务处理端中，确定出与当前时间片对应的任务处理端，作为候选任务处理端；
24.在所述候选任务处理端满足预设响应条件的情况下，将所述候选任务处理端识别为与所述处理指令对应的任务处理端。
25.在其中一个实施例中，所述根据所述任务实例之间的任务依赖信息，确定出所述任务实例的处理顺序，包括：
26.根据所述任务实例之间的任务依赖信息，确定出所述任务实例对应的依赖任务实例；
27.将所述任务实例对应的依赖任务实例，识别为所述任务实例的上一任务实例；
28.根据所述任务实例的上一任务实例，对所述任务实例进行排序处理，得到所述任务实例的处理顺序。
29.在其中一个实施例中，在将与所述第一任务实例对应的处理指令，发送至对应的任务处理端之后，还包括：
30.在所述处理结果表示处理失败的情况下，展示所述第一任务实例对应的任务失败信息；
31.响应于针对所述任务失败信息的任务重试指令，将与所述第一任务实例对应的处理指令，发送至另一任务处理端。
32.第二方面，本技术还提供了一种任务处理装置。所述装置包括：
33.信息获取模块，用于获取金融系统中的任务实例之间的任务依赖信息；
34.顺序确定模块，用于根据所述任务实例之间的任务依赖信息，确定出所述任务实例的处理顺序；
35.第一确定模块，用于根据所述任务实例的处理顺序，从所述任务实例中，确定出第一任务实例；
36.指令发送模块，用于将与所述第一任务实例对应的处理指令，发送至对应的任务处理端；所述任务处理端用于根据所述处理指令，对获取到的所述第一任务实例进行处理，并将得到的处理结果反馈至所述终端；
37.第二确定模块，用于在所述处理结果表示处理成功的情况下，根据所述任务实例的处理顺序，从所述任务实例中，确定出第二任务实例，作为第一任务实例，并跳转至所述将与所述第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与所述
任务实例对应的处理指令均发送至对应的任务处理端；所述第二任务实例为所述第一任务实例的下一任务实例。
38.第三方面，本技术还提供了一种计算机设备。所述计算机设备包括存储器和处理器，所述存储器存储有计算机程序，所述处理器执行所述计算机程序时实现以下步骤：
39.获取金融系统中的任务实例之间的任务依赖信息；
40.根据所述任务实例之间的任务依赖信息，确定出所述任务实例的处理顺序；
41.根据所述任务实例的处理顺序，从所述任务实例中，确定出第一任务实例；
42.将与所述第一任务实例对应的处理指令，发送至对应的任务处理端；所述任务处理端用于根据所述处理指令，对获取到的所述第一任务实例进行处理，并将得到的处理结果反馈至所述终端；
43.在所述处理结果表示处理成功的情况下，根据所述任务实例的处理顺序，从所述任务实例中，确定出第二任务实例，作为第一任务实例，并跳转至所述将与所述第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与所述任务实例对应的处理指令均发送至对应的任务处理端；所述第二任务实例为所述第一任务实例的下一任务实例。
44.第四方面，本技术还提供了一种计算机可读存储介质。所述计算机可读存储介质，其上存储有计算机程序，所述计算机程序被处理器执行时实现以下步骤：
45.获取金融系统中的任务实例之间的任务依赖信息；
46.根据所述任务实例之间的任务依赖信息，确定出所述任务实例的处理顺序；
47.根据所述任务实例的处理顺序，从所述任务实例中，确定出第一任务实例；
48.将与所述第一任务实例对应的处理指令，发送至对应的任务处理端；所述任务处理端用于根据所述处理指令，对获取到的所述第一任务实例进行处理，并将得到的处理结果反馈至所述终端；
49.在所述处理结果表示处理成功的情况下，根据所述任务实例的处理顺序，从所述任务实例中，确定出第二任务实例，作为第一任务实例，并跳转至所述将与所述第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与所述任务实例对应的处理指令均发送至对应的任务处理端；所述第二任务实例为所述第一任务实例的下一任务实例。
50.第五方面，本技术还提供了一种计算机程序产品。所述计算机程序产品，包括计算机程序，该计算机程序被处理器执行时实现以下步骤：
51.获取金融系统中的任务实例之间的任务依赖信息；
52.根据所述任务实例之间的任务依赖信息，确定出所述任务实例的处理顺序；
53.根据所述任务实例的处理顺序，从所述任务实例中，确定出第一任务实例；
54.将与所述第一任务实例对应的处理指令，发送至对应的任务处理端；所述任务处理端用于根据所述处理指令，对获取到的所述第一任务实例进行处理，并将得到的处理结果反馈至所述终端；
55.在所述处理结果表示处理成功的情况下，根据所述任务实例的处理顺序，从所述任务实例中，确定出第二任务实例，作为第一任务实例，并跳转至所述将与所述第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与所述任务实例对应的处理
指令均发送至对应的任务处理端；所述第二任务实例为所述第一任务实例的下一任务实例。
56.上述任务处理方法、装置、计算机设备、存储介质和计算机程序产品，获取金融系统中的任务实例之间的任务依赖信息；根据所述任务实例之间的任务依赖信息，确定出所述任务实例的处理顺序；根据所述任务实例的处理顺序，从所述任务实例中，确定出第一任务实例；将与所述第一任务实例对应的处理指令，发送至对应的任务处理端；所述任务处理端用于根据所述处理指令，对获取到的所述第一任务实例进行处理，并将得到的处理结果反馈至所述终端；在所述处理结果表示处理成功的情况下，根据所述任务实例的处理顺序，从所述任务实例中，确定出第二任务实例，作为第一任务实例，并跳转至所述将与所述第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与所述任务实例对应的处理指令均发送至对应的任务处理端；所述第二任务实例为所述第一任务实例的下一任务实例。该方案通过获取金融系统中的任务实例之间的任务依赖信息，从而确定出各任务实例之间的处理依赖关系；根据任务实例之间的任务依赖信息，确定出任务实例的处理顺序，从而确定出各任务实例对应的处理次序；根据任务实例的处理顺序，从任务实例中，确定出第一任务实例，从而确定出处理顺序为第一的任务实例；将与第一任务实例对应的处理指令，发送至对应的任务处理端；任务处理端用于根据处理指令，对获取到的第一任务实例进行处理，并将得到的处理结果反馈至终端，从而使得任务处理端响应于处理指令，将对应的处理结果反馈至终端；在处理结果表示处理成功的情况下，根据任务实例的处理顺序，从任务实例中，确定出第二任务实例，作为第一任务实例，并跳转至将与第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与任务实例对应的处理指令均发送至对应的任务处理端；第二任务实例为第一任务实例的下一任务实例，从而在当前的任务实例成功处理后，继续处理下一任务实例，直到任务实例处理完毕，从而有利于提高任务处理的成功率和效率。
附图说明
57.图1为一个实施例中任务处理方法的流程示意图；
58.图2为一个实施例中确定任务实例和任务依赖信息的步骤的流程示意图；
59.图3为一个实施例中确定任务依赖信息的步骤的流程示意图；
60.图4为一个实施例中确定对应的任务处理端的步骤的流程示意图；
61.图5为一个实施例中任务处理方法的结构示意图；
62.图6为一个实施例中任务处理装置的结构框图；
63.图7为一个实施例中计算机设备的内部结构图。
具体实施方式
64.为了使本技术的目的、技术方案及优点更加清楚明白，以下结合附图及实施例，对本技术进行进一步详细说明。应当理解，此处描述的具体实施例仅仅用以解释本技术，并不用于限定本技术。
65.需要说明的是，本技术所涉及的用户信息(包括但不限于用户设备信息、用户个人信息等)和数据(包括但不限于用于分析的数据、存储的数据、展示的数据等)，均为经用户
授权或者经过各方充分授权的信息和数据，且相关数据的收集、使用和处理需要遵守相关国家和地区的相关法律法规和标准。
66.为了更清晰阐明本技术涉及的技术方案，以下对本技术涉及的术语进行解释：
67.任务实例可以是生成的任务实例(具体的任务)，例如根据任务定义信息生成的任务实例。
68.任务定义信息可以是任务的描述信息，也可以是任务的标识，各任务实例可以对应有不同的任务定义信息(任务定义)。
69.任务实例之间的任务依赖信息可以是任务实例之间的依赖关系(处理依赖关系)，例如需要处理a任务实例之后才能处理b任务实例，则b任务实例依赖于a任务实例，a任务实例是b任务实例的上一任务实例(即b任务实例是a任务实例的下一任务实例，a任务实例的处理顺序在b任务实例的处理顺序的前面，a任务实例的处理优先级高于b任务实例的处理优先级)。
70.任务实例的处理顺序可以是各任务实例的处理的顺序(可以以序列的形式来表示)；第一任务实例可以用于表示任务实例中的未处理任务实例中的排序第一的任务实例；与第一任务实例对应的处理指令可以是用于指示任务处理端处理第一任务实例的指令。
71.任务处理端可以是另一终端或服务器，可以有多个任务处理端，任务处理端的选取可以是通过随机的方式来选取。
72.处理结果可以是任务处理端对第一任务实例进行处理后得到的关于第一任务实例的处理结果。
73.第二任务实例可以是对应的处理顺序排在第一任务实例的处理顺序的后一个的任务实例。
74.任务实例数据库可以是用于存储任务实例的数据库；待生成任务实例可以是未生成的任务实例。
75.待生成任务实例的任务依赖信息可以用于表示待生成任务实例之间的依赖关系(处理依赖关系)。
76.任务分片信息可以用于表示(指示)如何分解(或拆分)任务实例(如初始任务实例)的信息，例如用于表示如何将一个整体任务实例分解成多个任务实例；当前时间片可以表示当前时间或当前时间段。
77.预设响应条件可以是预先设置的触发响应的条件，例如基于心跳机制构建的条件，可以用于检测候选任务处理端是否可用或是否处于连接状态。
78.任务实例对应的依赖任务实例可以用于表示任务实例所依赖的任务实例，例如上述举例的a任务实例和b任务实例，则b任务实例对应的依赖任务实例为a任务实例。
79.第一任务实例对应的任务失败信息可以是用于表示第一任务实例处理失败的信息；任务重试指令可以是用于指示重新对任务实例进行处理的指令。
80.在一个实施例中，如图1所示，提供了一种任务处理方法，本实施例以该方法应用于终端进行举例说明；可以理解的是，该方法也可以应用于服务器，还可以应用于包括终端和服务器的系统，并通过终端和服务器之间的交互实现。其中，终端可以但不限于是各种个人计算机、笔记本电脑、智能手机、平板电脑等；服务器可以用独立的服务器或者是多个服务器组成的服务器集群来实现。本实施例中，该方法包括以下步骤：
81.步骤s101，获取金融系统中的任务实例之间的任务依赖信息。
82.具体的，终端从金融系统中，获取任务实例之间的依赖关系，作为任务实例之间的任务依赖信息。
83.步骤s102，根据任务实例之间的任务依赖信息，确定出任务实例的处理顺序。
84.具体的，终端根据任务实例之间的任务依赖信息，对任务实例进行排序处理，得到任务实例的处理顺序。
85.步骤s103，根据任务实例的处理顺序，从任务实例中，确定出第一任务实例。
86.具体的，终端根据任务实例的处理顺序，从任务实例中，确定出未处理任务实例中的排序第一的任务实例，作为第一任务实例。
87.步骤s104，将与第一任务实例对应的处理指令，发送至对应的任务处理端；任务处理端用于根据处理指令，对获取到的第一任务实例进行处理，并将得到的处理结果反馈至终端。
88.具体的，终端将与第一任务实例对应的处理指令，发送至对应的任务处理端，使得任务处理端响应于处理指令，根据处理指令，对获取到的第一任务实例进行处理，得到处理结果，并将得到的处理结果反馈至终端。
89.步骤s105，在处理结果表示处理成功的情况下，根据任务实例的处理顺序，从任务实例中，确定出第二任务实例，作为第一任务实例，并跳转至将与第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与任务实例对应的处理指令均发送至对应的任务处理端；第二任务实例为第一任务实例的下一任务实例。
90.具体的，终端接收任务处理端发送的处理结果，识别处理结果是否表示处理成功，在处理结果表示处理成功的情况下，根据任务实例的处理顺序，从任务实例中，确定出第二任务实例，将第二任务实例作为第一任务实例，并跳转至将与第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与任务实例对应的处理指令均发送至对应的任务处理端(如任务实例均被处理)。
91.上述任务处理方法中，获取金融系统中的任务实例之间的任务依赖信息；根据任务实例之间的任务依赖信息，确定出任务实例的处理顺序；根据任务实例的处理顺序，从任务实例中，确定出第一任务实例；将与第一任务实例对应的处理指令，发送至对应的任务处理端；任务处理端用于根据处理指令，对获取到的第一任务实例进行处理，并将得到的处理结果反馈至终端；在处理结果表示处理成功的情况下，根据任务实例的处理顺序，从任务实例中，确定出第二任务实例，作为第一任务实例，并跳转至将与第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与任务实例对应的处理指令均发送至对应的任务处理端；第二任务实例为第一任务实例的下一任务实例。该方案通过获取金融系统中的任务实例之间的任务依赖信息，从而确定出各任务实例之间的处理依赖关系；根据任务实例之间的任务依赖信息，确定出任务实例的处理顺序，从而确定出各任务实例对应的处理次序；根据任务实例的处理顺序，从任务实例中，确定出第一任务实例，从而确定出处理顺序为第一的任务实例；将与第一任务实例对应的处理指令，发送至对应的任务处理端；任务处理端用于根据处理指令，对获取到的第一任务实例进行处理，并将得到的处理结果反馈至终端，从而使得任务处理端响应于处理指令，将对应的处理结果反馈至终端；在处理结果表示处理成功的情况下，根据任务实例的处理顺序，从任务实例中，确定出第二任务实
例，作为第一任务实例，并跳转至将与第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与任务实例对应的处理指令均发送至对应的任务处理端；第二任务实例为第一任务实例的下一任务实例，从而在当前的任务实例成功处理后，继续处理下一任务实例，直到任务实例处理完毕，从而有利于提高任务处理的成功率和效率。
92.在一个实施例中，在步骤s101中，获取金融系统中的任务实例之间的任务依赖信息，具体包括如下内容：获取金融系统中的任务实例，以及任务实例之间的任务依赖信息；上述步骤s104，在将与第一任务实例对应的处理指令，发送至对应的任务处理端之前，还包括如下内容：将任务实例存储至任务实例数据库中；任务处理端用于从任务实例数据库中获取任务实例。
93.具体的，终端从金融系统中，获取任务实例，以及获取任务实例之间的任务依赖信息；在将与第一任务实例对应的处理指令，发送至对应的任务处理端之前，将任务实例存储至任务实例数据库中，以使任务处理端在接收到处理指令时，从任务实例数据库中获取第一任务实例。
94.本实施例提供的技术方案，通过获取金融系统中的任务实例，将任务实例存储至任务实例数据库中，使得任务处理端从任务实例数据库中获取对应的任务实例，有利于提高任务处理端获取对应的任务实例的成功率，从而有利于后续提高任务处理的成功率。
95.在一个实施例中，如图2所示，在上述步骤中，获取金融系统中的任务实例，以及任务实例之间的任务依赖信息，具体包括如下内容：
96.步骤s201，获取金融系统中的待生成任务实例的任务定义信息、任务依赖信息和任务分片信息。
97.步骤s202，根据任务定义信息、任务依赖信息和任务分片信息，生成任务实例，并确定出任务实例之间的任务依赖信息。
98.具体的，终端获取金融系统中的待生成任务实例的任务定义信息、任务依赖信息和任务分片信息；根据任务定义信息、任务依赖信息和任务分片信息，生成任务实例，并确定出任务实例之间的任务依赖信息。
99.本实施例提供的技术方案，通过根据任务定义信息、任务依赖信息和任务分片信息，确定出任务实例和任务实例之间的任务依赖信息，有利于得到更准确的任务实例和任务实例之间的任务依赖信息，从而有利于后续提高任务处理的成功率。
100.在一个实施例中，如图3所示，在上述步骤中，根据任务定义信息、任务依赖信息和任务分片信息，生成任务实例，并确定出任务实例之间的任务依赖信息，具体包括如下内容：
101.步骤s301，根据任务定义信息，生成初始任务实例。
102.步骤s302，根据任务分片信息，对初始任务实例进行分解处理，得到任务实例。
103.步骤s303，根据任务依赖信息，确定出任务实例之间的任务依赖信息。
104.具体的，终端根据任务定义信息，生成与任务定义信息对应的任务实例，作为初始任务实例；根据任务分片信息，对初始任务实例进行分解处理(也可以是划分处理)，得到初始任务实例拆分后的多个任务实例；根据任务依赖信息，确定出各任务实例之间的依赖关系，作为任务实例之间的任务依赖信息。
105.本实施例提供的技术方案，通过任务定义信息和任务分片信息，确定任务实例，并
根据任务依赖信息，确定出任务实例之间的任务依赖信息，有利于得到更准确的任务实例和任务实例之间的任务依赖信息，从而有利于后续提高任务处理的成功率。
106.在一个实施例中，如图4所示，上述步骤s104，在将与第一任务实例对应的处理指令，发送至对应的任务处理端之前，还包括如下内容：
107.步骤s401，从多个任务处理端中，确定出与当前时间片对应的任务处理端，作为候选任务处理端。
108.步骤s402，在候选任务处理端满足预设响应条件的情况下，将候选任务处理端识别为与处理指令对应的任务处理端。
109.具体的，终端确定出当前时间片，从多个任务处理端中，确定出与当前时间片对应的任务处理端(例如允许在当前时间片运行或响应的任务处理端)，作为候选任务处理端；判断候选任务处理端是否满足预设响应条件，在候选任务处理端满足预设响应条件的情况下，将候选任务处理端作为与处理指令对应的任务处理端。
110.本实施例提供的技术方案，通过将满足预设响应条件的候选任务处理端识别为对应的任务处理端，有利于准确地确定出对应的任务处理端，从而有利于后续提高任务处理的成功率。
111.在一个实施例中，在步骤s102中，根据任务实例之间的任务依赖信息，确定出任务实例的处理顺序，具体包括如下内容：根据任务实例之间的任务依赖信息，确定出任务实例对应的依赖任务实例；将任务实例对应的依赖任务实例，识别为任务实例的上一任务实例；根据任务实例的上一任务实例，对任务实例进行排序处理，得到任务实例的处理顺序。
112.具体的，终端根据任务实例之间的任务依赖信息，确定出各任务实例对应的依赖任务实例；针对每一任务实例，将任务实例对应的依赖任务实例，作为任务实例的上一任务实例；根据各任务实例的上一任务实例，对所有任务实例进行排序处理，得到任务实例的序列，作为任务实例的处理顺序。
113.本实施例提供的技术方案，通过确定出各任务实例的上一任务实例，根据任务实例的上一任务实例，对任务实例进行排序处理，得到任务实例的处理顺序，有利于得到更准确的任务实例的处理顺序，从而有利于后续提高任务处理的成功率。
114.在一个实施例中，上述步骤s104，在将与第一任务实例对应的处理指令，发送至对应的任务处理端之后，还包括如下内容：在处理结果表示处理失败的情况下，展示第一任务实例对应的任务失败信息；响应于针对任务失败信息的任务重试指令，将与第一任务实例对应的处理指令，发送至另一任务处理端。
115.具体的，终端判断处理结果是否表示处理失败，在识别到处理结果表示处理失败的情况下，展示第一任务实例对应的任务失败信息；接收针对任务失败信息的任务重试指令，响应于针对任务失败信息的任务重试指令，将与第一任务实例对应的处理指令，发送至另一任务处理端(如另一个任务处理端)，以使该另一任务处理端对第一任务实例进行处理。
116.本实施例提供的技术方案，通过在处理结果表示处理失败的情况下，响应于针对任务失败信息的任务重试指令，将与对应的处理指令发送至另一任务处理端，有利于在处理失败时，重新对第一任务实例进行处理，从而有利于提高任务处理的成功率。
117.以下以一个应用实例说明本技术提供的任务处理方法，本应用实例以该方法应用
于终端进行举例说明，如图5所示，主要步骤包括：
118.第一步，终端通过任务定义信息管理模块，获取任务定义、任务依赖、任务分片信息等任务定义类的数据库语言；将任务定义信息存储在应用的数据库；可输出任务定义信息(已存储在数据库中，供任务实例生成装置使用)。
119.其中，终端可以是基于同库模式实现的分布式调度的终端，可包括任务定义、任务调度，任务执行、任务管理控制台(统一管理平台)四个模块(单元)。任务定义模块可负责定义任务的相关信息，如任务定义、任务依赖和任务分片等。任务调度模块可负责生成相应的任务实例，根据任务属性和系统资源状态进行任务调度。任务执行模块可负责将分配给自己的作业任务，完成执行，并反馈执行结果至任务调度模块。统一的任务管理控制平台可负责统一的运维应急、作业监控展示能力。
120.第二步，终端通过任务调度装置，根据任务定义信息生成任务实例，并将任务实例信息写入任务实例数据库，建成每日任务的执行计划，并发现应用执行器装置，通过请求完成任务调度，并上报执行进度及任务执行结果给任务管理控制统一平台。
121.具体的，终端获取任务定义信息(已存储在应用侧数据库中)；根据任务定义信息生成任务实例，并将任务实例信息写入任务实例数据库，上报给任务管理控制统一平台；基于任务定义信息，启动轮询的任务实例分发程序(指令分发)，通过时间片轮转，准备下发调度指令给任务执行装置；通过心跳机制，发现任务执行装置，并通过网络渠道方式，下发调度指令；监听任务依赖信息，一旦依赖的任务实例完成，根据任务依赖关系，触发任务实例的调度；如任务执行失败等，通过暴露调度重试接口，通过任务管理控制统一平台触发应急重试任务；检测任务执行进度及执行结果，一旦任务完成或进度又更新，触发任务管理控制统一平台消息推送机制，将任务执行情况同步；可输出任务实例信息、执行进度及执行结果(已存储在任务实例数据库中，供任务调度装置及推送任务管理控制统一平台使用)。
122.第三步，终端通过任务执行装置，完成任务调度装置的调度指令解析，并完成作业具体任务的执行，并反馈执行结果至任务调度模块。
123.具体的，终端获取任务实例信息，并获取调度指令消息(由任务调度装置下发调度指令)；接收调度指令消息，通过数据库获取任务实例信息，分片信息并启动任务；启动任务后，更新任务执行进度状态至数据库，并基于应用侧的数据开展数据的更新操作执行批量任务；任务执行完成后，回调任务调度装置任务处理结果接口，并将任务执行结果更新至应用侧数据库；可输出任务状态信息(包括任务执行进度状态、任务执行结果等，可存储在任务状态数据库中，供任务调度装置使用)。
124.第四步，终端通过任务管理控制统一平台装置，完成所有应用的任务集中展示及运维操作，具体不限于作业的进度展示，作业的执行结果展示。
125.具体的，终端获取作业定义、实例信息、作业执行结果、作业的执行进度情况；接收作业定义信息上报，保存在平台侧的只读数据库中，展示使用；接收作业实例信息，保存在平台侧的只读数据库中，展示使用；接收作业的执行结果信息，保存在平台侧的只读数据库中，展示使用；若任务失败，响应于页面的重试指令，平台通过调用调度装置的重试接口，完成任务重试；可输出重试任务信息(包含任务的名称、任务的分片号等信息)
126.本应用实例提供的技术方案，将应用的数据和计算，同调度侧的数据放在同一个数据库中，减少了数据传输的开销和网络延迟，提高了调度效率；同时采用基于心跳机制发
现执行器的方式，降低额外引入单独的注册中心发现执行器的方式，提升了调度计算资源的优化和整合，在保证调度效率的前提下，兼容平台级的应急和监控可用性；将调度逻辑下沉到应用侧，以提高在满足运维监控的前提下，降低平台级灾难场景下的调度失败率；具有高效、可靠和可扩展的优点，可以快速处理大量数据，提高任务处理的成功率和效率。
127.应该理解的是，虽然如上所述的各实施例所涉及的流程图中的各个步骤按照箭头的指示依次显示，但是这些步骤并不是必然按照箭头指示的顺序依次执行。除非本文中有明确的说明，这些步骤的执行并没有严格的顺序限制，这些步骤可以以其它的顺序执行。而且，如上所述的各实施例所涉及的流程图中的至少一部分步骤可以包括多个步骤或者多个阶段，这些步骤或者阶段并不必然是在同一时刻执行完成，而是可以在不同的时刻执行，这些步骤或者阶段的执行顺序也不必然是依次进行，而是可以与其它步骤或者其它步骤中的步骤或者阶段的至少一部分轮流或者交替地执行。
128.基于同样的发明构思，本技术实施例还提供了一种用于实现上述所涉及的任务处理方法的任务处理装置。该装置所提供的解决问题的实现方案与上述方法中所记载的实现方案相似，故下面所提供的一个或多个任务处理装置实施例中的具体限定可以参见上文中对于任务处理方法的限定，在此不再赘述。
129.在一个实施例中，如图6所示，提供了一种任务处理装置，该装置600可以包括：
130.信息获取模块601，用于获取金融系统中的任务实例之间的任务依赖信息。
131.顺序确定模块602，用于根据任务实例之间的任务依赖信息，确定出任务实例的处理顺序。
132.第一确定模块603，用于根据任务实例的处理顺序，从任务实例中，确定出第一任务实例。
133.指令发送模块604，用于将与第一任务实例对应的处理指令，发送至对应的任务处理端；任务处理端用于根据处理指令，对获取到的第一任务实例进行处理，并将得到的处理结果反馈至终端。
134.第二确定模块605，用于在处理结果表示处理成功的情况下，根据任务实例的处理顺序，从任务实例中，确定出第二任务实例，作为第一任务实例，并跳转至将与第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与任务实例对应的处理指令均发送至对应的任务处理端；第二任务实例为第一任务实例的下一任务实例。
135.在一个实施例中，信息获取模块601，还用于获取金融系统中的任务实例，以及任务实例之间的任务依赖信息；该装置600还包括：实例存储模块，用于将任务实例存储至任务实例数据库中；任务处理端用于从任务实例数据库中获取任务实例。
136.在一个实施例中，信息获取模块601，还用于获取金融系统中的待生成任务实例的任务定义信息、任务依赖信息和任务分片信息；根据任务定义信息、任务依赖信息和任务分片信息，生成任务实例，并确定出任务实例之间的任务依赖信息。
137.在一个实施例中，信息获取模块601，还用于根据任务定义信息，生成初始任务实例；根据任务分片信息，对初始任务实例进行分解处理，得到任务实例；根据任务依赖信息，确定出任务实例之间的任务依赖信息。
138.在一个实施例中，该装置600还包括：第三确定模块，用于从多个任务处理端中，确定出与当前时间片对应的任务处理端，作为候选任务处理端；在候选任务处理端满足预设
响应条件的情况下，将候选任务处理端识别为与处理指令对应的任务处理端。
139.在一个实施例中，顺序确定模块602，还用于根据任务实例之间的任务依赖信息，确定出任务实例对应的依赖任务实例；将任务实例对应的依赖任务实例，识别为任务实例的上一任务实例；根据任务实例的上一任务实例，对任务实例进行排序处理，得到任务实例的处理顺序。
140.在一个实施例中，该装置600还包括：信息展示模块，用于在处理结果表示处理失败的情况下，展示第一任务实例对应的任务失败信息；响应于针对任务失败信息的任务重试指令，将与第一任务实例对应的处理指令，发送至另一任务处理端。
141.上述任务处理装置中的各个模块可全部或部分通过软件、硬件及其组合来实现。上述各模块可以硬件形式内嵌于或独立于计算机设备中的处理器中，也可以以软件形式存储于计算机设备中的存储器中，以便于处理器调用执行以上各个模块对应的操作。
142.需要说明的是，本技术提供的任务处理的方法和装置可用于金融领域涉及任务处理的应用领域中，也可用于除金融领域之外的任意领域涉及任务处理的处理中，本技术提供的任务处理的方法和装置的应用领域不做限定。
143.在一个实施例中，提供了一种计算机设备，该计算机设备可以是终端，其内部结构图可以如图7所示。该计算机设备包括处理器、存储器、输入/输出接口、通信接口、显示单元和输入装置。其中，处理器、存储器和输入/输出接口通过系统总线连接，通信接口、显示单元和输入装置通过输入/输出接口连接到系统总线。其中，该计算机设备的处理器用于提供计算和控制能力。该计算机设备的存储器包括非易失性存储介质和内存储器。该非易失性存储介质存储有操作系统和计算机程序。该内存储器为非易失性存储介质中的操作系统和计算机程序的运行提供环境。该计算机设备的输入/输出接口用于处理器与外部设备之间交换信息。该计算机设备的通信接口用于与外部的终端进行有线或无线方式的通信，无线方式可通过wifi、移动蜂窝网络、nfc(近场通信)或其他技术实现。该计算机程序被处理器执行时以实现一种任务处理方法。该计算机设备的显示单元用于形成视觉可见的画面，可以是显示屏、投影装置或虚拟现实成像装置。显示屏可以是液晶显示屏或者电子墨水显示屏，该计算机设备的输入装置可以是显示屏上覆盖的触摸层，也可以是计算机设备外壳上设置的按键、轨迹球或触控板，还可以是外接的键盘、触控板或鼠标等。
144.本领域技术人员可以理解，图7中示出的结构，仅仅是与本技术方案相关的部分结构的框图，并不构成对本技术方案所应用于其上的计算机设备的限定，具体的计算机设备可以包括比图中所示更多或更少的部件，或者组合某些部件，或者具有不同的部件布置。
145.在一个实施例中，还提供了一种计算机设备，包括存储器和处理器，存储器中存储有计算机程序，该处理器执行计算机程序时实现上述各方法实施例中的步骤。
146.在一个实施例中，提供了一种计算机可读存储介质，其上存储有计算机程序，该计算机程序被处理器执行时实现上述各方法实施例中的步骤。
147.在一个实施例中，提供了一种计算机程序产品，包括计算机程序，该计算机程序被处理器执行时实现上述各方法实施例中的步骤。
148.本领域普通技术人员可以理解实现上述实施例方法中的全部或部分流程，是可以通过计算机程序来指令相关的硬件来完成，所述的计算机程序可存储于一非易失性计算机可读取存储介质中，该计算机程序在执行时，可包括如上述各方法的实施例的流程。其中，
本技术所提供的各实施例中所使用的对存储器、数据库或其它介质的任何引用，均可包括非易失性和易失性存储器中的至少一种。非易失性存储器可包括只读存储器(read-only memory，rom)、磁带、软盘、闪存、光存储器、高密度嵌入式非易失性存储器、阻变存储器(reram)、磁变存储器(magnetoresistive random access memory，mram)、铁电存储器(ferroelectric random access memory，fram)、相变存储器(phase change memory，pcm)、石墨烯存储器等。易失性存储器可包括随机存取存储器(random access memory，ram)或外部高速缓冲存储器等。作为说明而非局限，ram可以是多种形式，比如静态随机存取存储器(static random access memory，sram)或动态随机存取存储器(dynamic random access memory，dram)等。本技术所提供的各实施例中所涉及的数据库可包括关系型数据库和非关系型数据库中至少一种。非关系型数据库可包括基于区块链的分布式数据库等，不限于此。本技术所提供的各实施例中所涉及的处理器可为通用处理器、中央处理器、图形处理器、数字信号处理器、可编程逻辑器、基于量子计算的数据处理逻辑器等，不限于此。
149.以上实施例的各技术特征可以进行任意的组合，为使描述简洁，未对上述实施例中的各个技术特征所有可能的组合都进行描述，然而，只要这些技术特征的组合不存在矛盾，都应当认为是本说明书记载的范围。
150.以上所述实施例仅表达了本技术的几种实施方式，其描述较为具体和详细，但并不能因此而理解为对本技术专利范围的限制。应当指出的是，对于本领域的普通技术人员来说，在不脱离本技术构思的前提下，还可以做出若干变形和改进，这些都属于本技术的保护范围。因此，本技术的保护范围应以所附权利要求为准。

技术特征：
1.一种任务处理方法，其特征在于，应用于终端，所述方法包括：获取金融系统中的任务实例之间的任务依赖信息；根据所述任务实例之间的任务依赖信息，确定出所述任务实例的处理顺序；根据所述任务实例的处理顺序，从所述任务实例中，确定出第一任务实例；将与所述第一任务实例对应的处理指令，发送至对应的任务处理端；所述任务处理端用于根据所述处理指令，对获取到的所述第一任务实例进行处理，并将得到的处理结果反馈至所述终端；在所述处理结果表示处理成功的情况下，根据所述任务实例的处理顺序，从所述任务实例中，确定出第二任务实例，作为第一任务实例，并跳转至所述将与所述第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与所述任务实例对应的处理指令均发送至对应的任务处理端；所述第二任务实例为所述第一任务实例的下一任务实例。2.根据权利要求1所述的方法，其特征在于，所述获取金融系统中的任务实例之间的任务依赖信息，包括：获取金融系统中的任务实例，以及所述任务实例之间的任务依赖信息；在将与所述第一任务实例对应的处理指令，发送至对应的任务处理端之前，还包括：将所述任务实例存储至任务实例数据库中；所述任务处理端用于从所述任务实例数据库中获取所述任务实例。3.根据权利要求2所述的方法，其特征在于，所述获取金融系统中的任务实例，以及所述任务实例之间的任务依赖信息，包括：获取金融系统中的待生成任务实例的任务定义信息、任务依赖信息和任务分片信息；根据所述任务定义信息、所述任务依赖信息和所述任务分片信息，生成任务实例，并确定出所述任务实例之间的任务依赖信息。4.根据权利要求3所述的方法，其特征在于，所述根据所述任务定义信息、所述任务依赖信息和所述任务分片信息，生成任务实例，并确定出所述任务实例之间的任务依赖信息，包括：根据所述任务定义信息，生成初始任务实例；根据所述任务分片信息，对所述初始任务实例进行分解处理，得到任务实例；根据所述任务依赖信息，确定出所述任务实例之间的任务依赖信息。5.根据权利要求1所述的方法，其特征在于，在将与所述第一任务实例对应的处理指令，发送至对应的任务处理端之前，还包括：从多个任务处理端中，确定出与当前时间片对应的任务处理端，作为候选任务处理端；在所述候选任务处理端满足预设响应条件的情况下，将所述候选任务处理端识别为与所述处理指令对应的任务处理端。6.根据权利要求1所述的方法，其特征在于，所述根据所述任务实例之间的任务依赖信息，确定出所述任务实例的处理顺序，包括：根据所述任务实例之间的任务依赖信息，确定出所述任务实例对应的依赖任务实例；将所述任务实例对应的依赖任务实例，识别为所述任务实例的上一任务实例；根据所述任务实例的上一任务实例，对所述任务实例进行排序处理，得到所述任务实例的处理顺序。
7.根据权利要求1所述的方法，其特征在于，在将与所述第一任务实例对应的处理指令，发送至对应的任务处理端之后，还包括：在所述处理结果表示处理失败的情况下，展示所述第一任务实例对应的任务失败信息；响应于针对所述任务失败信息的任务重试指令，将与所述第一任务实例对应的处理指令，发送至另一任务处理端。8.一种任务处理装置，其特征在于，所述装置包括：信息获取模块，用于获取金融系统中的任务实例之间的任务依赖信息；顺序确定模块，用于根据所述任务实例之间的任务依赖信息，确定出所述任务实例的处理顺序；第一确定模块，用于根据所述任务实例的处理顺序，从所述任务实例中，确定出第一任务实例；指令发送模块，用于将与所述第一任务实例对应的处理指令，发送至对应的任务处理端；所述任务处理端用于根据所述处理指令，对获取到的所述第一任务实例进行处理，并将得到的处理结果反馈至所述终端；第二确定模块，用于在所述处理结果表示处理成功的情况下，根据所述任务实例的处理顺序，从所述任务实例中，确定出第二任务实例，作为第一任务实例，并跳转至所述将与所述第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与所述任务实例对应的处理指令均发送至对应的任务处理端；所述第二任务实例为所述第一任务实例的下一任务实例。9.一种计算机设备，包括存储器和处理器，所述存储器存储有计算机程序，其特征在于，所述处理器执行所述计算机程序时实现权利要求1至7中任一项所述的方法的步骤。10.一种计算机可读存储介质，其上存储有计算机程序，其特征在于，所述计算机程序被处理器执行时实现权利要求1至7中任一项所述的方法的步骤。11.一种计算机程序产品，包括计算机程序，其特征在于，该计算机程序被处理器执行时实现权利要求1至7中任一项所述的方法的步骤。

技术总结
本申请涉及大数据技术领域，提供了一种任务处理方法、装置、计算机设备、存储介质和计算机程序产品，可具体应用于金融领域或其他相关领域。本申请能够实现提高任务处理的成功率和效率。该方法包括：获取金融系统中的任务实例之间的任务依赖信息；根据任务依赖信息，确定出任务实例的处理顺序；根据处理顺序，从任务实例中，确定出第一任务实例；将与第一任务实例对应的处理指令，发送至对应的任务处理端；在处理结果表示处理成功的情况下，根据处理顺序，从任务实例中确定出第二任务实例，作为第一任务实例，并跳转至将与第一任务实例对应的处理指令，发送至对应的任务处理端的步骤，直到将与任务实例对应的处理指令均发送至对应的任务处理端。的任务处理端。的任务处理端。


技术研发人员：徐克宝 郭一凡 张素洁 高雁翔
受保护的技术使用者：中国工商银行股份有限公司
技术研发日：2023.06.12
技术公布日：2023/9/20