CN114092246A - 金融交易链路的问题定位方法及装置 - Google Patents
金融交易链路的问题定位方法及装置 Download PDFInfo
- Publication number
- CN114092246A CN114092246A CN202111404283.2A CN202111404283A CN114092246A CN 114092246 A CN114092246 A CN 114092246A CN 202111404283 A CN202111404283 A CN 202111404283A CN 114092246 A CN114092246 A CN 114092246A
- Authority
- CN
- China
- Prior art keywords
- transaction
- link
- serial number
- unique serial
- transaction link
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
- 238000000034 method Methods 0.000 title claims abstract description 98
- 230000008569 process Effects 0.000 claims description 44
- 238000004590 computer program Methods 0.000 claims description 27
- 238000012545 processing Methods 0.000 claims description 23
- 238000012546 transfer Methods 0.000 claims description 15
- 238000011144 upstream manufacturing Methods 0.000 claims description 15
- 238000003860 storage Methods 0.000 claims description 10
- 238000010276 construction Methods 0.000 claims description 6
- 230000002123 temporal effect Effects 0.000 claims description 2
- 238000013473 artificial intelligence Methods 0.000 abstract description 2
- 238000010586 diagram Methods 0.000 description 15
- 238000004458 analytical method Methods 0.000 description 9
- 238000005516 engineering process Methods 0.000 description 8
- 230000006870 function Effects 0.000 description 8
- 238000009826 distribution Methods 0.000 description 4
- 230000005540 biological transmission Effects 0.000 description 3
- 230000010365 information processing Effects 0.000 description 3
- 238000012423 maintenance Methods 0.000 description 3
- 238000013024 troubleshooting Methods 0.000 description 3
- 230000009286 beneficial effect Effects 0.000 description 2
- 238000009933 burial Methods 0.000 description 2
- 239000000969 carrier Substances 0.000 description 2
- 238000011161 development Methods 0.000 description 2
- 238000012384 transportation and delivery Methods 0.000 description 2
- 102100037362 Fibronectin Human genes 0.000 description 1
- 101001027128 Homo sapiens Fibronectin Proteins 0.000 description 1
- 230000004931 aggregating effect Effects 0.000 description 1
- 238000013459 approach Methods 0.000 description 1
- 238000007596 consolidation process Methods 0.000 description 1
- 230000007547 defect Effects 0.000 description 1
- 238000007689 inspection Methods 0.000 description 1
- 230000010354 integration Effects 0.000 description 1
- 238000007726 management method Methods 0.000 description 1
- 238000004519 manufacturing process Methods 0.000 description 1
- 239000000463 material Substances 0.000 description 1
- 230000007246 mechanism Effects 0.000 description 1
- 238000005065 mining Methods 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
- 238000002360 preparation method Methods 0.000 description 1
- 230000004044 response Effects 0.000 description 1
- 238000012163 sequencing technique Methods 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
- 238000012800 visualization Methods 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q40/00—Finance; Insurance; Tax strategies; Processing of corporate or income taxes
- G06Q40/04—Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F11/00—Error detection; Error correction; Monitoring
- G06F11/30—Monitoring
- G06F11/3065—Monitoring arrangements determined by the means or processing involved in reporting the monitored data
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/30—Information retrieval; Database structures therefor; File system structures therefor of unstructured textual data
- G06F16/36—Creation of semantic tools, e.g. ontology or thesauri
- G06F16/367—Ontology
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Business, Economics & Management (AREA)
- Physics & Mathematics (AREA)
- Finance (AREA)
- Accounting & Taxation (AREA)
- General Engineering & Computer Science (AREA)
- Quality & Reliability (AREA)
- Databases & Information Systems (AREA)
- Life Sciences & Earth Sciences (AREA)
- Data Mining & Analysis (AREA)
- Computational Linguistics (AREA)
- Animal Behavior & Ethology (AREA)
- Development Economics (AREA)
- Economics (AREA)
- Marketing (AREA)
- Strategic Management (AREA)
- Technology Law (AREA)
- General Business, Economics & Management (AREA)
- Financial Or Insurance-Related Operations Such As Payment And Settlement (AREA)
Abstract
本发明公开了一种金融交易链路的问题定位方法及装置，涉及人工智能技术领域，其中该方法包括：在每一业务系统按照如下方法处理交易请求：在交易进入当前业务系统时，判断交易中是否带有全局唯一序号；若不带有全局唯一序号，生成全局唯一序号；通过预先在交易链路中的关键路径处设置的交易记录日志埋点，获取交易在当前业务系统的关键路径处的交易状态信息；根据所有业务系统涉及交易链路中所有的交易状态信息，构造整个交易的实际交易链路；将实际交易链路与预先建立的金融交易链路知识图谱进行比对，根据比对结果定位交易链路的问题。本发明可以实现高效准确地定位复杂金融交易链路的问题。
Description
技术领域
本发明涉及人工智能技术领域，尤其涉及一种金融交易链路的问题定位方法及装置。
背景技术
本部分旨在为权利要求书中陈述的本发明实施例提供背景或上下文。此处的描述不因为包括在本部分中就承认是现有技术。
在一些大型金融科技公司中，因为职责划分细致，往往存在应用系统纷繁庞杂的现象。一笔业务交易从进入第一个业务系统开始处理，到在最后一个系统处理完成，往往需要横跨数个甚至数十个业务系统。在交易处理过程中，一旦其中一个业务系统处理故障，便会导致整个交易失败。而要进行故障排查，则需要交易链路上的全部关联业务系统共同排查，耗费巨大的人力物力财力。而随着微服务与容器技术的流行，以及流量增长带来的服务集群化，一个业务系统内部往往还会继续分割成数个微服务，每个微服务又会部署在数十台服务器组成的服务器集群中，问题排查更是难上加难。
发明内容
本发明实施例提供一种金融交易链路的问题定位方法，用以高效准确地定位复杂金融交易链路的问题，该方法包括：
接收金融交易请求；
在每一业务系统按照如下方法处理所述交易请求：在交易进入当前业务系统时，判断交易中是否带有全局唯一序号；若不带有全局唯一序号，生成全局唯一序号；所述全局唯一序号作为交易链路的唯一标识向后续业务系统中传递；通过预先在交易链路中的关键路径处设置的交易记录日志埋点，获取交易在当前业务系统的关键路径处的交易状态信息；
根据所有业务系统涉及交易链路中所有的交易状态信息，构造整个交易的实际交易链路；
将所述实际交易链路与预先建立的金融交易链路知识图谱进行比对，根据比对结果定位交易链路的问题；所述金融交易链路知识图谱基于业务系统的上下游关系、业务流程的先后执行关系及业务流程涉及的业务要素预先建立。
本发明实施例还提供一种金融交易链路的问题定位装置，用以高效准确地定位复杂金融交易链路的问题，该装置包括：
接收单元，用于接收金融交易请求；
处理单元，用于在每一业务系统按照如下方法处理所述交易请求：在交易进入当前业务系统时，判断交易中是否带有全局唯一序号；若不带有全局唯一序号，生成全局唯一序号；所述全局唯一序号作为交易链路的唯一标识向后续业务系统中传递；通过预先在交易链路中的关键路径处设置的交易记录日志埋点，获取交易在当前业务系统的关键路径处的交易状态信息；
构造单元，用于根据所有业务系统涉及交易链路中所有的交易状态信息，构造整个交易的实际交易链路；
定位单元，用于将所述实际交易链路与预先建立的金融交易链路知识图谱进行比对，根据比对结果定位交易链路的问题；所述金融交易链路知识图谱基于业务系统的上下游关系、业务流程的先后执行关系及业务流程涉及的业务要素预先建立。
本发明实施例还提供一种计算机设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，所述处理器执行所述计算机程序时实现上述金融交易链路的问题定位方法。
本发明实施例还提供一种计算机可读存储介质，所述计算机可读存储介质存储有计算机程序，所述计算机程序被处理器执行时实现上述金融交易链路的问题定位方法。
本发明实施例还提供一种计算机程序产品，所述计算机程序产品包括计算机程序，所述计算机程序被处理器执行时实现上述金融交易链路的问题定位方法。
本发明实施例中，金融交易链路的问题定位方案，与现有技术中需要很多人为参与定位金融交易链路的问题，效率和准确率都低的技术方案相比，通过：接收金融交易请求；在每一业务系统按照如下方法处理所述交易请求：在交易进入当前业务系统时，判断交易中是否带有全局唯一序号；若不带有全局唯一序号，生成全局唯一序号；所述全局唯一序号作为交易链路的唯一标识向后续业务系统中传递；通过预先在交易链路中的关键路径处设置的交易记录日志埋点，获取交易在当前业务系统的关键路径处的交易状态信息；根据所有业务系统涉及交易链路中所有的交易状态信息，构造整个交易的实际交易链路；将所述实际交易链路与预先建立的金融交易链路知识图谱进行比对，根据比对结果定位交易链路的问题；所述金融交易链路知识图谱基于业务系统的上下游关系、业务流程的先后执行关系及业务流程涉及的业务要素预先建立，可以实现高效准确地定位复杂金融交易链路的问题。
附图说明
为了更清楚地说明本发明实施例或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。在附图中：
图1为本发明实施例中金融交易链路的问题定位方法的流程示意图；
图2为本发明另一实施例中金融交易链路的问题定位方法的流程示意图；
图3为本发明另一实施例中金融交易链路的问题定位方法的流程示意图；
图4为本发明实施例中金融交易链路知识图谱的示意图；
图5为本发明实施例中金融交易链路的问题定位的原理示意图；
图6为本发明实施例中金融交易链路的问题定位装置的结构示意图；
图7为本发明另一实施例中金融交易链路的问题定位装置的结构示意图；
图8为本发明另一实施例中金融交易链路的问题定位装置的结构示意图；
图9为本发明实施例中以图表的形式展现状态信息的示意图。
具体实施方式
为使本发明实施例的目的、技术方案和优点更加清楚明白，下面结合附图对本发明实施例做进一步详细说明。在此，本发明的示意性实施例及其说明用于解释本发明，但并不作为对本发明的限定。
知识图谱(Knowledge Graph)，在图书情报界称为知识域可视化或知识领域映射地图，是显示知识发展进程与结构关系的一系列各种不同的图形，用可视化技术描述知识资源及其载体，挖掘、分析、构建、绘制和显示知识及它们之间的相互联系。
在业界应用中，基于日志埋点和日志归集整理的分布式链路追踪技术已经存在。常见的链路追踪技术方法主要包括如下模块：1)Collector模块接收或收集各应用传输的数据；2)Storage模块存储接收或收集过来的数据；3)API(Query)负责查询Storage中存储的数据，提供简单的JSON API获取数据；4)Web模块提供Web UI界面供用户查询查看。
现有链路追踪方案的主要侧重点有二：其一，通过收集各个业务系统的交易数据，获得实时的交易统计信息，比如当前交易量、系统响应时间、交易正常率等统计指标，主要侧重于宏观统计信息的搜集展现；其二，通过构建一个统一的分布式日志管理平台，避免了交易日志分散在各个业务系统、无法集中管理的问题，主要侧重于交易日志的归集划一。
一些分布式交易链路追踪方案提出了日志埋点的概念，但是究其根本，还是为了通过关键词实现日志信息的快速检索，主要目的还是为了检索方便。
纵观上述方案，或是为了获取宏观指标，或是为了日志检索便利，但都缺少了针对特定交易更进一步的高阶分析。要进行高阶分析，就势必需要结合交易所在的业务场景和业务逻辑进行分析。对于目前现有方案，对交易链路高阶分析的关注是不足的。比如一笔交易发生错误，传统方案至多只是把这笔交易关联的日志信息检索出来，但至于问题发生在哪里，是什么原因导致的，仍然需要人工进行问题定位。
本发明实施例正是基于上述不足提出一种金融交易链路的问题定位方案，该方案通过基于知识图谱技术对金融业务进行高阶建模，实现了对交易状态信息以及整个交易链路的高阶分析，进而实现了复杂金融交易链路下问题的快速定位。下面对该金融交易链路的问题定位方案进行详细介绍。
图1为本发明实施例中金融交易链路的问题定位方法的流程示意图，如图1所示，该方法包括如下步骤：
步骤101：接收金融交易请求；
步骤102：在每一业务系统按照如下方法处理所述交易请求：在交易进入当前业务系统时，判断交易中是否带有全局唯一序号；若不带有全局唯一序号，生成全局唯一序号；所述全局唯一序号作为交易链路的唯一标识向后续业务系统中传递；通过预先在交易链路中的关键路径处设置的交易记录日志埋点，获取交易在当前业务系统的关键路径处的交易状态信息；
步骤103：根据所有业务系统涉及交易链路中所有的交易状态信息，构造整个交易的实际交易链路；
步骤104：将所述实际交易链路与预先建立的金融交易链路知识图谱进行比对，根据比对结果定位交易链路的问题；所述金融交易链路知识图谱基于业务系统的上下游关系、业务流程的先后执行关系及业务流程涉及的业务要素预先建立。
本发明实施例提供的金融交易链路的问题定位方法，工作时：接收金融交易请求；在每一业务系统按照如下方法处理所述交易请求：在交易进入当前业务系统时，判断交易中是否带有全局唯一序号；若不带有全局唯一序号，生成全局唯一序号；所述全局唯一序号作为交易链路的唯一标识向后续业务系统中传递；通过预先在交易链路中的关键路径处设置的交易记录日志埋点，获取交易在当前业务系统的关键路径处的交易状态信息；根据所有业务系统涉及交易链路中所有的交易状态信息，构造整个交易的实际交易链路；将所述实际交易链路与预先建立的金融交易链路知识图谱进行比对，根据比对结果定位交易链路的问题；所述金融交易链路知识图谱根据基于业务系统的上下游关系、业务流程的先后执行关系及业务流程涉及的业务要素预先建立，可以实现高效准确地定位复杂金融交易链路的问题。下面结合图2至图5进行详细介绍。
在一个实施例中，如图5所示，上述金融交易链路的问题定位方法还可以包括：在判断交易中带有全局唯一序号时，将所述全局唯一序号向后续业务系统传递。
具体实施时，全局唯一序号作为贯穿整个交易链路的唯一标识，然后在后续业务系统中传递该唯一标识，便于贯穿整个交易链路，构造实际交易链路，进一步提高了金融交易链路问题定位的效率和准确率。
在一个实施例中，在判断交易中带有全局唯一序号时，将所述全局唯一序号向后续业务系统传递，可以包括：在判断交易中带有全局唯一序号时，通过表述性状态传递REST协议和Dubbo协议将所述全局唯一序号向后续业务系统传递。
在一个实施例中，在REST协议中，全局唯一序号可以通过HTTP首部Http Header进行传递；在Dubbo协议中，可以通过临时状态记录器RpcContext进行传递。
具体实施时，在跨交易系统调用方面，为了支持全局唯一序号的系统间传递，本发明支持REST和Dubbo两种协议。在REST协议中，全局唯一序号通过Http Header进行传递；在Dubbo协议中，通过RpcContext进行传递。
在一个实施例中，如图2所示，上述金融交易链路的问题定位方法还可以包括步骤105：将所有的交易状态信息以图表的形式展现。
具体实施时，便于用户直观地了解交易状态信息，进一步提高了金融交易链路问题定位的效率和准确率。
在一个实施例中，如图3所示，上述金融交易链路的问题定位方法还可以包括步骤106：以表述性状态传递接口REST API的形式将结构化的交易状态信息返回给第三方调用系统。
具体实施时，将状态信息以REST API的形式将结构化数据形式(JSON)返回给第三方调用系统功能，以便于构建更强大的生态系统，方便第三方系统的集成与扩展。
为了便于理解本发明如何实施，下面进行整体介绍。
本发明实施例通过基于业务系统的上下游关系、业务流程的先后执行关系、特定业务流程涉及的业务要素等构建金融交易链路知识图谱。将金融交易链路知识图谱应用于交易链路上的状态信息，以实现复杂金融交易链路下问题的快速定位。该方法包括如下步骤。
1)基于业务系统的上下游关系、业务流程的先后执行关系、特定业务流程涉及的业务要素等构建金融交易链路知识图谱，并将知识图谱应用于问题定位。注：该步骤是最核心的流程步骤。
2)为了进行交易唯一性定位，在第一个业务系统处生成全局唯一序号，并在后续系统间进行传递；
3)在交易链路中的关键路径处进行交易记录日志埋点，记录交易在关键路径处的状态信息。
4)将交易链路中所有的交易状态信息通过消息队列进行归集处理，以构造整个交易的实际交易链路。
5)将实际交易链路与金融交易链路知识图谱进行比对，快速发现问题。比如在金融交易链路知识图谱中，融资交易包括信息录入、信息检查、报文传输、融资发放四个步骤。其中融资发放的业务流程匹配规则为“[IGTBNET][FINC.INPUT]”，将该匹配规则作为特征字符，与该笔交易对应的所有交易状态信息逐条进行匹配，如果某条交易状态信息中含有该特征字符，则说明该条交易状态信息命中该规则，然后从该条交易状态信息中读取该条交易的执行状态(是否执行成功)，作为当前步骤是否执行成功的标志。后续步骤同理。如果所有步骤均执行成功，则说明说明交易没有问题；否则，则说明执行过程中存在问题。如果存在问题，则通过判断哪一各步骤没有执行成功，可以快速发现定位问题。
为了便于理解本发明如何实施，下面再结合图4和图5举一例子详细说明。
针对复杂交易链路下故障难以追踪排查的问题，本发明提出了一种金融交易链路的问题定位方法，该方法为一种基于知识图谱技术的复杂金融交易链路追踪方法，实现了复杂金融交易链路下故障问题的快速排查和快速定位。该方法包括如下步骤。
1)预先构建知识图谱的步骤：从整体的业务场景和业务流程出发，用知识图谱的形式对业务流程进行建模，包括但不限于业务系统的上下游关系、业务流程的先后执行关系、特定业务流程关注的业务要素、知识图谱节点与交易状态信息的匹配规则等信息，即结合具体业务场景和业务流程，用知识图谱的形式对业务流程进行建模，即用知识图谱的形式对业务流程进行建模，并将构建好的知识图谱存储到知识图谱构建及维护模块。构建的知识图谱结构示例如图4所示。本发明其他的准备步骤还可以包括：业务价值分析，梳理交易链路中的关键路径。
该步骤1)可以通过一个知识图谱构建及维护模块来实现，该模块根据整体的业务场景和业务流程，用知识图谱的形式对业务流程进行建模，包括但不限于业务系统的上下游关系、业务流程的先后执行关系、特定业务流程涉及的业务要素、知识图谱节点与交易状态信息的匹配规则等信息。
2)本发明实施例使用一个全局唯一序号作为贯穿整个交易链路的唯一标识。为了达到全局唯一序号在所有业务系统中传递的目的，需对交易系统进行一定改造。
该步骤2)可以通过一个全局唯一序号生成及中转模块来实现，该模型(金融交易链路知识图谱)实现当一笔融资交易进入第一个业务系统(IGTBNET)后，该业务系统为该笔交易生成全局唯一序号，然后将该序号向后续业务系统传递；对于后续业务系统，如果检测到全局唯一序号已生成，则将该序号向后续业务系统进行传递，例如当发生系统间调用时(比如IGTNET调用SCFS)，上游系统(IGTBNET)把该全局唯一序号作为参数传递给下游系统(SCFS)，下游系统不再重新生成全局唯一序号，而是使用传递过来的全局唯一序号作为当前交易的全局唯一序号。即当一笔交易进入第一个业务系统，全局唯一序号生成及中转模块生成一个全局唯一序号作为贯穿整个交易链路的唯一标识，然后在后续业务系统中传递该唯一标识。
在全局序号生成器的选择方面，本发明实施例采用UUID机制实现。
在跨交易系统(业务系统)调用方面，为了支持全局唯一序号的业务系统间传递，本发明实施例支持REST和Dubbo两种协议。在REST协议中，全局唯一序号通过Http Header进行传递；在Dubbo协议中，通过RpcContext进行传递。
另外，关于后续业务系统：即被第一个系统调用的系统，以及相关联被调用的系统，比如A调用了B和C系统，C调用了D和E，E调用了F，F调用了G，则B、C、D、E、F、G均属于A系统的后续业务系统。
另外，关于传递的含义：假设第一个系统为A，在A系统中生成全局唯一序号，在A调用B和C系统，C调用D和E，E调用F，F调用G时，B、C、D、E、F、G均不再重新生成全局唯一序号，而是采用A系统生成的全局唯一序号作为当前交易的全局唯一序号。为了保证全局唯一序号能够在A到G所有系统间保持一致，故需在进行系统调用时“传递”。
具体实施时，以融资交易为例，需要经过信息录入、信息检查、报文传输、融资发放等四步，经过的业务系统包括IGTBNET(信息录入)、SCFS(信息检查)、MCIS(报文传输)、BANCS(融资发放)四个系统，如图4所示的归属系统。其中IGTBNET为第一个业务系统，SCFS、MCIS、BANCS为后续业务系统。
3)在各个业务系统交易链路的关键路径处进行预先交易记录日志埋点，记录交易在关键路径处的交易状态信息、涉及的业务要素、执行时间等关键要素信息。
在交易记录日志埋点方面，本发明实施例可以采用SLF4J+LOGBACK实现，记录格式如下表1所示：
表1
以中括号作为分隔符，其中第一部分为交易发生时间，第二部分为全局唯一序号，第三部分为所在业务系统标识，第四部分为业务流程名称，第五部分为交易执行状态，最后一部分为涉及的业务要素。
在消息队列选型方面，本发明实施例可以选用Kafka作为消息队列中间件，以提供更好的数据吞吐量。
另外，本发明实施例中提到的状态信息可以包括：执行时间；执行该交易消耗的时间；执行结果(成功、失败、未明)；调用该交易的传入参数；调用该交易后的执行结果；调用该交易后的错误信息(如果执行失败的话)。
4)将交易链路中所有的交易状态信息通过消息队列进行归集处理，以便构造整个交易的完整交易链路，即将日志埋点数据通过消息队列归集到同一处，从而方便后续处理。
该步骤3)和步骤4)可以通过一个交易状态信息收集模块来实现，该模块功能主要有两个：第一，在交易链路中的关键路径处进行交易记录日志埋点时，该模块负责记录交易在关键路径处的状态信息；第二，将记录的状态信息通过消息队列发送给交易状态信息处理模块。即交易状态信息收集模块在交易链路中的关键路径处进行交易记录日志埋点，记录交易在关键路径处的状态信息，并将所有的交易状态信息通过消息队列进行归集处理。
另外，本发明实施例中提到的需要关注的业务要素可以包括：比如进行融资交易时，融资编号、融资人、融资币别、融资金额、融资入账账号均属于“需要关注的业务要素”；再比如在进行转账交易时，交易流水号、付款人、收款人、币别、金额均属于“需要关注的业务要素”。
另外，本发明实施例中提到的相关值可以是：即关注的业务要素在交易中的实际发生值，比如融资交易，关注的业务要素为“融资金额”，实际融资交易的融资金额为1000万，则1000万为“相关值”。
5)将归集的交易链路状态信息与知识图谱中的相应节点进行匹配，匹配方式：将日志中的业务系统标识、业务流程名称作为匹配条件，与知识图谱中的所在系统和业务流程匹配规则进行匹配，即可得到一笔交易数据在全局交易链路中的状态信息，以及交易结束位置在全局链路中所处的位置。
该步骤5)可以通过一个交易状态信息处理模块来实现。该模块从消息队列读取所有的交易状态信息，根据交易记录格式对交易状态信息进行反解析，得到交易发生时间、全局唯一序号、所在业务系统标识、业务流程名称、交易执行状态、涉及业务要素等信息；从知识图谱构建及维护模块读取构建好的知识图谱，根据知识图谱中的业务流程匹配规则逐条对交易状态信息进行匹配；匹配后，再从知识图谱中获取需要关注的业务要素，从交易状态信息的涉及业务要素字段中抽取出需要关注的业务要素相关值；而后将交易发生时间、全局唯一序号、所在业务系统标识、业务流程名称、交易执行状态、关注业务要素等信息存储到数据库。即交易状态信息处理模块对交易状态信息进行匹配和结构化处理，而后持久化到数据库。
另外，本发明实施例中提到的实际交易链路与完整交易链路的关系示例：实际交易链路与完整交易链路是否完全一致；实际交易链路在完整交易链路中，哪些交易执行成功了，哪些执行失败，哪些没有被执行。
另外，本发明实施例还可以包括一个交易状态信息分析模块，该模块的功能主要有四个：第一，从知识图谱构建及维护模块拉取构建好的知识图谱；第二，根据全局唯一序号从数据库读取结构化后的交易状态信息，按照交易序号进行排序，构建一笔交易的实际交易链路；第三，将实际交易链路信息代入知识图谱，得到该笔交易在完整交易链路中的定位，并将实际交易链路与完整交易链路的关系转储为结构化数据；第四，将结构化后的数据返回给交易状态信息查询及展示模块。即交易状态信息分析模块构造一笔交易的实际交易链路，实际交易链路与知识图谱中的相应节点进行匹配，即可得到该笔交易数据在完整交易链路中的状态信息，以及交易结束位置在完整交易链路中所处的位置。
6)将状态信息以图表的形式展现，展示图表如图9所示，或者以REST API的形式将结构化数据形式(JSON)返回给第三方调用系统。
该步骤6)可以通过一个交易状态信息查询及展示模块来实现，该模块根据用户输入的查询条件，从交易状态信息分析模块读取结构化数据，然后使用图表的形式展现给用户，或者以REST API的形式将结构化数据形式(JSON)返回给第三方调用系统。即交易状态信息查询及展示模块将状态信息以图表的形式展现，或者以REST API的形式将结构化数据形式(JSON)返回给第三方调用系统。
另外，本发明实施例中提到的第三方调用系统为：基于本发明进行二次开发的系统，通过调用本系统获得数据，再对数据进行加工、处理、展现等操作的系统。
本发明实施例提供的金融交易链路的问题定位方法解决了金融科技公司在面对复杂金融交易链路场景时，问题排查需要统筹链路上下游系统共同排查的窘境，有助于提高金融科技公司在复杂金融交易链路下问题的发现与解决效率，有助于提高企业的运营能力，对外树立能力强大、效率高效的良好企业形象。
本发明实施例中还提供了一种金融交易链路的问题定位装置，如下面的实施例所述。由于该装置解决问题的原理与金融交易链路的问题定位方法相似，因此该装置的实施可以参见金融交易链路的问题定位方法的实施，重复之处不再赘述。
图6为本发明实施例中金融交易链路的问题定位装置的结构示意图，如图6所示，该装置包括：
接收单元01，用于接收金融交易请求；
处理单元02，用于在每一业务系统按照如下方法处理所述交易请求：在交易进入当前业务系统时，判断交易中是否带有全局唯一序号；若不带有全局唯一序号，生成全局唯一序号；所述全局唯一序号作为交易链路的唯一标识向后续业务系统中传递；通过预先在交易链路中的关键路径处设置的交易记录日志埋点，获取交易在当前业务系统的关键路径处的交易状态信息；
构造单元03，用于根据所有业务系统涉及交易链路中所有的交易状态信息，构造整个交易的实际交易链路；
定位单元04，用于将所述实际交易链路与预先建立的金融交易链路知识图谱进行比对，根据比对结果定位交易链路的问题；所述金融交易链路知识图谱根据基于业务系统的上下游关系、业务流程的先后执行关系及业务流程涉及的业务要素预先建立。
在一个实施例中，所述处理单元还用于：在判断交易中带有全局唯一序号时，将所述全局唯一序号向后续业务系统传递。
在一个实施例中，如图7所示，上述金融交易链路的问题定位装置还可以包括：展示单元05，用于将所有的交易状态信息以图表的形式展现。
在一个实施例中，如图8所示，上述金融交易链路的问题定位装置还可以包括：反馈单元06，用于以表述性状态传递接口REST API的形式将结构化的交易状态信息返回给第三方调用系统。
本申请技术方案中对数据的获取、存储、使用、处理等均符合国家法律法规的相关规定。
本发明实施例还提供一种计算机设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，所述处理器执行所述计算机程序时实现上述金融交易链路的问题定位方法。
本发明实施例还提供一种计算机可读存储介质，所述计算机可读存储介质存储有计算机程序，所述计算机程序被处理器执行时实现上述金融交易链路的问题定位方法。
本发明实施例还提供一种计算机程序产品，所述计算机程序产品包括计算机程序，所述计算机程序被处理器执行时实现上述金融交易链路的问题定位方法。
本发明实施例中，金融交易链路的问题定位方案，与现有技术中需要很多人为参与定位金融交易链路的问题，效率和准确率都低的技术方案相比，通过：接收金融交易请求；在每一业务系统按照如下方法处理所述交易请求：在交易进入当前业务系统时，判断交易中是否带有全局唯一序号；若不带有全局唯一序号，生成全局唯一序号；所述全局唯一序号作为交易链路的唯一标识向后续业务系统中传递；通过预先在交易链路中的关键路径处设置的交易记录日志埋点，获取交易在当前业务系统的关键路径处的交易状态信息；根据所有业务系统涉及交易链路中所有的交易状态信息，构造整个交易的实际交易链路；将所述实际交易链路与预先建立的金融交易链路知识图谱进行比对，根据比对结果定位交易链路的问题；所述金融交易链路知识图谱根据基于业务系统的上下游关系、业务流程的先后执行关系及业务流程涉及的业务要素预先建立，可以实现高效准确地定位复杂金融交易链路的问题。
本领域内的技术人员应明白，本发明的实施例可提供为方法、系统、或计算机程序产品。因此，本发明可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且，本发明可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。
本发明是参照根据本发明实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器，使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。
这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中，使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品，该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。
这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上，使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理，从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。
以上所述的具体实施例，对本发明的目的、技术方案和有益效果进行了进一步详细说明，所应理解的是，以上所述仅为本发明的具体实施例而已，并不用于限定本发明的保护范围，凡在本发明的精神和原则之内，所做的任何修改、等同替换、改进等，均应包含在本发明的保护范围之内。
Claims (13)
1.一种金融交易链路的问题定位方法，其特征在于，包括：
接收金融交易请求；
在每一业务系统按照如下方法处理所述交易请求：在交易进入当前业务系统时，判断交易中是否带有全局唯一序号；若不带有全局唯一序号，生成全局唯一序号；所述全局唯一序号作为交易链路的唯一标识向后续业务系统中传递；通过预先在交易链路中的关键路径处设置的交易记录日志埋点，获取交易在当前业务系统的关键路径处的交易状态信息；
根据所有业务系统涉及交易链路中所有的交易状态信息，构造整个交易的实际交易链路；
将所述实际交易链路与预先建立的金融交易链路知识图谱进行比对，根据比对结果定位交易链路的问题；所述金融交易链路知识图谱基于业务系统的上下游关系、业务流程的先后执行关系及业务流程涉及的业务要素预先建立。
2.如权利要求1所述的金融交易链路的问题定位方法，其特征在于，还包括：在判断交易中带有全局唯一序号时，将所述全局唯一序号向后续业务系统传递。
3.如权利要求2所述的金融交易链路的问题定位方法，其特征在于，在判断交易中带有全局唯一序号时，将所述全局唯一序号向后续业务系统传递，包括：在判断交易中带有全局唯一序号时，通过表述性状态传递REST协议和Dubbo协议将所述全局唯一序号向后续业务系统传递。
4.如权利要求3所述的金融交易链路的问题定位方法，其特征在于，在REST协议中，全局唯一序号通过HTTP首部Http Header进行传递；在Dubbo协议中，通过临时状态记录器RpcContext进行传递。
5.如权利要求1所述的金融交易链路的问题定位方法，其特征在于，还包括：将所有的交易状态信息以图表的形式展现。
6.如权利要求1所述的金融交易链路的问题定位方法，其特征在于，还包括：以表述性状态传递接口REST API的形式将结构化的交易状态信息返回给第三方调用系统。
7.一种金融交易链路的问题定位装置，其特征在于，包括：
接收单元，用于接收金融交易请求；
处理单元，用于在每一业务系统按照如下方法处理所述交易请求：在交易进入当前业务系统时，判断交易中是否带有全局唯一序号；若不带有全局唯一序号，生成全局唯一序号；所述全局唯一序号作为交易链路的唯一标识向后续业务系统中传递；通过预先在交易链路中的关键路径处设置的交易记录日志埋点，获取交易在当前业务系统的关键路径处的交易状态信息；
构造单元，用于根据所有业务系统涉及交易链路中所有的交易状态信息，构造整个交易的实际交易链路；
定位单元，用于将所述实际交易链路与预先建立的金融交易链路知识图谱进行比对，根据比对结果定位交易链路的问题；所述金融交易链路知识图谱基于业务系统的上下游关系、业务流程的先后执行关系及业务流程涉及的业务要素预先建立。
8.如权利要求7所述的金融交易链路的问题定位装置，其特征在于，所述处理单元还用于：在判断交易中带有全局唯一序号时，将所述全局唯一序号向后续业务系统传递。
9.如权利要求7所述的金融交易链路的问题定位装置，其特征在于，还包括：展示单元，用于将所有的交易状态信息以图表的形式展现。
10.如权利要求7所述的金融交易链路的问题定位装置，其特征在于，还包括：反馈单元，用于以表述性状态传递接口REST API的形式将结构化的交易状态信息返回给第三方调用系统。
11.一种计算机设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，其特征在于，所述处理器执行所述计算机程序时实现权利要求1至6任一所述方法。
12.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质存储有计算机程序，所述计算机程序被处理器执行时实现权利要求1至6任一所述方法。
13.一种计算机程序产品，其特征在于，所述计算机程序产品包括计算机程序，所述计算机程序被处理器执行时实现权利要求1至6任一所述方法。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111404283.2A CN114092246A (zh) | 2021-11-24 | 2021-11-24 | 金融交易链路的问题定位方法及装置 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111404283.2A CN114092246A (zh) | 2021-11-24 | 2021-11-24 | 金融交易链路的问题定位方法及装置 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN114092246A true CN114092246A (zh) | 2022-02-25 |
Family
ID=80304215
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202111404283.2A Pending CN114092246A (zh) | 2021-11-24 | 2021-11-24 | 金融交易链路的问题定位方法及装置 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN114092246A (zh) |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114691732A (zh) * | 2022-03-09 | 2022-07-01 | 中国邮政储蓄银行股份有限公司 | 定位异常交易的方法、装置、非易失性存储介质与处理器 |
| CN115984002A (zh) * | 2023-02-22 | 2023-04-18 | 上海信宝博通电子商务有限公司 | 用于车辆交易管理的数据处理方法和装置 |
Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110287053A (zh) * | 2019-06-27 | 2019-09-27 | 四川新网银行股份有限公司 | 分布式系统异常统一处理的方法 |
| CN112087320A (zh) * | 2020-08-16 | 2020-12-15 | 中信百信银行股份有限公司 | 一种异常定位方法、装置、电子设备和可读存储介质 |
| CN112256530A (zh) * | 2020-10-27 | 2021-01-22 | 广州助蜂网络科技有限公司 | 一种可链路追踪的日志服务方法及其系统 |
| CN112422335A (zh) * | 2020-11-10 | 2021-02-26 | 普元信息技术股份有限公司 | 技术中台中基于微服务架构实现业务链路分析的方法、系统、装置及存储介质 |
| CN112486786A (zh) * | 2020-11-12 | 2021-03-12 | 贝壳技术有限公司 | 一种调用链路追踪方法及装置 |
| CN112565194A (zh) * | 2020-11-09 | 2021-03-26 | 广东华兴银行股份有限公司 | 一种交易链路跟踪方法、电子设备及存储介质 |
-
2021
- 2021-11-24 CN CN202111404283.2A patent/CN114092246A/zh active Pending
Patent Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN110287053A (zh) * | 2019-06-27 | 2019-09-27 | 四川新网银行股份有限公司 | 分布式系统异常统一处理的方法 |
| CN112087320A (zh) * | 2020-08-16 | 2020-12-15 | 中信百信银行股份有限公司 | 一种异常定位方法、装置、电子设备和可读存储介质 |
| CN112256530A (zh) * | 2020-10-27 | 2021-01-22 | 广州助蜂网络科技有限公司 | 一种可链路追踪的日志服务方法及其系统 |
| CN112565194A (zh) * | 2020-11-09 | 2021-03-26 | 广东华兴银行股份有限公司 | 一种交易链路跟踪方法、电子设备及存储介质 |
| CN112422335A (zh) * | 2020-11-10 | 2021-02-26 | 普元信息技术股份有限公司 | 技术中台中基于微服务架构实现业务链路分析的方法、系统、装置及存储介质 |
| CN112486786A (zh) * | 2020-11-12 | 2021-03-12 | 贝壳技术有限公司 | 一种调用链路追踪方法及装置 |
Cited By (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114691732A (zh) * | 2022-03-09 | 2022-07-01 | 中国邮政储蓄银行股份有限公司 | 定位异常交易的方法、装置、非易失性存储介质与处理器 |
| CN115984002A (zh) * | 2023-02-22 | 2023-04-18 | 上海信宝博通电子商务有限公司 | 用于车辆交易管理的数据处理方法和装置 |
| CN115984002B (zh) * | 2023-02-22 | 2024-01-16 | 上海信宝博通电子商务有限公司 | 用于车辆交易管理的数据处理方法和装置 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111752799B (zh) | 一种业务链路跟踪方法、装置、设备及储存介质 | |
| CN110149361B (zh) | 一种互联网业务操作过程回溯方法、系统以及装置 | |
| US7689455B2 (en) | Analyzing and detecting anomalies in data records using artificial intelligence | |
| CN112035191B (zh) | 基于微服务的apm全链路监控系统及方法 | |
| CN111061696B (zh) | 一种交易报文日志的解析方法及装置 | |
| CN111552509B (zh) | 一种接口间依赖关系的确定方法及装置 | |
| KR102325258B1 (ko) | 원격통신 네트워크의 네트워크 성능에 관한 자율적 또는 ai-보조적 유효성 검증 또는 결정 수행을 행하고 그리고/또는 원격통신 네트워크 내에서 자율적 또는 ai-보조적 장애해결 또는 성능 증진을 행하기 위한 방법, 원격통신 네트워크, 시스템, 머신 지능 엔티티, 시각화 인터페이스, 컴퓨터 프로그램 그리고 컴퓨터-판독가능 매체 | |
| CN114092246A (zh) | 金融交易链路的问题定位方法及装置 | |
| CN112711496A (zh) | 日志信息全链路追踪方法、装置、计算机设备和存储介质 | |
| CN114745295A (zh) | 数据采集方法、装置、设备和可读存储介质 | |
| CN105868956A (zh) | 一种数据处理方法及装置 | |
| CN109409948B (zh) | 交易异常检测方法、装置、设备及计算机可读存储介质 | |
| CN111913824B (zh) | 确定数据链路故障原因的方法及相关设备 | |
| CN112416557B (zh) | 调用关系的确定方法和装置、存储介质及电子装置 | |
| CN113688012A (zh) | 调用链监控系统及方法 | |
| WO2024149107A1 (zh) | 一种软件日志处理方法 | |
| CN113411209A (zh) | 一种分布式的密码服务全链路检测系统及方法 | |
| CN116361137A (zh) | 业务调用链追踪方法、装置、电子设备和可读存储介质 | |
| Bosch et al. | Towards automated detection of data pipeline faults | |
| CN114281549A (zh) | 数据的处理方法及装置 | |
| CN117312101B (zh) | 结构日志的确定方法及装置、存储介质、电子设备 | |
| CN114819981A (zh) | 客服问题处理方法、装置、设备以及存储介质 | |
| CN112685252A (zh) | 微服务监控方法、装置、设备和存储介质 | |
| CN114679487B (zh) | 链路处理方法、装置、存储介质、处理器 | |
| CN111045953A (zh) | 一种基于分布式的测试用例执行系统及方法 |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination |