数据线的缺陷解决方法、装置、设备、介质及产品

著录项
  • CN202211606566.X
  • 20221213
  • CN115907412A
  • 20230404
  • 中国建设银行股份有限公司;建信金融科技有限责任公司
  • 曾辉耀;方妍;徐国柱
  • G06Q10/0631
  • G06Q10/0631 G06F16/25 G06F16/28

  • 北京市西城区金融大街25号
  • 北京(11)
  • 北京东方亿思知识产权代理有限责任公司
  • 赵秀芹
摘要
本申请公开了一种数据线的缺陷解决方法、装置、设备、介质及产品。该方法包括:在目标上游业务系统向数据仓库重新提供目标源数据的情况下,响应于第一用户的第一输入,向数据仓库发送目标数据重跑申请,目标数据重跑申请携带目标源数据对应的关联信息,关联信息包括目标源数据的目标标识信息;在数据仓库接收到目标数据重跑申请的情况下,响应于第二用户的第二输入,根据多个作业任务分别对应的源数据信息,确定目标标识信息对应的目标作业任务;基于目标源数据执行目标作业任务,得到目标结果数据,以便在接收到目标下游应用系统获取目标结果数据的请求的情况下,将目标结果数据发送至目标下游应用系统。这样,可以提高缺陷解决的效率。
权利要求

1.一种数据线的缺陷解决方法,其特征在于,包括:

在目标上游业务系统向数据仓库重新提供目标源数据的情况下,响应于第一用户的第一输入,向所述数据仓库发送目标数据重跑申请,所述目标数据重跑申请携带所述目标源数据对应的关联信息,所述关联信息包括所述目标源数据的目标标识信息;

在所述数据仓库接收到所述目标数据重跑申请的情况下,响应于第二用户的第二输入,根据预先配置的多个作业任务分别对应的源数据信息,确定所述目标标识信息对应的目标作业任务,所述源数据信息包括所述作业任务所需的源数据的第一标识信息;

基于所述目标源数据执行所述目标作业任务,得到目标结果数据,以便在接收到目标下游应用系统获取所述目标结果数据的请求的情况下,将所述目标结果数据发送至所述目标下游应用系统。

2.根据权利要求1所述的方法,其特征在于,所述关联信息还包括所述目标源数据对应的目标联系人信息,在所述数据仓库接收到所述目标数据重跑申请之后,所述方法还包括:

在所述目标源数据未通过数据检核的情况下,根据所述目标联系人信息,通知所述目标源数据对应的目标联系人,以便所述目标联系人重新提供数据;

在所述目标源数据通过数据检核的情况下,基于所述目标源数据执行所述目标作业任务;

在基于所述目标源数据执行所述目标作业任务的过程中出现异常的情况下,根据所述目标联系人信息,通知所述目标源数据对应的目标联系人,以便所述目标联系人重新提供数据。

3.根据权利要求1所述的方法,其特征在于,所述方法还包括:

响应于所述第二用户的第三输入,在所述数据仓库中配置多个作业任务分别对应的源数据信息和结果数据信息,所述结果数据信息包括所述作业任务对应的结果数据的第二标识信息;

以及,

响应于所述第二用户的第四输入,在所述数据仓库中配置多个下游应用系统分别对应的标注信息,所述标注信息包括所述下游应用系统的系统标识和所述下游应用系统所需的结果数据的第三标识信息。

4.根据权利要求3所述的方法,其特征在于,所述基于所述目标源数据执行所述目标作业任务,得到目标结果数据,包括:

根据所述源数据信息,确定所述目标作业任务所需的第一源数据的第四标识信息;

根据所述第四标识信息获取所述第一源数据,所述第一源数据包括所述目标源数据;

基于所述第一源数据执行所述目标作业任务,得到目标结果数据。

5.根据权利要求3所述的方法,其特征在于,在所述基于所述目标源数据执行所述目标作业任务,得到目标结果数据之后,所述方法还包括:

根据所述结果数据信息,确定所述目标作业任务对应的目标结果数据的第五标识信息;

根据所述标注信息确定所述第五标识信息对应的目标系统标识;

根据所述目标系统标识,向所述目标系统标识对应的第一下游应用系统发送提示信息,所述提示信息用于提示目标缺陷标识所指示的缺陷已解决。

6.根据权利要求1所述的方法,其特征在于,所述关联信息还包括重新提供所述目标源数据所针对的缺陷的目标缺陷标识,在所述基于所述目标源数据执行所述目标作业任务,得到目标结果数据之后,所述方法还包括:

将所述目标缺陷标识所指示的缺陷的状态更新为已解决状态。

7.一种数据线的缺陷解决装置,其特征在于,所述装置包括:

第一发送模块,用于在目标上游业务系统向数据仓库重新提供目标源数据的情况下,响应于第一用户的第一输入,向所述数据仓库发送目标数据重跑申请,所述目标数据重跑申请携带所述目标源数据对应的关联信息,所述关联信息包括所述目标源数据的目标标识信息;

第一确定模块,用于在所述数据仓库接收到所述目标数据重跑申请的情况下,响应于第二用户的第二输入,根据预先配置的多个作业任务分别对应的源数据信息,确定所述目标标识信息对应的目标作业任务,所述源数据信息包括所述作业任务所需的源数据的第一标识信息;

第一执行模块,用于基于所述目标源数据执行所述目标作业任务,得到目标结果数据,以便在接收到目标下游应用系统获取所述目标结果数据的请求的情况下,将所述目标结果数据发送至所述目标下游应用系统。

8.一种电子设备,其特征在于,所述设备包括:处理器以及存储有计算机程序指令的存储器;

所述处理器执行所述计算机程序指令时实现如权利要求1-6任意一项所述的数据线的缺陷解决方法。

9.一种计算机存储介质,其特征在于,所述计算机存储介质上存储有计算机程序指令,所述计算机程序指令被处理器执行时实现如权利要求1-6任意一项所述的数据线的缺陷解决方法。

10.一种计算机程序产品,其特征在于,所述计算机程序产品中的指令由电子设备的处理器执行时,使得所述电子设备执行如权利要求1-6任意一项所述的数据线的缺陷解决方法。

说明书
技术领域

本申请属于任务处理技术领域,尤其涉及一种数据线的缺陷解决方法、装置、设备、介质及产品。

目前,在对数据线进行准确性测试后,若发现数据准确性存在缺陷,通常从下游应用系统到中游数据仓库,再到上游业务系统逐步反向分析流转缺陷,上游定位问题后,重新调整数据并向数据仓库重供数据。上游业务系统完成数据重供后,若系统测试人员不知道已完成数据重供,则数据仓库无法对重供的数据进行处理。

相关技术中,上游业务系统完成数据重供后,上游业务系统开发人员可以通知系统测试人员数据流转信息,系统测试人员再告知数据仓库开发人员触发数据仓库对重供数据进行处理,但是通过该方法触发数据仓库对重供数据进行处理,流转时间较长,而且容易出现数据流转信息不清晰的问题,从而会导致缺陷解决的效率低下。

本申请实施例提供一种数据线的缺陷解决方法、装置、设备、介质及产品,可以提高缺陷解决的效率。

第一方面,本申请实施例提供一种数据线的缺陷解决方法,该方法包括:

在目标上游业务系统向数据仓库重新提供目标源数据的情况下,响应于第一用户的第一输入,向数据仓库发送目标数据重跑申请,目标数据重跑申请携带目标源数据对应的关联信息,关联信息包括目标源数据的目标标识信息;

在数据仓库接收到目标数据重跑申请的情况下,响应于第二用户的第二输入,根据预先配置的多个作业任务分别对应的源数据信息,确定目标标识信息对应的目标作业任务,源数据信息包括作业任务所需的源数据的第一标识信息;

基于目标源数据执行目标作业任务,得到目标结果数据,以便在接收到目标下游应用系统获取目标结果数据的请求的情况下,将目标结果数据发送至目标下游应用系统。

第二方面,本申请实施例提供了一种数据线的缺陷解决装置,该装置包括:

第一发送模块,用于在目标上游业务系统向数据仓库重新提供目标源数据的情况下,响应于第一用户的第一输入,向数据仓库发送目标数据重跑申请,目标数据重跑申请携带目标源数据对应的关联信息,关联信息包括目标源数据的目标标识信息;

第一确定模块,用于在数据仓库接收到目标数据重跑申请的情况下,响应于第二用户的第二输入,根据预先配置的多个作业任务分别对应的源数据信息,确定目标标识信息对应的目标作业任务,源数据信息包括作业任务所需的源数据的第一标识信息;

第一执行模块,用于基于目标源数据执行目标作业任务,得到目标结果数据,以便在接收到目标下游应用系统获取目标结果数据的请求的情况下,将目标结果数据发送至目标下游应用系统。

第三方面,本申请实施例提供了一种电子设备,设备包括:处理器以及存储有计算机程序指令的存储器;

处理器执行计算机程序指令时实现如第一方面的任一项实施例中所示的数据线的缺陷解决方法。

第四方面,本申请实施例提供了一种计算机存储介质,计算机存储介质上存储有计算机程序指令,计算机程序指令被处理器执行时实现第一方面的任一项实施例中所示的数据线的缺陷解决方法。

第五方面,本申请实施例提供了一种计算机程序产品,计算机程序产品中的指令由电子设备的处理器执行时,使得电子设备执行第一方面的任一项实施例中所示的数据线的缺陷解决方法。

本申请实施例的数据线的缺陷解决方法、装置、设备、介质及产品,在目标上游业务系统向数据仓库重新提供目标源数据的情况下,响应于第一用户的第一输入,可以向数据仓库发送目标数据重跑申请,由于该目标数据重跑申请携带目标源数据对应的关联信息,该关联信息包括目标源数据的目标标识信息,而且数据仓库中预先配置了多个作业任务分别对应的源数据信息,源数据信息又包括多个作业任务分别所需的源数据的第一标识信息,因此,在数据仓库接收到目标数据重跑申请的情况下,可以响应于第二用户的第二输入,根据预先配置的多个作业任务分别对应的源数据信息,确定目标标识信息对应的目标作业任务,然后便可以基于目标源数据执行目标作业任务,得到目标结果数据,这样,触发执行目标作业任务无需经过多个人员之间的流转,而且根据目标数据重跑申请所携带的关联信息中包括的目标标识信息可以准确地确定需要执行的目标作业任务,因此能够快速基于目标源数据执行目标作业任务,得到目标结果数据,从而解决缺陷,提高了缺陷解决的效率。

为了更清楚地说明本申请实施例的技术方案,下面将对本申请实施例中所需要使用的附图作简单的介绍,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他的附图。

图1是本申请一个实施例提供的一种数据线的缺陷解决方法的流程图;

图2是本申请一个实施例提供的另一种数据线的缺陷解决方法的流程图;

图3是本申请一个实施例提供的一种数据线的缺陷解决装置的结构示意图;

图4是本申请一个实施例提供的一种电子设备的结构示意图。

下面将详细描述本申请的各个方面的特征和示例性实施例,为了使本申请的目的、技术方案及优点更加清楚明白,以下结合附图及具体实施例,对本申请进行进一步详细描述。应理解,此处所描述的具体实施例仅意在解释本申请,而不是限定本申请。对于本领域技术人员来说,本申请可以

在不需要这些具体细节中的一些细节的情况下实施。下面对实施例的描述5仅仅是为了通过示出本申请的示例来提供对本申请更好的理解。

需要说明的是,在本文中,诸如第一和第二等之类的关系术语仅仅用来将一个实体或者操作与另一个实体或操作区分开来,而不一定要求或者暗示这些实体或操作之间存在任何这种实际的关系或者顺序。而且,术语

“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含,从而0使得包括一系列要素的过程、方法、物品或者设备不仅包括那些要素,而

且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法、物品或者设备所固有的要素。在没有更多限制的情况下,由语句“包括……”

限定的要素,并不排除在包括所述要素的过程、方法、物品或者设备中还存在另外的相同要素。

5此外,还需要说明的是,本申请技术方案中对数据的获取、存储、使

用、处理等均符合国家法律法规的相关规定。

如背景技术,目前对数据线的测试除了功能性测试外,还有数据准确性的测试,对于数据准确性的测试,一般采用长案例来进行,具体的流程

为:上游业务系统做测试案例进行业务埋数、上游业务系统将预埋数据供0数给数据仓库、数据仓库将预埋数据进行检核并加载到数据仓库、数据仓

库对数据进行加工处理并将处理结果传给下游应用系统、下游应用系统将数据加工成报表指标展现给用户,用户对结果进行测试验证。当出现数据准确性缺陷时,下游应用系统、中游数据仓库、上游业务系统逐步反向分

析流转缺陷,上游定位问题后,重新调整数据并重新提供数据给数据仓库。5上游业务系统完成数据重供后,若系统测试人员不知道或未流转缺陷或数

据流转信息描述不清,则数据仓库无法及时处理这些重供数据,导致缺陷解决时间变长。而且,当存在多个上游业务系统、多个下游应用系统时,无法确定数据重供是为了进行测试,还是为了解决某个缺陷。目前对数据线进行测试的相关技术主要关注测试案例如何设计、缺陷如何流转,但没有把缺陷解决过程与缺陷流转的流程进行有效的结合,没有将缺陷问题的外延影响进行充分考虑。缺少对数据仓库内部数据缺陷处理的有效支持。

具体地,上游组件重供数据给仓库时,需要通过缺陷流转告诉仓库测试人员,测试人员再告知仓库开发人员进行处理,容易出现数据流转信息不清晰、流转过程处理时间长的问题,导致开发人员处理重供数据效率低下。

本申请实施例提供了一种数据线的缺陷解决方法,在目标上游业务系统向数据仓库重新提供目标源数据的情况下,响应于第一用户的第一输入,可以向数据仓库发送目标数据重跑申请,由于该目标数据重跑申请携带目标源数据对应的关联信息,该关联信息包括目标源数据的目标标识信息,而且数据仓库中预先配置了多个作业任务分别对应的源数据信息,源数据信息又包括多个作业任务分别所需的源数据的第一标识信息,因此,在数据仓库接收到目标数据重跑申请的情况下,可以响应于第二用户的第二输入,根据预先配置的多个作业任务分别对应的源数据信息,确定目标标识信息对应的目标作业任务,然后便可以基于目标源数据执行目标作业任务,得到目标结果数据,这样,触发执行目标作业任务无需经过多个人员之间的流转,而且根据目标数据重跑申请所携带的关联信息中包括的目标标识信息可以准确地确定需要执行的目标作业任务,因此能够快速基于目标源数据执行目标作业任务,得到目标结果数据,从而解决缺陷,提高了缺陷解决的效率。

图1示出了本申请一个实施例提供的一种数据线的缺陷解决方法的流程示意图,需要说明的是,该数据线的缺陷解决方法可以应用于数据线的缺陷解决装置,如图1所示,该数据线的缺陷解决方法可以包括如下步骤:

S110,在目标上游业务系统向数据仓库重新提供目标源数据的情况下,响应于第一用户的第一输入,向数据仓库发送目标数据重跑申请;

S120,在数据仓库接收到目标数据重跑申请的情况下,响应于第二用户的第二输入,根据预先配置的多个作业任务分别对应的源数据信息,确定目标标识信息对应的目标作业任务;

S130,基于目标源数据执行目标作业任务,得到目标结果数据,以便在接收到目标下游应用系统获取目标结果数据的请求的情况下,将目标结果数据发送至目标下游应用系统。

由此,在目标上游业务系统向数据仓库重新提供目标源数据的情况下,响应于第一用户的第一输入,可以向数据仓库发送目标数据重跑申请,由于该目标数据重跑申请携带目标源数据对应的关联信息,该关联信息包括目标源数据的目标标识信息,而且数据仓库中预先配置了多个作业任务分别对应的源数据信息,源数据信息又包括多个作业任务分别所需的源数据的第一标识信息,因此,在数据仓库接收到目标数据重跑申请的情况下,可以响应于第二用户的第二输入,根据预先配置的多个作业任务分别对应的源数据信息,确定目标标识信息对应的目标作业任务,然后便可以基于目标源数据执行目标作业任务,得到目标结果数据,这样,触发执行目标作业任务无需经过多个人员之间的流转,而且根据目标数据重跑申请所携带的关联信息中包括的目标标识信息可以准确地确定需要执行的目标作业任务,因此能够快速基于目标源数据执行目标作业任务,得到目标结果数据,从而解决缺陷,提高了缺陷解决的效率。

涉及S110,数据线可以包括至少一个上游业务系统、数据仓库和至少一个下游应用系统。上游应用系统可以向数据仓库提供源数据,数据仓库可以对上游应用系统提供的源数据进行处理,得到结果数据,然后在下游应用系统向数据仓库请求结果数据时,将结果数据发送至下游应用系统。

目标数据重跑申请可以用于申请重新对目标源数据进行处理,也就是说,申请重新执行目标源数据对应的目标作业任务。该目标数据重跑申请可以携带目标源数据对应的关联信息。关联信息可以包括目标源数据的目标标识信息。示例性地,目标标识信息可以为目标源数据所在表的表名。

第一输入可以是触发向数据仓库发送目标数据重跑申请的输入。在目标上游业务系统向数据仓库重新提供目标源数据的同时或之后,数据线的缺陷解决装置可以响应于第一用户的第一输入,控制目标上游业务系统向数据仓库发送目标数据重跑申请。第一用户可以是目标上游业务系统的开发人员,当然也可以是其他人员,在此不做限定。

在一些实施方式中,在S110之前,该方法还可以包括:

响应于第一用户的第五输入,确定目标源数据对应的关联信息。

其中,第五输入可以是录入关联信息的输入。关联数据还可以包括目标源数据对应的测试环境和目标源数据的日期批次。

示例性地,目标源数据对应的测试环境可以指示目标源数据应用于对数据线的准确性进行测试。目标源数据可以为2022年12月06日的第一批数据。

涉及S120,第二用户可以为数据仓库的开发人员,当然也可以是其他人员,在此不做限定。第二输入可以为从数据仓库接收到的多个数据重跑申请中选择目标数据重跑申请的输入。

具体地,可以预先在数据仓库中配置多个作业任务分别对应的源数据信息,该源数据信息可以包括作业任务所需的源数据的第一标识信息。根据该源数据信息可以确定每个作业任务所需的源数据的第一标识信息,由于目标源数据的关联信息中包括目标源数据的目标标识信息,因此在数据仓库接收到携带目标标识信息的目标数据重跑申请的情况下,可以根据该源数据信息确定与目标标识信息对应的一个或多个作业任务,也即目标作业任务。目标作业任务可以包括一个或多个作业任务,目标作业任务可以为重新提供目标源数据后需要重新执行的作业任务。

涉及S130,确定目标作业任务后,数据线的缺陷解决装置便可以控制数据仓库基于目标源数据执行该目标作业任务,得到目标结果数据。

然后,若数据仓库接收到目标下游应用系统获取目标结果数据的请求,数据线的缺陷解决装置便可以控制数据仓库将该目标结果数据发送至目标下游应用系统。目标下游应用系统可以包括一个或多个下游应用系统。

在一些实施方式中,为了提高缺陷解决的效率,关联信息还可以包括目标源数据对应的目标联系人信息,在数据仓库接收到目标数据重跑申请之后,该方法还可以包括:

在目标源数据未通过数据检核的情况下,根据目标联系人信息,通知目标源数据对应的目标联系人,以便目标联系人重新提供数据;

在目标源数据通过数据检核的情况下,基于目标源数据执行目标作业任务;

在基于目标源数据执行目标作业任务的过程中出现异常的情况下,根据目标联系人信息,通知目标源数据对应的目标联系人,以便目标联系人重新提供数据。

其中,目标联系人信息可以包括目标联系人的,还可以包括目标联系人的标识,该目标联系人的标识可以包括目标联系人的姓名和/或职责。目标联系人可以为目标上游业务系统的开发人员。示例性地,目标联系人可以为第一用户。

这里,可以周期性地确定数据仓库是否接收到数据重跑申请,在数据仓库接收到目标数据重跑申请后,可以确定目标上游系统向数据仓库重新提供了目标源数据。然后,可以对目标源数据进行数据检核,若目标源数据未通过数据检核,则可以根据目标联系人信息,通知目标源数据对应的目标联系人,以便目标联系人重新提供数据。若目标源数据通过数据检核,则可以将目标源数据加载入仓,并基于该目标源数据执行目标作业任务,若在基于目标源数据执行目标作业任务的过程中出现异常,则可以根据目标联系人信息,通知目标源数据对应的目标联系人,以便目标联系人重新提供数据。

也就是说,在数据检核和数据处理的任一过程中出现问题,都可以根据目标联系人信息,通知目标源数据对应的目标联系人,以便目标联系人重新提供数据。重新提供数据之后可以返回执行S110。

如此,由于目标源数据的关联信息中包括目标联系人信息,目标联系人可以是目标上游业务系统的开发人员,因此若目标源数据存在异常,可以及时通知目标上游业务系统的开发人员重新提供数据,重新进行数据处理,因此提高了缺陷解决的效率。

在一些实施方式中,为了便于确定需要重新执行的作业任务和受影响的下游应用系统,在S110之前,该方法还可以包括:

响应于第二用户的第三输入,在数据仓库中配置多个作业任务分别对应的源数据信息和结果数据信息;

以及,

响应于第二用户的第四输入,在数据仓库中配置多个下游应用系统分别对应的标注信息。

这里,源数据信息可以包括作业任务所需的源数据的第一标识信息,还可以包括作业任务的标识和该作业任务所需的源数据对应的上游业务系统标识。示例性地,作业任务的标识可以为作业任务的名称。

结果数据信息可以包括作业任务对应的结果数据的第二标识信息,还可以包括作业任务的标识。示例性地,该第二标识信息可以为结果数据所在表的表名。

标注信息可以包括下游应用系统的系统标识和下游应用系统所需的结果数据的第三标识信息。下游应用系统所需的结果数据可以指能够通过该下游应用系统请求的结果数据。此外,该标注信息还可以包括该下游应用系统的用途信息。

第三输入可以是录入源数据信息和结果数据信息的输入。第四输入可以是录入标注信息的输入。

需要说明的是,本申请实施例对配置源数据信息和结果数据信息,与配置标注信息的先后顺序不做限定。

如此,通过预先配置多个作业任务分别对应的源数据信息和结果数据信息,以及多个下游应用系统分别对应的标注信息,可以方便后续确定需要重新执行的作业任务和受影响的下游应用系统。

在一些实施方式中,如图2所示,为了更加快速准确地执行目标源数据对应的目标作业任务,S130可以包括S1301至S1303,具体如下:

S1301,根据源数据信息,确定目标作业任务所需的第一源数据的第四标识信息;

S1302,根据第四标识信息获取第一源数据;

S1303,基于第一源数据执行目标作业任务,得到目标结果数据。

这里,由于预先配置了多个作业任务分别对应的源数据信息和结果数据信息,而源数据信息可以包括每个作业任务所需的源数据的第一标识信息,因此源数据信息中可以包括目标作业任务所需的第一源数据的第四标识信息,因此可以根据预先配置的源数据信息确定目标作业任务所需的第一源数据的第四标识信息。根据该第四标识信息可以获取到第一源数据,该第一源数据可以包括目标源数据,还可以包括目标作业任务所需的除目标源数据之外的其他源数据。然后可以基于该第一源数据执行目标作业任务,得到目标结果数据。

然后,还可以将该目标结果数据存储至数据仓库。

示例性地,可以生成需要重跑的作业任务清单,该作业任务清单中可以包括目标作业任务所包括的至少一个作业任务。

如此,通过上述过程可以根据预先配置的源数据信息,更加快速准确地确定需要重新执行的作业任务和源数据,也即目标作业任务和第一源数据,从而能够更加快速准确地执行目标作业任务,避免再次出现问题,提高了缺陷解决的效率。

在一些实施方式中,为了明确数据线的缺陷是否已经解决,降低沟通成本,关联信息还可以包括重新提供目标源数据所针对的缺陷的目标缺陷标识,在S130之后,该方法还可以包括:

将目标缺陷标识所指示的缺陷的状态更新为已解决状态。

这里,目标缺陷标识可以用于指示数据线所出现的缺陷。在基于重新提供的目标源数据重新执行目标作业任务,得到目标结果数据之后,可以将该目标缺陷标识所指示的缺陷的状态更新为已解决状态。

需要说明的是,数据线的缺陷解决装置可以在基于目标源数据执行目标作业任务,得到目标结果数据之后,自动将目标缺陷标识所指示的缺陷的状态更新为已解决状态。

数据线的缺陷解决装置也可以响应于第三用户的第六输入,将目标缺陷标识所指示的缺陷的状态更新为已解决状态。其中,第三用户可以为数据线的测试人员,第六输入可以为修改缺陷状态的输入。示例性地,在基于目标源数据执行目标作业任务,得到目标结果数据之后,可以将执行结果通知第三用户,以便第三用户进行第六输入。

如此,通过在基于重新提供的目标源数据重新执行目标作业任务,得到目标结果数据之后,更新缺陷的状态,可以明确数据线的缺陷是否已经解决,降低了各方之间的沟通成本,提高了工作效率。

目标上游业务系统重新提供的目标源数据可能会影响很多目标作业任务的执行,这些目标作业任务执行得到的目标结果数据又会影响很多下游应用系统。在调整并重新提供目标源数据的过程中,其他受影响的下游应用系统也可能会发现该缺陷并上报,这会导致重复上报该缺陷,重复处理该缺陷会导致相同问题重复分析,缺陷流转和管理压力递增。

在一些实施方式中,为了尽可能避免下游应用系统重复上报缺陷,并加快已上报缺陷的关闭速度,在S130之后,该方法还可以包括:

根据结果数据信息,确定目标作业任务对应的目标结果数据的第五标识信息;

根据标注信息确定第五标识信息对应的目标系统标识;

根据目标系统标识,向目标系统标识对应的第一下游应用系统发送提示信息。

这里,结果数据信息可以包括每个作业任务对应的结果数据的第二标识信息,因此结果数据信息中可以包括目标作业任务对应的目标结果数据的第五标识信息,因此根据预先配置的结果数据信息可以确定目标作业任务对应的目标结果数据的第五标识信息。

标注信息可以包括每个下游应用系统的系统标识和该下游应用系统所需的结果数据的第三标识信息,因此标注信息中可以包括目标结果数据的第五标识信息及该第五标识信息对应的目标系统标识,因此可以根据预先配置的标注信息确定第五标识信息对应的目标系统标识。

受影响的下游应用系统可能是多个,因此目标系统标识可以包括一个或多个系统标识。示例性地,可以导出受影响的下游应用系统清单。

目标系统标识可以为第一下游应用系统的系统标识,因此可以向目标系统标识对应的第一下游应用系统发送提示信息。该提示信息可以用于提示目标缺陷标识所指示的缺陷已解决。第一下游应用系统可以为受到该缺陷影响的下游应用系统,该第一下游应用系统可以包括一个或多个下游应用系统。

如此,通过该提示信息可以提醒第一下游应用系统对应的工作人员该缺陷已经解决,尚未上报该缺陷的系统不需要再上报该缺陷,已经上报该缺陷的系统可以关闭该缺陷,因此可以避免下游应用系统重复上报缺陷并加快一上报缺陷的关闭,减轻系统压力。此外,还可以提醒第一下游应用系统对应的工作人员缺陷已解决,可以重新请求结果数据。

基于相同的发明构思,本申请实施例还提供了一种数据线的缺陷解决装置。下面结合图3对本申请实施例提供的数据线的缺陷解决装置进行详细说明。

图3示出了本申请一个实施例提供的一种数据线的缺陷解决装置的结构示意图。

如图3所示,该数据线的缺陷解决装置可以包括:

第一发送模块301,用于在目标上游业务系统向数据仓库重新提供目标源数据的情况下,响应于第一用户的第一输入,向数据仓库发送目标数据重跑申请,目标数据重跑申请携带目标源数据对应的关联信息,关联信息包括目标源数据的目标标识信息;

第一确定模块302,用于在数据仓库接收到目标数据重跑申请的情况下,响应于第二用户的第二输入,根据预先配置的多个作业任务分别对应的源数据信息,确定目标标识信息对应的目标作业任务,源数据信息包括作业任务所需的源数据的第一标识信息;

第一执行模块303,用于基于目标源数据执行目标作业任务,得到目标结果数据,以便在接收到目标下游应用系统获取目标结果数据的请求的情况下,将目标结果数据发送至目标下游应用系统。

由此,在目标上游业务系统向数据仓库重新提供目标源数据的情况下,响应于第一用户的第一输入,可以向数据仓库发送目标数据重跑申请,由于该目标数据重跑申请携带目标源数据对应的关联信息,该关联信息包括目标源数据的目标标识信息,而且数据仓库中预先配置了多个作业任务分别对应的源数据信息,源数据信息又包括多个作业任务分别所需的源数据的第一标识信息,因此,在数据仓库接收到目标数据重跑申请的情况下,可以响应于第二用户的第二输入,根据预先配置的多个作业任务分别对应的源数据信息,确定目标标识信息对应的目标作业任务,然后便可以基于目标源数据执行目标作业任务,得到目标结果数据,这样,触发执行目标作业任务无需经过多个人员之间的流转,而且根据目标数据重跑申请所携带的关联信息中包括的目标标识信息可以准确地确定需要执行的目标作业任务,因此能够快速基于目标源数据执行目标作业任务,得到目标结果数据,从而解决缺陷,提高了缺陷解决的效率。

在一些实施方式中,为了提高缺陷解决的效率,关联信息还包括目标源数据对应的目标联系人信息,该数据线的缺陷解决装置还可以包括:

接收模块,用于在数据仓库接收到目标数据重跑申请之后,在目标源数据未通过数据检核的情况下,根据目标联系人信息,通知目标源数据对应的目标联系人,以便目标联系人重新提供数据;

第二执行模块,用于在目标源数据通过数据检核的情况下,基于目标源数据执行目标作业任务;

通知模块,用于在基于目标源数据执行目标作业任务的过程中出现异常的情况下,根据目标联系人信息,通知目标源数据对应的目标联系人,以便目标联系人重新提供数据。

在一些实施方式中,为了便于确定需要重新执行的作业任务和受影响的下游应用系统,该数据线的缺陷解决装置还可以包括:

第一配置模块,用于响应于第二用户的第三输入,在数据仓库中配置多个作业任务分别对应的源数据信息和结果数据信息,结果数据信息包括作业任务对应的结果数据的第二标识信息;

以及,

第二配置模块,用于响应于第二用户的第四输入,在数据仓库中配置多个下游应用系统分别对应的标注信息,标注信息包括下游应用系统的系统标识和下游应用系统所需的结果数据的第三标识信息。

在一些实施方式中,为了更加快速准确地执行目标源数据对应的目标作业任务,第一执行模块303可以包括:

第一确定子模块,用于根据源数据信息,确定目标作业任务所需的第一源数据的第四标识信息;

获取子模块,用于根据第四标识信息获取第一源数据,第一源数据包括目标源数据;

执行子模块,用于基于第一源数据执行目标作业任务,得到目标结果数据。

在一些实施方式中,为了尽可能避免下游应用系统重复上报缺陷,并加快已上报缺陷的关闭速度,该数据线的缺陷解决装置还可以包括:

第二确定模块,用于在基于目标源数据执行目标作业任务,得到目标结果数据之后,根据结果数据信息,确定目标作业任务对应的目标结果数据的第五标识信息;

第三确定模块,用于根据标注信息确定第五标识信息对应的目标系统标识;

第二发送模块,用于根据目标系统标识,向目标系统标识对应的第一下游应用系统发送提示信息,提示信息用于提示目标缺陷标识所指示的缺陷已解决。

在一些实施方式中,为了明确数据线的缺陷是否已经解决,降低沟通成本,关联信息还可以包括重新提供目标源数据所针对的缺陷的目标缺陷标识,该数据线的缺陷解决装置还可以包括:

更新模块,用于在基于目标源数据执行目标作业任务,得到目标结果数据之后,将目标缺陷标识所指示的缺陷的状态更新为已解决状态。

图4示出了本申请一个实施例提供的一种电子设备的结构示意图。

如图4所示,该电子设备4能够实现根据本申请实施例中的数据线的缺陷解决方法以及数据线的缺陷解决装置的电子设备的示例性硬件架构的结构图。该电子设备可以指代本申请实施例中的电子设备。

该电子设备4可以包括处理器401以及存储有计算机程序指令的存储器402。

具体地,上述处理器401可以包括中央处理器(CPU),或者特定集成电路(Application Specific Integrated Circuit,ASIC),或者可以被配置成实施本申请实施例的一个或多个集成电路。

存储器402可以包括用于数据或指令的大容量存储器。举例来说而非限制,存储器402可包括硬盘驱动器(Hard Disk Drive,HDD)、软盘驱动器、闪存、光盘、磁光盘、磁带或通用串行总线(Universal Serial Bus,USB)驱动器或者两个或更多个以上这些的组合。在合适的情况下,存储器402可包括可移除或不可移除(或固定)的介质。在合适的情况下,存储器402可在综合网关容灾设备的内部或外部。在特定实施例中,存储器402是非易失性固态存储器。在特定实施例中,存储器402可包括只读存储器(ROM),随机存取存储器(RAM),磁盘存储介质设备,光存储介质设备,闪存设备,电气、光学或其他物理/有形的存储器存储设备。因此,通常,存储器402包括一个或多个编码有包括计算机可执行指令的软件的有形(非暂态)计算机可读存储介质(例如,存储器设备),并且当该软件被执行(例如,由一个或多个处理器)时,其可操作来执行参考根据本申请的一方面的方法所描述的操作。

处理器401通过读取并执行存储器402中存储的计算机程序指令,以实现上述实施例中的任意一种数据线的缺陷解决方法。

在一个示例中,该电子设备还可包括通信接口403和总线404。其中,如图4所示,处理器401、存储器402、通信接口403通过总线404连接并完成相互间的通信。

通信接口403,主要用于实现本申请实施例中各模块、装置、单元和/或设备之间的通信。

总线404包括硬件、软件或两者,将电子设备的部件彼此耦接在一起。举例来说而非限制,总线可包括加速图形端口(AGP)或其他图形总线、增强工业标准架构(EISA)总线、前端总线(FSB)、超传输(HT)互连、工业标准架构(ISA)总线、无限带宽互连、低引脚数(LPC)总线、存储器总线、道架构(MCA)总线、外围组件互连(PCI)总线、PCI-Express(PCI-X)总线、串行高级技术附件(SATA)总线、视频电子标准协会局部(VLB)总线或其他合适的总线或者两个或更多个以上这些的组合。在合适的情况下,总线404可包括一个或多个总线。尽管本申请实施例描述和示出了特定的总线,但本申请考虑任何合适的总线或互连。

该电子设备可以执行本申请实施例中的数据线的缺陷解决方法,从而实现结合图1至图3描述的数据线的缺陷解决方法和装置。

另外,结合上述实施例中的数据线的缺陷解决方法,本申请实施例可提供一种计算机存储介质来实现。该计算机存储介质上存储有计算机程序指令;该计算机程序指令被处理器执行时实现上述实施例中的任意一种数据线的缺陷解决方法。

需要明确的是,本申请并不局限于上文所描述并在图中示出的特定配置和处理。为了简明起见,这里省略了对已知方法的详细描述。在上述实施例中,描述和示出了若干具体的步骤作为示例。但是,本申请的方法过程并不限于所描述和示出的具体步骤,本领域的技术人员可以在领会本申请的精神后,作出各种改变、修改和添加,或者改变步骤之间的顺序。

以上所述的结构框图中所示的功能块可以实现为硬件、软件、固件或者它们的组合。当以硬件方式实现时,其可以例如是电子电路、专用集成电路(ASIC)、适当的固件、插件、功能卡等等。当以软件方式实现时,本申请的元素是被用于执行所需任务的程序或者代码段。程序或者代码段可以存储在机器可读介质中,或者通过载波中携带的数据信号在传输介质或者通信链路上传送。“机器可读介质”可以包括能够存储或传输信息的任何介质。机器可读介质的例子包括电子电路、半导体存储器设备、ROM、闪存、可擦除ROM(EROM)、软盘、CD-ROM、光盘、硬盘、光纤介质、射频(RF)链路,等等。代码段可以经由诸如因特网、内联网等的计算机网络被下载。

还需要说明的是,本申请中提及的示例性实施例,基于一系列的步骤或者装置描述一些方法或系统。但是,本申请不局限于上述步骤的顺序,也就是说,可以按照实施例中提及的顺序执行步骤,也可以不同于实施例中的顺序,或者若干步骤同时执行。

上面参考根据本申请的实施例的方法、装置(系统)和计算机程序产品的流程图和/或框图描述了本申请的各方面。应当理解,流程图和/或框图中的每个方框以及流程图和/或框图中各方框的组合可以由计算机程序指令实现。这些计算机程序指令可被提供给通用计算机、专用计算机、或其它可编程数据处理装置的处理器,以产生一种机器,使得经由计算机或其它可编程数据处理装置的处理器执行的这些指令使能对流程图和/或框图的一个或多个方框中指定的功能/动作的实现。这种处理器可以是但不限于是通用处理器、专用处理器、特殊应用处理器或者现场可编程逻辑电路。还可理解,框图和/或流程图中的每个方框以及框图和/或流程图中的方框的组合,也可以由执行指定的功能或动作的专用硬件来实现,或可由专用硬件和计算机指令的组合来实现。

以上所述,仅为本申请的具体实施方式,所属领域的技术人员可以清楚地了解到,为了描述的方便和简洁,上述描述的系统、模块和单元的具体工作过程,可以参考前述方法实施例中的对应过程,在此不再赘述。应理解,本申请的保护范围并不局限于此,任何熟悉本技术领域的技术人员在本申请揭露的技术范围内,可轻易想到各种等效的修改或替换,这些修改或替换都应涵盖在本申请的保护范围之内。

本文发布于:2024-09-23 22:36:06,感谢您对本站的认可!

本文链接:https://www.17tex.com/tex/1/87035.html

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,我们将在24小时内删除。

留言与评论(共有 0 条评论)
   
验证码:
Copyright ©2019-2024 Comsenz Inc.Powered by © 易纺专利技术学习网 豫ICP备2022007602号 豫公网安备41160202000603 站长QQ:729038198 关于我们 投诉建议