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

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.第三获取模块，用于获取所述中断作业的优先级；
58.添加模块，用于将所述中断作业按照所述优先级加入至待处理队列中，所述待处理队列中各作业按照优先级由高至低的顺序排列；
59.第二遍历模块，用于按序遍历所述待处理队列中的作业，对所述待处理队列中的各所述作业进行依次处理。
60.在其中一个实施例中，所述第三获取模块，还用于：
61.在所述目标作业节点对应的特征属性中存在优先级属性的情况下，根据所述优先级属性获取所述中断作业的优先级；或者，
62.在所述目标作业节点对应的特征属性中不存在优先级属性的情况下，根据所述中断作业属于的应用类型、及所述中断作业对系统日结算的影响类型，确定所述中断作业的优先级，并将所述优先级添加为所述目标作业节点的所述优先级属性。
63.在其中一个实施例中，所述第二确定模块，还用于：
64.对所述中断作业进行重提处理；
65.在重提处理成功的情况下，停止进行基于所述中断作业对第一解决方案进行遍历的步骤；或者，
66.在重提处理失败的情况下，基于所述中断作业，对除重提处理外的各所述第一解决方案进行遍历。
67.在其中一个实施例中，所述装置还包括：
68.生成模块，用于在各所述第三解决方案均无法解决所述中断作业的情况下，根据所述中断作业、所述中断日志、各所述第一解决方案及各所述第三解决方案，生成所述中断作业对应的错误报告。
69.第三方面，本技术还提供了一种计算机设备。所述计算机设备包括存储器和处理器，所述存储器存储有计算机程序，所述处理器执行所述计算机程序时实现以上任一项方法。
70.第四方面，本技术还提供了一种计算机可读存储介质。所述计算机可读存储介质，其上存储有计算机程序，所述计算机程序被处理器执行时实现以上任一项方法。
71.第五方面，本技术还提供了一种计算机程序产品。所述计算机程序产品，包括计算机程序，该计算机程序被处理器执行时实现以上任一项方法。
72.上述作业处理方法、装置、计算机设备和存储介质，在获取中断作业对应的错误信息后，通过作业知识图谱查找中断作业的解决方案，并在作业知识图谱中不存在第一目标连接关系(也即作业知识图谱中未记录中断作业在产生错误信息时的解决方案)的情况下，从作业知识图谱中另行确定至少一个第一解决方案，并通过遍历各第一解决方案解决中断作业。由于本技术实施例建立作业知识图谱，并在其中记录各作业的解决方案，故而在作业中断时可以通过作业知识图谱查询到作业的解决方案，并对作业进行自动处理，故而可以提升作业处理的效率。
附图说明
73.图1为一个实施例中作业处理方法的流程示意图；
74.图2为一个实施例中构建第二目标连接关系的示意图；
75.图3为一个实施例中步骤106的流程示意图；
76.图4为一个实施例中步骤302的流程示意图；
77.图5为一个实施例中作业处理方法的流程示意图；
78.图6为一个实施例中作业处理方法的流程示意图；
79.图7为一个实施例中确定优先级的示意图；
80.图8为一个实施例中步骤106的流程示意图；
81.图9为一个实施例中基于中断作业对第一解决方案进行遍历的示意图；
82.图10为一个实施例中作业处理装置的结构框图；
83.图11为一个实施例中计算机设备的内部结构图。
具体实施方式
84.为了使本技术的目的、技术方案及优点更加清楚明白，以下结合附图及实施例，对本技术进行进一步详细说明。应当理解，此处描述的具体实施例仅仅用以解释本技术，并不用于限定本技术。
85.在一个实施例中，如图1所示，提供了一种作业处理方法，本实施例以该方法应用于服务器进行举例说明，可以理解的是，该方法也可以应用于终端，还可以应用于包括终端和服务器的系统，并通过终端和服务器的交互实现。本实施例中，该方法包括以下步骤：
86.步骤102，在检测到中断作业时，获取中断作业的中断日志，并从中断日志中获取中断作业对应的错误信息。
87.本技术实施例中，作业在分布式平台上运行，每个作业依赖于不同的容器，且在数据库中均有记录。针对每个容器，可以通过设置实时采集、断点监控和数据库实时扫面的方式，在检测到作业中断时自动调用容器的日志接口，抓取作业中断时间点时的中断日志。中断日志中记录有中断作业的中断时间，以及中断作业中断时报出的错误信息。错误信息可以为错误代码，也可以为对错误的文字描述等，其具体取决于作业日志的生成方式，本技术实施例对此不作具体限定。
88.步骤104，确定中断作业在作业知识图谱中对应的目标作业节点，并确定错误信息在所述目标作业节点的连接关系中对应的第一目标连接关系。
89.本技术实施例中，作业知识图谱为在进行作业处理之前，预先根据各作业的信息构建的知识图谱。作业知识图谱中可以包括至少一个作业节点，以及与各作业节点连接的至少一个方案节点。方案节点和作业节点之间通过基于错误信息生成的连接关系进行连接，每一个作业节点分别表征一个作业，每一个方案节点分别表征在作业产生如方案节点对应的连接关系所表征的错误信息时，可以解决作业中断问题的一个方案(例如，重提作业、清理hbase、制造上游空文件等等)。作业和作业节点之间的对应关系，以及方案和方案节点之间的对应关系可以预先记录在数据库中。或者，也可以通过在作业节点/方案节点中记录作业/方案的唯一标识码、唯一名称标识等方式来建立作业节点/方案节点和作业/方案之间的对应关系，本技术实施例对此不作具体限定。
90.目标作业节点即根据中断作业的信息构建出的作业节点。在每个作业开始运行之前，可以在作业知识图谱中检测是否有该作业对应的作业节点，若作业节点不存在，则可以构建作业对应的作业节点，以使得每个正在运行的作业在作业知识图谱中都能有对应的作业节点。作业节点中还可以包括作业的定义、作业的依赖及作业实例等信息，可以将作业知识图谱和sql(structured query language，结构化查询语言)数据库中的作业定义表、作业依赖表和作业实例表进行关联，以使得在创建作业节点时，作业知识图谱可以自动根据作业的名称，从sql数据库中抓取上述信息。此外，作业节点中还可以包括测试环境信息、开发环境信息、应用支持负责人员对接信息、历史版本改造信息等；在将作业知识图谱以可视
化技术进行展现时，可以同时展示作业名、所属应用、作业状态、作业优先级、测试负责人、开发人员、业务功能大类、业务功能小类、功能详情、作业清单、测试详情等，以使得作业知识图谱能够向运维人员展示更为详尽的信息。
91.在检测到中断作业时，可以从作业知识图谱中查询和中断作业对应的目标作业节点。具体查询方式取决于作业和作业节点之间对应关系的记录方式。例如，若作业和作业节点之间的对应关系存储于数据库中，则可以通过查询数据库获取和中断作业对应的目标作业节点；若作业节点中记录有作业的唯一标识码，则可以通过中断作业的唯一标识码遍历各作业节点，以获取唯一标识码和中断作业的唯一标识码对应的目标作业节点。
92.同时，还可以根据错误信息，确定在目标作业节点的各连接关系中，是否存在错误信息对应的第一目标连接关系，也即确定作业知识图谱中是否记录有在产生该错误信息时，可以解决中断作业的方案。在存在第一目标连接关系的情况下，可以获取通过第一目标连接关系和目标作业节点连接的方案节点，进而获取该方案节点所表征的解决方案，并通过该解决方案对中断作业进行处理。
93.步骤106，在不存在第一目标连接关系的情况下，从作业知识图谱中确定至少一个第一解决方案，并基于中断作业对各第一解决方案进行遍历，直至中断作业得到解决为止。
94.本技术实施例中，在不存在第一目标连接关系时，可以通过作业知识图谱中的其他作业节点，查询可以解决中断作业的第一解决方案。由于各作业都可能出现相同的错误信息，而在错误信息相同的情况下，能够解决某一作业的解决方案可能也适用于其他的作业，故而可以将其他作业节点的方案节点对应的解决方案作为第一解决方案，并基于中断作业对各第一解决方案进行遍历，以尝试通过各第一解决方案解决中断作业。
95.可以遍历作业知识图谱中的各作业节点，并查询各作业节点的连接关系中是否存在和中断作业的错误信息对应的连接关系。若存在，则可以获取该连接关系对应的方案节点所表征的解决方案，并将该解决方案作为第一解决方案；若不存在，则继续对下一个作业节点的连接关系进行查询。通过上述方式，可以从作业知识图谱中获取各作业在出现中断作业的错误信息时，曾经解决过各作业的解决方案，并将这些解决方案作为第一解决方案。
96.在基于中断作业对各第一解决方案进行遍历时，为提高解决中断作业的效率，可以对各第一解决方案进行排序，以使得中断作业按序对各第一解决方案进行遍历。例如，可以确定各第一解决方案对应的方案节点的连接关系数量，并按照连接关系数量由大至小对各第一解决方案进行排序，以使得解决过最多作业的解决方案能排列的靠前。或者，也可以按照各第一解决方案的耗时由短至长对各第一解决方案进行排序，以使得耗时最短的解决方案能排列的靠前。本技术实施例对此不作具体限定。
97.若在遍历过所有的第一解决方案后，中断作业仍未得到解决，则可以根据中断日志生成错误报告，并将错误报告发送给运维人员，以呼叫运维人员对中断作业进行人工处理。
98.本技术实施例提供的作业处理方法，在获取中断作业对应的错误信息后，通过作业知识图谱查找中断作业的解决方案，并在作业知识图谱中不存在第一目标连接关系(也即作业知识图谱中未记录中断作业在产生错误信息时的解决方案)的情况下，从作业知识图谱中另行确定至少一个第一解决方案，并通过遍历各第一解决方案解决中断作业。由于本技术实施例建立作业知识图谱，并在其中记录各作业的解决方案，故而在作业中断时可
以通过作业知识图谱查询到作业的解决方案，并对作业进行自动处理，故而可以提升作业处理的效率。
99.在一个实施例中，上述方法还包括：
100.在存在第一目标连接关系的情况下，根据第一目标连接关系对应的方案节点，确定错误信息对应的第二解决方案，并通过第二解决方案对中断作业进行处理。
101.本技术实施例中，若存在第一目标连接关系，则说明作业知识图谱中记录有中断作业之前产生该错误信息时，解决过中断作业的解决方案。可以获取与第一目标连接关系对应的方案节点，并查询方案节点对应的解决方案(具体查询解决方案的方式可参照通过中断作业查询目标作业节点的方式，本技术实施例在此不再赘述)。在获得解决方案后，可以通过解决方案对中断作业进行处理。
102.本技术实施例提供的作业处理方法，在存在第一目标连接关系的情况下，通过第一目标连接关系对应的方案节点获取中断作业的解决方案。由于第一目标连接关系对应的方案节点所表征的解决方案，即是在中断作业之前出现第一目标连接关系所表征的错误信息时解决过中断作业的方案，故而通过该解决方案对中断作业进行处理即可以快速解决中断作业，进而提升处理中断作业的效率。
103.在一个实施例中，在不存在第一目标连接关系的情况下，上述方法还包括：
104.将解决中断作业的第一解决方案对应的方案节点作为目标方案节点，并根据目标方案节点、目标作业节点及错误信息，构建第二目标连接关系。
105.本技术实施例中，在第一解决方案成功解决中断作业的情况下，可以将第一解决方案、错误信息及中断作业之间的对应关系记录在作业知识图谱中，以使得在中断作业再次出现如错误信息所代表的问题时，可以直接从知识图谱中查询到错误信息对应的解决方案，而无需重复进行基于中断作业对第一解决方案进行遍历的流程。
106.参照图2所示，为上述过程的一个示例。假设中断作业对应的目标作业节点为作业b节点，错误信息为错误b，解决中断作业的第一解决方案为方案b节点，则可以根据错误信息，在方案b节点和作业b节点之间构建出如图中虚线所示的连接关系。也即，在作业知识图谱中，每个作业节点可以和多个方案节点连接，每个连接的方案节点代表在作业节点所表征的作业出现不同的错误信息时，能够解决作业中断问题的一个方案；同时，每个方案节点也可以和多个作业节点连接，每个连接的作业节点代表方案节点所表征的方案可以解决的一个作业。
107.本技术实施例提供的作业处理方法，在第一解决方案成功解决中断作业的情况下，将第一解决方案对应的目标方案节点和目标作业节点通过第二目标连接关系进行连接，以使得在中断作业下一次出现同样的错误信息时，可以快速根据第二目标连接关系查询到中断作业对应的解决方案，并根据解决方案对中断作业进行处理，提升处理中断作业的效率。
108.在一个实施例中，如图3所示，步骤106中，确定至少一个第一解决方案，包括：
109.步骤302，对作业知识图谱中的各作业节点进行聚类处理，并将与目标作业节点属于同一类别的作业节点作为第一候选作业节点。
110.步骤304，确定错误信息在各第一候选作业节点的连接关系中对应的第三目标连接关系。
111.步骤306，在存在第三目标连接关系的情况下，通过第三目标连接关系对应的方案节点获取第一解决方案。
112.本技术实施例中，在确定第一解决方案时，可以首先对作业知识图谱中的各作业节点进行聚类，并将和目标作业节点属于同一个类别(也即处于同一个聚类簇)的作业节点作为第一候选作业节点，以从和目标作业节点较为相近的作业节点中查询第一解决方案。本技术实施例对于对各作业节点进行聚类的方式不作具体限定，任一聚类方法均适用于本技术实施例中。进行聚类的标准可以由中断作业的特征属性决定，中断作业的特征属性可以包括但不限于中断作业的中断时间、中断作业所属的应用、中断作业的作业类型、错误信息的关联性等。
113.在进行聚类之前，可以首先获取中断作业的特征属性，并在特征属性满足预设条件时，根据预设条件对应的聚类标准对各作业节点进行聚类。预设条件可以由本领域技术人员根据测试环境中作业发生中断的具体情况进行确定，本技术实施例对此不作具体限定。例如，预设条件可以为作业在某一时段发生中断、作业属于某一特定应用、作业属于某一特定作业类型等。
114.举例来说，若在某个时间点附近作业产生中断的情况较多，而中断作业又恰好在该时间点附近发生中断(也即中断作业的特征属性满足在特定时段发生中断的这一预设条件)，则可以根据中断时间对各作业节点进行聚类，将历史上在该时段中发生中断的全部作业对应的作业节点作为第一候选作业节点，并查询各第一候选作业节点的连接关系中，是否存在错误信息对应的第三目标连接关系，也即各第一候选作业节点对应的作业在历史上是否出现过相同的错误信息；若存在第三目标连接关系，则可以将第三目标连接关系对应的方案节点所表征的解决方案，作为第一解决方案。通过上述过程，在确定第一解决方案时仅考虑和目标作业节点较为相似的作业节点，可以缩小第一解决方案的范围，加快作业处理的效率。
115.若中断作业的特征属性不满足任一预设条件，此时可以根据通用标准(例如所属应用，具体可以由本领域技术人员自行设定)对各作业节点进行聚类，或者，也可以不对各作业节点进行聚类，而是直接从全部作业节点中查询第一解决方案，本技术实施例对此不作具体限定。
116.本技术实施例提供的作业处理方法，在确定第一解决方案时，首先对各作业节点进行聚类处理，以从和目标作业节点较为相似的作业节点中确定第一解决方案，可以缩小第一解决方案的范围，加快作业处理的效率。
117.在一个实施例中，如图4所示，步骤302中，对作业知识图谱中的各作业节点进行聚类处理，包括：
118.步骤402，从目标作业节点对应的各特征属性中确定至少一个目标特征属性。
119.步骤404，基于各目标特征属性，对知识图谱中的各作业节点进行聚类处理。
120.本技术实施例中，作业节点的特征属性可以记录在作业知识图谱中，其可以以节点属性的方式进行记录，也可以作为单独的节点进行记录。在作为单独的节点进行记录时，每一个特征属性在作业知识图谱中都拥有对应的属性节点，各属性节点和作业节点之间通过相应的连接关系进行连接。例如记录具体中断时间的属性节点可以和作业节点之间通过“中断时间”的连接关系进行连接。
121.可以从目标作业节点的各特征属性中，选取至少一个目标特征属性，并根据各目标特征属性对作业节点进行聚类处理。举例来说，可以遍历目标作业节点的各特征属性，并在特征属性满足该特征属性类别对应的预设条件时，将特征属性作为目标特征属性。本技术实施例对于根据各目标特征值属性对作业节点进行聚类处理的方式不作具体限定，任一聚类方法均适用于本技术实施例中。
122.本技术实施例提供的作业处理方法，在确定第一解决方案时，选取目标特征属性，并基于目标特征属性对各作业节点进行聚类处理，以从和目标作业节点较为相似的作业节点中确定第一解决方案，可以缩小第一解决方案的范围，加快作业处理的效率。
123.在一个实施例中，如图5所示，上述方法还包括：
124.步骤502，在各第一解决方案均无法解决中断作业的情况下，确定错误信息，在各第二候选作业节点的连接关系中对应的第四目标连接关系，第二候选作业节点为全部作业节点中，除第一候选作业节点外的作业节点。
125.步骤504，在存在第四目标连接关系的情况下，通过第四目标连接关系对应的方案节点获取第三解决方案。
126.步骤506，基于中断作业对各第三解决方案进行遍历，直至中断作业得到解决为止。
127.本技术实施例中，在第一解决方案无法解决中断作业的情况下，可以扩大解决方案的搜索范围，也即从和目标作业节点不属于同一类别的作业节点(第二候选作业节点)中确定第三解决方案，并基于中断作业对各第三解决方案进行遍历。
128.在确定第三解决方案时，可以基于错误信息对各第二候选节点进行遍历，并确定各第二候选节点对应的连接关系中，是否存在和错误信息对应的第四目标连接关系。若存在，则可以通过和第四目标连接关系对应的方案节点获取第三解决方案。在确定全部第三解决方案后，可以通过中断作业遍历各第三解决方案，也即尝试通过各第三解决方案解决中断作业，直至中断作业得到解决为止。其中，获取第三解决方案以及对第三解决方案进行遍历的过程，可以参照前述实施例中获取第一解决方案以及对第一解决方案进行遍历的过程，本技术实施例在此不再赘述。
129.本技术实施例提供的作业处理方法，在第一解决方案无法解决中断作业时，从除第一候选作业节点外的作业节点中查找第三解决方案，并基于中断作业对第三解决方案进行遍历，以此在第一解决方案无法解决中断作业时，扩大解决方案的搜索范围。优先从与目标作业节点相近的作业节点中查找解决方案，并在查找不到时再从其他作业节点中查找解决方案，可以提高解决方案的查找效率，进而提高中断作业的解决效率。
130.在一个实施例中，如图6所示，步骤102中，在检测到中断作业后，上述方法还包括：
131.步骤602，获取中断作业的优先级。
132.步骤604，将中断作业按照优先级加入至待处理队列中，待处理队列中各作业按照优先级由高至低的顺序排列。
133.步骤606，按序遍历待处理队列，对待处理队列中的各作业进行依次处理。
134.本技术实施例中，由于同时可能有多个作业发生中断，而某些作业中断对测试环境的影响比其他作业要大，故而可以为作业设置优先级，以使得在作业发生中断成为中断作业时，可以按照中断作业的优先级按序处理各中断作业。其中，优先级可以由本领域技术
人员预先设定并存储于数据库或作业知识图谱中，在作业中断时，可以从数据库或作业知识图谱中获取中断作业的优先级；或者，也可以设定优先级的计算规则，并在作业中断时，基于计算规则对作业的优先级进行计算，本技术实施例对此不作具体限定。
135.确定中断作业的优先级后，可以将中断作业按照优先级加入待处理队列中。待处理队列中的作业按照优先级由高至低的顺序排列，以使得通过按序遍历待处理队列，即可以按照优先级由高至低的顺序对各发生中断的作业进行处理。在将中断作业加入待处理队列中时，可以比较中断作业的优先级和待处理队列中各作业的优先级，并将中断作业插入至较其优先级更低的第一个作业的前一位。例如，若优先级分为1、2、3、4四个级别，其中1级优先级最高，4级优先级最低，中断作业的优先级为2，则可以按序检测待处理队列中各作业的优先级，在检测到作业的优先级比中断作业的优先级更高或相等时(也即作业的优先级为1或2时)，继续检测下一个作业；在检测到第一个优先级比中断作业的优先级低的作业时(也即检测到第一个优先级为3的作业时)，将中断作业插入至该作业之前，以此将中断作业加入至待处理队列中。
136.本技术实施例提供的作业处理方法，通过设置待处理队列，使得各需要被处理的作业在待处理队列中按照优先级由高至低的顺序排列，并通过按序遍历待处理队列的方式对各作业进行处理，可以使得优先级较高的作业得到优先处理，以此降低作业中断对测试环境带来的影响，并且提高优先级较高的作业的稳定性。
137.在一个实施例中，步骤602中，获取中断作业的优先级，包括：
138.在目标作业节点对应的特征属性中存在优先级属性的情况下，根据优先级属性获取中断作业的优先级；或者，
139.在目标作业节点对应的特征属性中不存在优先级属性的情况下，根据中断作业属于的应用类型、及中断作业对系统日结算的影响类型，确定中断作业的优先级，并将优先级添加为目标作业节点的优先级属性。
140.本技术实施例中，目标作业节点的特征属性中可以包括优先级属性，优先级属性用于表征中断作业的优先级。在获取中断作业的优先级时，可以首先查询作业知识图谱中是否存在中断作业的优先级属性，若存在则可以根据优先级属性中获取优先级。优先级属性在知识图谱中的记录方式可参见前述实施例中的相关描述，本技术实施例在此不再赘述。
141.在作业知识图谱中不存在中断作业的优先级属性时，可以根据中断作业属于的应用类型，以及中断作业对系统日结算的影响类型确定中断作业的优先级。在应用的作业数量越多时，作业中断对于测试的影响越大，故而中断作业的优先级应当和中断作业所属应用对应的作业数量成正比。部分作业可能会影响系统的日结算(也即日切)，若这部分作业发生中断则可能使得系统无法完成日结算，故而影响日结算的作业的优先级应当比不影响日结算的作业的优先级更高。在根据上述两个因素确定中断作业的优先级时，可以首先考虑中断作业属于的应用类型，其次考虑中断作业对系统日结算的影响类型。也即，作业所属应用对应的作业数量越多，作业的优先级越高；在两个作业同属于一个应用时，影响日结算的作业的优先级比不影响日结算的作业的优先级高。
142.此外，也可以根据其他因素确定中断作业的优先级。例如作业是否涉及账务类(账务类作业的优先级比非账务类作业的优先级高)，或者作业是否为零场次作业(零场次作业
的优先级比非零场次作业的优先级高)等，其具体可由本领域技术人员根据实际需求确定，本技术实施例对此不作具体限定。
143.参见图7所示，为一个示例性的优先级确定规则。可以根据中断作业，从sql数据库中获取中断作业的所属应用类型，进而根据应用的作业数量，确定中断作业的第一优先级分值；再根据中断作业是否涉及账务类，确定中断作业的第二优先级分值；再根据中断作业是否影响日切，确定中断作业的第三优先级分值；再根据中断作业是否为零场次作业，确定中断作业的第四优先级分值。进而可以将各优先级分值加权求和，以得到中断作业的优先级。各优先级分值的权重应当满足下一级优先级分值的取值不会影响根据上一级优先级分值确定的初步排序(在本示例中，各优先级分值按照级别由高至低的排序为第一优先级分值、第二优先级分值、第三优先级分值和第四优先级分值)，也即，若a作业的第一优先级分值比b作业的第一优先级分值低，则即便a作业的第二优先级分值比b作业的第二优先级分值高，a作业的优先级也仍然应当低于b作业的优先级。一个示例性的优先级计算规则可以参照公式(一)所示：
144.p＝1000
×
p1+100
×
p2+10
×
p3+4公式(一)
145.其中，p为优先级，p1为第一优先级分值，p2为第二优先级分值，p3为第三优先级分值，p4为第四优先级分值，第一优先级分值、第二优先级分值、第三优先级分值和第四优先级分值的取值应当在0至9之间。
146.在确定中断作业的优先级后，还可以将中断作业的优先级添加为目标作业节点的优先级属性，以使得再次需要获取中断作业的优先级时，可以从作业知识图谱中直接查询得到中断作业的优先级，提高查询优先级的效率。
147.本技术实施例提供的作业处理方法，从作业知识图谱中获取中断作业的优先级，并在无法获取到优先级的情况下，根据中断作业属于的应用类型及中断作业对系统日结算的影响类型，确定中断作业的优先级，可以使得所属应用对应的作业数量更多，且影响系统日结算的作业得到优先处理，以此降低作业中断对测试环境带来的影响。
148.在一个实施例中，如图8所示，步骤106中，基于中断作业对第一解决方案进行遍历，包括：
149.步骤802，对中断作业进行重提处理。
150.步骤804，在重提处理成功的情况下，停止进行基于中断作业对第一解决方案进行遍历的步骤；或者，
151.步骤806，在重提处理失败的情况下，基于中断作业，对除重提处理外的各第一解决方案进行遍历。
152.本技术实施例中，由于重提处理为最为高效的解决方案，故而可以首先尝试对中断作业进行重提处理。若重提处理失败，则可以尝试其他的解决方案，如清理hbase、修复数据库、制造上游空文件等。参照图9所示，为上述过程的一个示意图。
153.若各第一解决方案中存在重提处理，则在重提处理失败的情况下，可以将重提处理从各第一解决方案中删除，以使得中断作业在对第一解决方案进行遍历时不会再遍历到重提处理；若各第一解决方案中不存在重提处理，则在重提处理失败的情况下，可以直接通过中断作业在对第一解决方案进行遍历。
154.本技术实施例提供的作业处理方法，优先对中断作业进行重提处理，并在重提处
理不成功的情况下，再通过中断作业对除重提处理外的各第一解决方案进行遍历。由于重提处理为最高效的处理方案，优先通过重提处理尝试解决中断作业，可以提高作业处理的效率。
155.在一个实施例中，上述方法还包括：
156.在各第三解决方案均无法解决中断作业的情况下，根据中断作业、中断日志、各第一解决方案及各第三解决方案，生成中断作业对应的错误报告。
157.本技术实施例中，在第三解决方案也无法解决中断作业的情况下，作业知识图谱中已不存在还未尝试过的解决方案，此时可以通过生成中断作业对应的错误报告，呼叫运维人员对中断作业进行人工处理。生成错误报告时，除中断日志外，还可以将各第一解决方案及各第三解决方案添加至错误报告中，以向运维人员展示已尝试过的解决方案。
158.若运维人员成功处理中断作业，则可以根据运维人员的人工处理方案构建目标方案节点，并将目标方案节点和目标作业节点进行连接。构建目标方案节点及将目标方案节点和目标作业节点进行连接的具体步骤可参见前述实施例的相关描述，本技术实施例在此不再赘述。
159.本技术实施例提供的作业处理方法，在各第三解决方案也无法解决中断作业的情况下，可以生成错误报告，以呼叫运维人员对中断作业进行人工处理。本技术实施例首先尝试对中断作业进行自动处理，若处理不成功再生成错误报告，以使得运维人员对中断作业进行人工处理，故而可以提升作业的处理效率。
160.应该理解的是，虽然如上所述的各实施例所涉及的流程图中的各个步骤按照箭头的指示依次显示，但是这些步骤并不是必然按照箭头指示的顺序依次执行。除非本文中有明确的说明，这些步骤的执行并没有严格的顺序限制，这些步骤可以以其它的顺序执行。而且，如上所述的各实施例所涉及的流程图中的至少一部分步骤可以包括多个步骤或者多个阶段，这些步骤或者阶段并不必然是在同一时刻执行完成，而是可以在不同的时刻执行，这些步骤或者阶段的执行顺序也不必然是依次进行，而是可以与其它步骤或者其它步骤中的步骤或者阶段的至少一部分轮流或者交替地执行。
161.基于同样的发明构思，本技术实施例还提供了一种用于实现上述所涉及的作业处理方法的作业处理装置。该装置所提供的解决问题的实现方案与上述方法中所记载的实现方案相似，故下面所提供的一个或多个作业处理装置实施例中的具体限定可以参见上文中对于作业处理方法的限定，在此不再赘述。
162.在一个实施例中，如图10所示，提供了一种作业处理装置1000，包括：第一获取模块1002、第一确定模块1004、第二确定模块1006，其中：
163.第一获取模块1002，用于在检测到中断作业时，获取所述中断作业的中断日志，并从所述中断日志中获取所述中断作业对应的错误信息；
164.第一确定模块1004，用于确定所述中断作业在作业知识图谱中对应的目标作业节点，并确定所述错误信息在所述目标作业节点的连接关系中对应的第一目标连接关系；
165.第二确定模块1006，用于在不存在所述第一目标连接关系的情况下，从所述作业知识图谱中确定至少一个第一解决方案，并基于所述中断作业对各所述第一解决方案进行遍历，直至所述中断作业得到解决为止。
166.本技术实施例提供的作业处理装置，在获取中断作业对应的错误信息后，通过作
业知识图谱查找中断作业的解决方案，并在作业知识图谱中不存在第一目标连接关系(也即作业知识图谱中未记录中断作业在产生错误信息时的解决方案)的情况下，从作业知识图谱中另行确定至少一个第一解决方案，并通过遍历各第一解决方案解决中断作业。由于本技术实施例建立作业知识图谱，并在其中记录各作业的解决方案，故而在作业中断时可以通过作业知识图谱查询到作业的解决方案，并对作业进行自动处理，故而可以提升作业处理的效率。
167.在其中一个实施例中，所述装置还包括：
168.第三确定模块，用于在存在所述第一目标连接关系的情况下，根据所述第一目标连接关系对应的方案节点，确定所述错误信息对应的第二解决方案，并通过所述第二解决方案对所述中断作业进行处理。
169.在其中一个实施例中，所述装置还包括：
170.构建模块，用于将解决所述中断作业的所述第一解决方案对应的方案节点作为目标方案节点，并根据所述目标方案节点、所述目标作业节点及所述错误信息，构建第二目标连接关系。
171.在其中一个实施例中，所述第二确定模块1006，还用于：
172.对所述作业知识图谱中的各作业节点进行聚类处理，并将与所述目标作业节点属于同一类别的所述作业节点作为第一候选作业节点；
173.确定所述错误信息在各所述第一候选作业节点的连接关系中对应的第三目标连接关系；
174.在存在所述第三目标连接关系的情况下，通过所述第三目标连接关系对应的方案节点获取第一解决方案。
175.在其中一个实施例中，所述第二确定模块1006，还用于：
176.从所述目标作业节点对应的各特征属性中确定至少一个目标特征属性；
177.基于各所述目标特征属性，对所述知识图谱中的各作业节点进行聚类处理。
178.在其中一个实施例中，所述装置还包括：
179.第四确定模块，用于在各所述第一解决方案均无法解决所述中断作业的情况下，确定所述错误信息，在各第二候选作业节点的连接关系中对应的第四目标连接关系，所述第二候选作业节点为全部所述作业节点中，除所述第一候选作业节点外的作业节点；
180.第二获取模块，用于在存在所述第四目标连接关系的情况下，通过所述第四目标连接关系对应的方案节点获取第三解决方案；
181.第一遍历模块，用于基于所述中断作业对各所述第三解决方案进行遍历，直至所述中断作业得到解决为止。
182.在其中一个实施例中，所述装置还包括：
183.第三获取模块，用于获取所述中断作业的优先级；
184.添加模块，用于将所述中断作业按照所述优先级加入至待处理队列中，所述待处理队列中各作业按照优先级由高至低的顺序排列；
185.第二遍历模块，用于按序遍历所述待处理队列中的作业，对所述待处理队列中的各所述作业进行依次处理。
186.在其中一个实施例中，所述第三获取模块，还用于：
187.在所述目标作业节点对应的特征属性中存在优先级属性的情况下，根据所述优先级属性获取所述中断作业的优先级；或者，
188.在所述目标作业节点对应的特征属性中不存在优先级属性的情况下，根据所述中断作业属于的应用类型、及所述中断作业对系统日结算的影响类型，确定所述中断作业的优先级，并将所述优先级添加为所述目标作业节点的所述优先级属性。
189.在其中一个实施例中，所述第二确定模块1006，还用于：
190.对所述中断作业进行重提处理；
191.在重提处理成功的情况下，停止进行基于所述中断作业对第一解决方案进行遍历的步骤；或者，
192.在重提处理失败的情况下，基于所述中断作业，对除重提处理外的各所述第一解决方案进行遍历。
193.在其中一个实施例中，所述装置还包括：
194.生成模块，用于在各所述第三解决方案均无法解决所述中断作业的情况下，根据所述中断作业、所述中断日志、各所述第一解决方案及各所述第三解决方案，生成所述中断作业对应的错误报告。
195.上述作业处理装置中的各个模块可全部或部分通过软件、硬件及其组合来实现。上述各模块可以硬件形式内嵌于或独立于计算机设备中的处理器中，也可以以软件形式存储于计算机设备中的存储器中，以便于处理器调用执行以上各个模块对应的操作。
196.在一个实施例中，提供了一种计算机设备，该计算机设备可以是服务器，其内部结构图可以如图11所示。该计算机设备包括通过系统总线连接的处理器、存储器和网络接口。其中，该计算机设备的处理器用于提供计算和控制能力。该计算机设备的存储器包括非易失性存储介质和内存储器。该非易失性存储介质存储有操作系统和计算机程序。该内存储器为非易失性存储介质中的操作系统和计算机程序的运行提供环境。该计算机设备的网络接口用于与外部的终端通过网络连接通信。该计算机程序被处理器执行时以实现一种作业处理方法。
197.本领域技术人员可以理解，图11中示出的结构，仅仅是与本技术方案相关的部分结构的框图，并不构成对本技术方案所应用于其上的计算机设备的限定，具体的计算机设备可以包括比图中所示更多或更少的部件，或者组合某些部件，或者具有不同的部件布置。
198.在一个实施例中，提供了一种计算机设备，包括存储器和处理器，存储器中存储有计算机程序，该处理器执行计算机程序时实现上述各方法实施例中的步骤。
199.在一个实施例中，提供了一种计算机可读存储介质，其上存储有计算机程序，该计算机程序被处理器执行时实现上述各方法实施例中的步骤。
200.在一个实施例中，提供了一种计算机程序产品，包括计算机程序，该计算机程序被处理器执行时实现上述各方法实施例中的步骤。
201.需要说明的是，本技术所涉及的用户信息(包括但不限于用户设备信息、用户个人信息等)和数据(包括但不限于用于分析的数据、存储的数据、展示的数据等)，均为经用户授权或者经过各方充分授权的信息和数据。
202.本领域普通技术人员可以理解实现上述实施例方法中的全部或部分流程，是可以通过计算机程序来指令相关的硬件来完成，所述的计算机程序可存储于一非易失性计算机
可读取存储介质中，该计算机程序在执行时，可包括如上述各方法的实施例的流程。其中，本技术所提供的各实施例中所使用的对存储器、数据库或其它介质的任何引用，均可包括非易失性和易失性存储器中的至少一种。非易失性存储器可包括只读存储器(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)等。本技术所提供的各实施例中所涉及的数据库可包括关系型数据库和非关系型数据库中至少一种。非关系型数据库可包括基于区块链的分布式数据库等，不限于此。本技术所提供的各实施例中所涉及的处理器可为通用处理器、中央处理器、图形处理器、数字信号处理器、可编程逻辑器、基于量子计算的数据处理逻辑器等，不限于此。
203.以上实施例的各技术特征可以进行任意的组合，为使描述简洁，未对上述实施例中的各个技术特征所有可能的组合都进行描述，然而，只要这些技术特征的组合不存在矛盾，都应当认为是本说明书记载的范围。
204.以上所述实施例仅表达了本技术的几种实施方式，其描述较为具体和详细，但并不能因此而理解为对本技术专利范围的限制。应当指出的是，对于本领域的普通技术人员来说，在不脱离本技术构思的前提下，还可以做出若干变形和改进，这些都属于本技术的保护范围。因此，本技术的保护范围应以所附权利要求为准。

技术特征：
1.一种作业处理方法，其特征在于，所述方法包括：在检测到中断作业时，获取所述中断作业的中断日志，并从所述中断日志中获取所述中断作业对应的错误信息；确定所述中断作业在作业知识图谱中对应的目标作业节点，并确定所述错误信息在所述目标作业节点的连接关系中对应的第一目标连接关系；在不存在所述第一目标连接关系的情况下，从所述作业知识图谱中确定至少一个第一解决方案，并基于所述中断作业对各所述第一解决方案进行遍历，直至所述中断作业得到解决为止。2.根据权利要求1所述的方法，其特征在于，所述方法还包括：在存在所述第一目标连接关系的情况下，根据所述第一目标连接关系对应的方案节点，确定所述错误信息对应的第二解决方案，并通过所述第二解决方案对所述中断作业进行处理。3.根据权利要求1所述的方法，其特征在于，在不存在所述第一目标连接关系的情况下，所述方法还包括：将解决所述中断作业的所述第一解决方案对应的方案节点作为目标方案节点，并根据所述目标方案节点、所述目标作业节点及所述错误信息，构建第二目标连接关系。4.根据权利要求1所述的方法，其特征在于，所述从所述作业知识图谱中确定至少一个第一解决方案，包括：对所述作业知识图谱中的各作业节点进行聚类处理，并将与所述目标作业节点属于同一类别的所述作业节点作为第一候选作业节点；确定所述错误信息在各所述第一候选作业节点的连接关系中对应的第三目标连接关系；在存在所述第三目标连接关系的情况下，通过所述第三目标连接关系对应的方案节点获取第一解决方案。5.根据权利要求3所述的方法，其特征在于，所述对所述作业知识图谱中的各作业节点进行聚类处理，包括：从所述目标作业节点对应的各特征属性中确定至少一个目标特征属性；基于各所述目标特征属性，对所述知识图谱中的各作业节点进行聚类处理。6.根据权利要求4所述的方法，其特征在于，所述方法还包括：在各所述第一解决方案均无法解决所述中断作业的情况下，确定所述错误信息，在各第二候选作业节点的连接关系中对应的第四目标连接关系，所述第二候选作业节点为全部所述作业节点中，除所述第一候选作业节点外的作业节点；在存在所述第四目标连接关系的情况下，通过所述第四目标连接关系对应的方案节点获取第三解决方案；基于所述中断作业对各所述第三解决方案进行遍历，直至所述中断作业得到解决为止。7.根据权利要求1所述的方法，其特征在于，所述在检测到中断作业后，所述方法还包括：获取所述中断作业的优先级；
将所述中断作业按照所述优先级加入至待处理队列中，所述待处理队列中各作业按照优先级由高至低的顺序排列；按序遍历所述待处理队列中的作业，对所述待处理队列中的各所述作业进行依次处理。8.根据权利要求7所述的方法，其特征在于，所述获取所述中断作业的优先级，包括：在所述目标作业节点对应的特征属性中存在优先级属性的情况下，根据所述优先级属性获取所述中断作业的优先级；或者，在所述目标作业节点对应的特征属性中不存在优先级属性的情况下，根据所述中断作业属于的应用类型、及所述中断作业对系统日结算的影响类型，确定所述中断作业的优先级，并将所述优先级添加为所述目标作业节点的所述优先级属性。9.根据权利要求1所述的方法，其特征在于，所述基于所述中断作业对第一解决方案进行遍历，包括：对所述中断作业进行重提处理；在重提处理成功的情况下，停止进行基于所述中断作业对第一解决方案进行遍历的步骤；或者，在重提处理失败的情况下，基于所述中断作业，对除重提处理外的各所述第一解决方案进行遍历。10.根据权利要求6所述的方法，其特征在于，所述方法还包括：在各所述第三解决方案均无法解决所述中断作业的情况下，根据所述中断作业、所述中断日志、各所述第一解决方案及各所述第三解决方案，生成所述中断作业对应的错误报告。11.一种作业处理装置，其特征在于，所述装置包括：第一获取模块，用于在检测到中断作业时，获取所述中断作业的中断日志，并从所述中断日志中获取所述中断作业对应的错误信息；第一确定模块，用于确定所述中断作业在作业知识图谱中对应的目标作业节点，并确定所述错误信息在所述目标作业节点的连接关系中对应的第一目标连接关系；第二确定模块，用于在不存在所述第一目标连接关系的情况下，从所述作业知识图谱中确定至少一个第一解决方案，并基于所述中断作业对各所述第一解决方案进行遍历，直至所述中断作业得到解决为止。12.一种计算机设备，包括存储器和处理器，所述存储器存储有计算机程序，其特征在于，所述处理器执行所述计算机程序时实现权利要求1至10中任一项所述的方法的步骤。13.一种计算机可读存储介质，其上存储有计算机程序，其特征在于，所述计算机程序被处理器执行时实现权利要求1至10中任一项所述的方法的步骤。14.一种计算机程序产品，包括计算机程序，其特征在于，该计算机程序被处理器执行时实现权利要求1至10中任一项所述的方法的步骤。

技术总结
本申请涉及一种作业处理方法、装置、计算机设备和存储介质，涉及大数据技术领域。所述方法包括：在检测到中断作业时，获取中断作业的中断日志，并从中断日志中获取中断作业对应的错误信息；确定中断作业在作业知识图谱中对应的目标作业节点，并确定错误信息在所述目标作业节点的连接关系中对应的第一目标连接关系；在不存在第一目标连接关系的情况下，从作业知识图谱中确定至少一个第一解决方案，并基于中断作业对各第一解决方案进行遍历，直至中断作业得到解决为止。采用本方法能够提高解决中断作业的效率。中断作业的效率。中断作业的效率。


技术研发人员：唐化江 王添阳 李凡 王司宇
受保护的技术使用者：中国工商银行股份有限公司
技术研发日：2023.04.13
技术公布日：2023/7/12