CN115049493A - 一种区块链数据追踪方法、装置及电子设备 - Google Patents
一种区块链数据追踪方法、装置及电子设备 Download PDFInfo
- Publication number
- CN115049493A CN115049493A CN202210776279.7A CN202210776279A CN115049493A CN 115049493 A CN115049493 A CN 115049493A CN 202210776279 A CN202210776279 A CN 202210776279A CN 115049493 A CN115049493 A CN 115049493A
- Authority
- CN
- China
- Prior art keywords
- target
- node
- data
- nodes
- addresses
- 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 58
- 238000013499 data model Methods 0.000 claims abstract description 58
- 230000015654 memory Effects 0.000 claims description 18
- 230000008569 process Effects 0.000 claims description 11
- 230000004044 response Effects 0.000 claims description 4
- 238000004590 computer program Methods 0.000 claims description 3
- 238000004422 calculation algorithm Methods 0.000 description 8
- 238000010586 diagram Methods 0.000 description 3
- 238000012986 modification Methods 0.000 description 2
- 230000004048 modification Effects 0.000 description 2
- 238000012545 processing Methods 0.000 description 2
- 239000007787 solid Substances 0.000 description 2
- 238000003491 array Methods 0.000 description 1
- 238000004364 calculation method Methods 0.000 description 1
- 238000010276 construction Methods 0.000 description 1
- 230000007547 defect Effects 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 230000006870 function Effects 0.000 description 1
- 238000010295 mobile communication Methods 0.000 description 1
- 238000012544 monitoring process Methods 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
- 230000001105 regulatory effect Effects 0.000 description 1
- 238000012216 screening Methods 0.000 description 1
- 238000012546 transfer 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
- 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
- G06Q10/00—Administration; Management
- G06Q10/06—Resources, workflows, human or project management; Enterprise or organisation planning; Enterprise or organisation modelling
- G06Q10/063—Operations research, analysis or management
- G06Q10/0631—Resource planning, allocation, distributing or scheduling for enterprises or organisations
- G06Q10/06311—Scheduling, planning or task assignment for a person or group
- G06Q10/063114—Status monitoring or status determination for a person or group
-
- G—PHYSICS
- G16—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR SPECIFIC APPLICATION FIELDS
- G16Y—INFORMATION AND COMMUNICATION TECHNOLOGY SPECIALLY ADAPTED FOR THE INTERNET OF THINGS [IoT]
- G16Y40/00—IoT characterised by the purpose of the information processing
- G16Y40/10—Detection; Monitoring
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
- H04L67/104—Peer-to-peer [P2P] networks
Landscapes
- Business, Economics & Management (AREA)
- Engineering & Computer Science (AREA)
- Human Resources & Organizations (AREA)
- Economics (AREA)
- Strategic Management (AREA)
- General Business, Economics & Management (AREA)
- Theoretical Computer Science (AREA)
- Finance (AREA)
- Marketing (AREA)
- Accounting & Taxation (AREA)
- Development Economics (AREA)
- Physics & Mathematics (AREA)
- Entrepreneurship & Innovation (AREA)
- General Physics & Mathematics (AREA)
- Technology Law (AREA)
- Computer Networks & Wireless Communication (AREA)
- Educational Administration (AREA)
- Signal Processing (AREA)
- Game Theory and Decision Science (AREA)
- Operations Research (AREA)
- Quality & Reliability (AREA)
- Tourism & Hospitality (AREA)
- Computing Systems (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
本发明公开了一种区块链数据追踪方法、装置及电子设备，包括：对区块链中包含的地址以及地址间的交易数据进行遍历操作；将遍历到的区块链的地址作为图模型的节点，将任意两个节点对应的地址间的交易数据的流转方向作为图模型的有向边构建得到图数据模型；对图数据模型中的节点以及有向边进行属性数据配置操作；在图数据模型中确定问题地址对应的目标节点，从目标节点开始根据图数据模型的有向边确定与目标节点相连接的其他节点，直至查找到包含有目标标识的节点，目标标识为可用于表征用户身份的标识。由于抽象的图结构将大量的交易进行了合并，因此数据总量显著减少，降低了定位到带有指定标注的节点的计算复杂度，提高了数据追踪效率。
Description
技术领域
本发明涉及区块链技术领域，具体涉及一种区块链数据追踪方法、装置及电子设备。
背景技术
由于区块链的去中心化和匿名特性，监管机关在对链上交易进行监管时，常用的手段是通过层层传递的交易链，将问题地址定位到一些可进行实名信息调证的平台，调取问题地址对应的用户的身份信息，再通过汇总问题地址的交易信息确定问题地址对应账户的交易金额，通过用户的身份信息和对应的交易金额两条线的证据来固定监管信息。在固定用户的身份信息时，通常只需要知道问题地址和哪些地址发生过交易，而无需关注交易的时间以及某一笔交易是否与问题地址的资金相关。而在固定交易金额信息时则相反，不关心资金最终流向哪里，只关心从某个地址流出的资金是否属于问题地址的资金；可以理解为在追踪交易时要关注交易在时间维度的先后顺序；假设问题地址(addr1)向地址(addr2)转入了一笔资金，那么在该笔交易之后从addr2转出的资金才可能是与addr1相关联的资金。
常用的数据追踪方法为读取问题地址的全部交易信息，获取与该交易信息的关联地址，再依次获取这些关联地址的交易信息，如此反复下去，采用深度优先或广度优先的方法对所有交易进行遍历，筛选出符合追踪要求的交易进行计算，最后得到追踪的结果数据。但现有方法需要过滤目标问题地址的全部交易，交易量巨大，任意两个地址之间可能有成千上万条交易数据在数据库中，在检索时都要作为待筛选数据被读取，在区块链上地址和交易数据普遍量级在亿以上的这种情况下，数据追踪检索性能极低，资源占用极大。故亟待提出一种新的区块链数据追踪方法以提高区块链数据追踪效率。
发明内容
因此，本发明要解决的技术问题在于克服现有区块链问题数据追踪方法效率低的缺陷，从而提供一种区块链数据追踪方法、装置及电子设备。
根据第一方面，本发明实施例公开了一种区块链数据追踪方法，包括：对区块链中包含的地址以及地址间的交易数据进行遍历操作；将遍历到的区块链的地址作为图模型的节点以及将任意两个节点对应的地址间的交易数据的流转方向作为图模型的有向边构建得到图数据模型；对所述图数据模型中的节点以及有向边进行属性数据配置操作，所述节点的属性数据包括：节点对应的地址标识；在所述图数据模型中确定问题地址对应的目标节点，从所述目标节点开始根据所述图数据模型的有向边确定与所述目标节点相连接的其他节点，直至查找到包含有目标标识的节点，所述目标标识为用于表明身份信息的标识。
可选地，所述方法还包括：当所述问题地址包括多个，对每一个所述问题地址对应的目标节点执行查找对应的含有目标标识的节点的操作。
可选地，所述方法还包括：将查找到的所述包含有目标标识的节点作为新的目标节点，重复从所述目标节点开始根据所述图数据模型的有向边确定与所述目标节点相连接的其他节点的步骤，直至查找到所述新的目标节点对应的包含有目标标识的节点。
可选地，所述有向边的属性数据包括：两个节点之间的总交易次数、总交易金额以及所有交易对应的首次开始时间和最后结束时间；所述方法还包括：当查找到任一目标节点对应的包含有目标标识的节点，在从所述目标节点到所述包含有目标标识的节点之间所有的有向边中，确定所述所有的有向边中流转方向为从目标节点转出的第一目标有向边；根据所述第一目标有向边的属性数据确定每一条所述第一目标有向边的所有交易的最后结束时间是否晚于所述问题地址对应的目标节点的资金流入时间；将最后结束时间晚于所述问题地址对应的目标节点的资金流入时间的第一目标有向边作为第二目标有向边并确定所述每一条所述第二目标有向边的所有交易的首次开始时间是否晚于所述资金流入时间；若晚于所述资金流入时间，将所述第二目标有向边中全部交易数据作为问题交易数据。
可选地，所述方法还包括：在从图数据模型中的任一目标节点开始查找对应的包含有目标标识的节点的过程中，当连续多次查找到的节点均未包含目标标识，则响应停止对所述目标节点对应的包含有目标标识的节点的查找操作。
可选地，所述将遍历到的区块链的地址作为图模型的节点以及将遍历到的任意两个地址间的交易数据的流转方向作为图模型的有向边构建得到图数据模型，包括：将包含有相同地址归属信息的多个地址作为图模型的一个节点。
根据第二方面，本发明实施例还公开了一种区块链数据追踪装置，包括：遍历模块，用于对区块链中包含的地址以及地址间的交易数据进行遍历操作；构建模块，用于将遍历到的区块链的地址作为图模型的节点以及将任意两个节点对应的地址间的交易数据的流转方向作为图模型的有向边构建得到图数据模型；配置操作，用于对所述图数据模型中的节点以及有向边进行属性数据配置操作，所述节点的属性数据包括：节点对应的地址标识；查找模块，用于在所述图数据模型中确定问题地址对应的目标节点，从所述目标节点开始根据所述图数据模型的有向边确定与所述目标节点相连接的其他节点，直至查找到包含有目标标识的节点，所述目标标识为用于表明身份信息的标识。
可选地，所述查找模块，还用于当所述问题地址包括多个，对每一个所述问题地址对应的目标节点执行查找对应的含有目标标识的节点的操作。
根据第三方面，本发明实施例还公开了一种电子设备，包括：至少一个处理器；以及与所述至少一个处理器通信连接的存储器；其中，所述存储器存储有可被所述至少一个处理器执行的指令，所述指令被所述至少一个处理器执行，以使所述至少一个处理器执行如第一方面或第一方面任一可选实施方式所述的区块链数据追踪方法的步骤。
根据第四方面，本发明实施方式还公开了一种计算机可读存储介质，其上存储有计算机程序，所述计算机程序被处理器执行时实现如第一方面或第一方面任一可选实施方式所述的区块链数据追踪方法的步骤。
本发明技术方案，具有如下优点：
本发明提供的区块链数据追踪方法/装置，对区块链中包含的地址以及地址间的交易数据进行遍历操作，将遍历到的区块链的地址作为图模型的节点以及将任意两个节点对应的地址间的交易数据的流转方向作为图模型的有向边构建得到图数据模型，对图数据模型中的节点以及有向边进行属性数据配置操作，在图数据模型中确定问题地址对应的目标节点，从目标节点开始根据图数据模型的有向边确定与目标节点相连接的其他节点，直至查找到包含有目标标识的节点，目标标识为可用于表明身份信息的标识。通过对区块链中包含的地址以及地址间的交易数据进行遍历操作并构建对应的图数据模型，结合图数据模型中的节点的标识信息对问题地址对应的目标节点进行交易链路查询，直至查找到包含有用于表明身份信息的标识的节点；通过追踪到包含有可用于表明身份信息的标识的节点，可以通过该身份信息对可能是与问题地址相关联地址进行监管，且结合图数据模型进行与问题地址可能存在关联的地址的追踪，提高了对区块链数据追踪的效率。
附图说明
为了更清楚地说明本发明具体实施方式或现有技术中的技术方案，下面将对具体实施方式或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图是本发明的一些实施方式，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。
图1为本发明实施例中区块链数据追踪方法的一个具体示例的流程图；
图2为本发明实施例中区块链数据追踪方法的一个应用场景示意图；
图3为本发明实施例中区块链数据追踪装置的一个具体示例的原理框图；
图4为本发明实施例中电子设备的一个具体示例图。
具体实施方式
下面将结合附图对本发明的技术方案进行清楚、完整地描述，显然，所描述的实施例是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。
在本发明的描述中，需要说明的是，术语“中心”、“上”、“下”、“左”、“右”、“竖直”、“水平”、“内”、“外”等指示的方位或位置关系为基于附图所示的方位或位置关系，仅是为了便于描述本发明和简化描述，而不是指示或暗示所指的装置或元件必须具有特定的方位、以特定的方位构造和操作，因此不能理解为对本发明的限制。此外，术语“第一”、“第二”、“第三”仅用于描述目的，而不能理解为指示或暗示相对重要性。
此外，下面所描述的本发明不同实施方式中所涉及的技术特征只要彼此之间未构成冲突就可以相互结合。
本发明实施例公开了一种区块链数据追踪方法，该方法可应用于数据追踪平台，通过合并同一交易流转方向的交易数据进行业务建模，构建符合追踪要求的图数据模型，利用抽象的图数据与全量交易信息共同进行数据追踪，以达到加快检索速度、提升系统性能的目的。该方法不局限于某一种区块链，适合所有区块链数据追踪场景。如图1所示，该方法包括如下步骤：
步骤101，对区块链中包含的地址以及地址间的交易数据进行遍历操作；
示例性地，该区块链可以是任一待进行数据追踪的区块链，本申请实施例对该区块链的类型不作限定，只要能获取到该区块链中包含的全量交易数据即可，其中该全量交易数据可以包括但不限于交易哈希、交易发送地址、交易接收地址、交易额度以及交易时间等，该全量交易数据可以从经过授权的、记录有区块链全量交易数据的数据库中获取。
步骤102，将遍历到的区块链的地址作为图模型的节点以及将任意两个节点对应的地址间的交易数据的流转方向作为图模型的有向边构建得到图数据模型；
示例性地，可以将遍历到的区块链上的每一个交易地址作为图模型的一个节点，也可以将遍历到的包含有相同地址归属信息的多个地址作为图模型的一个节点，如对于遍历到的多个地址，其属性信息均包含同一交易平台地址信息，则可以表明这些地址来自于一个交易平台，则将该多个地址合并作为图模型的一个节点进行图数据模型的构建，减少了模型构建的数据量以及构建得到的图数据模型的维度，提高了后续利用图数据模型进行可疑数据追踪的效率。对于任意两个节点之间的交易数据，按照其对应的地址间的交易数据的流转方向构建图模型的有向边，即当节点A与节点B之间存在多个从节点A向节点B发出的交易，则仅需要在节点A以及节点B之间构建一条从节点A指向节点B的有向边即可。通过根据两个地址之间的交易数据的流转方向构建有向边，减少了构建得到的图数据模型的数据复杂度以及数据量。将区块链上的一个地址或某一类具有相同属性的地址簇构建为一个节点，记作Node；依次遍历区块链上所有交易，将两个节点之间的多次交易数据按照交易方向进行合并，构建为一条有向边，记作Edge。遍历完全部区块链数据后，将构造出一张由节点和有向边共同构建的图。
步骤103，对所述图数据模型中的节点以及有向边进行属性数据配置操作，所述节点的属性数据包括：节点对应的地址标识；示例性地，节点对应的地址标识包括但不限于隶属于某一交易平台的平台标识、节点金额等，本领域技术人员可以根据实际业务需求进行设置。
具体地，如图2所示为一图数据模型示意图，图中包含节点A、节点B以及节点T，由节点A指向节点B的有向边中包含有四个属性信息，分别为总交易次数(Count)、总交易金额(Value)、所有交易对应的首次开始时间(Begin)和最后结束时间(End)，其中图中的“1500393600”以及“1635004800”为时间戳表征形式，“1500393600”为节点A与节点B之间10次交易的首次开始时间对应的时间戳，“1635004800”为节点A与节点B之间10次交易的最后结束时间对应的时间戳。节点T的属性信息包括：节点的标签(Label)，本申请实施例中节点T的标签为钱包(Wallet)，以及节点当前剩余金额(Balance)。本领域技术人员可以根据实际需要灵活设置。
步骤104，在所述图数据模型中确定问题地址对应的目标节点，从所述目标节点开始根据所述图数据模型的有向边确定与所述目标节点相连接的其他节点，直至查找到包含有目标标识的节点，所述目标标识为用于表明身份信息的标识。
示例性地，问题地址可以是从其他监管平台获取到的需要进行追踪、监管的地址；也可以是在实际对区块链上的交易数据进行分析时通过算法捕捉到的可能存在问题的地址，本申请实施例对该问题地址的来源不作限定。在图数据模型中确定出问题地址对应的目标节点后，从该目标节点开始在该图数据模型中按照有向边构建的链路进行与该目标节点相关联的节点的查找，直至查找到包含可用于表明身份信息的标识的节点。由于该节点包含可用于表明其身份信息的标识，继而可以通过该标识确定该节点的身份信息，继而可以将该节点对应的地址作为与问题地址相关联的可疑问题地址实现后续对该可疑问题地址的追踪、监控。当查找到的节点包含的可用于表明身份信息的标识为可进行实名信息调证的平台的标识，则表征可以在可进行实名信息调证的平台确定该节点的身份信息，继而对该节点对应的地址进行追踪、监控。
作为本发明一个可选实施方式，所述方法还包括：当所述问题地址包括多个，对每一个所述问题地址对应的目标节点执行查找对应的含有目标标识的节点的操作。示例性地，当获取到多个问题地址需要进行关联地址查询时，重复上述实施例的步骤进行其他节点的查找操作。具体参见上述实施例，在此不再赘述。
作为本发明一个可选实施方式，所述方法还包括：将查找到的所述包含有目标标识的节点作为新的目标节点，重复从所述目标节点开始根据所述图数据模型的有向边确定与所述目标节点相连接的其他节点的步骤，直至查找到所述新的目标节点对应的包含有目标标识的节点。
示例性地，对于任一目标节点，当查找到与之对应的包含有目标标识的节点，重新以该包含有目标标识的节点作为新的目标节点进行下一轮的可疑节点的查找操作。具体的查找方式参见上述实施例，在此不再赘述。从目标节点开始，依次查找通过有向边进行连接的节点，查看这些节点是否带有指定标注(即可用于表征身份信息的标识)，若没有，则重复上述过程，直到找到具有指定标注的节点为止。由于抽象的图结构将大量的交易进行了合并，因此数据总量显著减少，降低了定位到带有指定标注的节点的计算复杂度，提高了数据追踪效率。
作为本发明一个可选实施方式，所述有向边的属性数据包括：两个节点之间的总交易次数、总交易金额以及所有交易对应的首次开始时间和最后结束时间；所述方法还包括：
当查找到任一目标节点对应的包含有目标标识的节点，在从所述目标节点到所述包含有目标标识的节点之间所有的有向边中，确定所述所有的有向边中流转方向为从目标节点转出的第一目标有向边；示例性地，如当图2中的节点A为目标节点，则第一目标有向边为节点A指向节点B的有向边以及从节点B指向节点T的有向边，即第一目标有向边对应的交易方向为目标节点的交易流出方向。
根据所述第一目标有向边的属性数据确定每一条所述第一目标有向边的所有交易的最后结束时间是否晚于所述问题地址对应的目标节点的资金流入时间；将最后结束时间晚于所述问题地址对应的目标节点的资金流入时间的第一目标有向边作为第二目标有向边并确定所述每一条所述第二目标有向边的所有交易的首次开始时间是否晚于所述资金流入时间；若晚于所述资金流入时间，将所述第二目标有向边中全部交易数据作为问题交易数据。
示例性地，以图2中节点B与节点T之间的第一目标有向边为例，资金流入时间可以是目标节点A第一次与节点B之间有交易的时间，当目标节点A与节点B之间存在交易，则会有目标节点A的资金流入节点B，当节点B与节点T之间的所有交易的最晚结束时间不晚于目标节点A的资金流入时间，则表明节点B与节点T之间所有交易涉及到的资金转移均在目标节点A的资金进入B之前完成，即可以判定节点B与节点T之间的交易情况与问题节点A无关，则在确定问题交易数据的过程中不需要对该条有向边的交易数据进行检索、计算，仅使用最后结束时间晚于问题地址对应的目标节点的资金流入时间的第一目标有向边即可，并将最后结束时间晚于问题地址对应的目标节点的资金流入时间的第一目标有向边作为第二目标有向边。
由于本申请实施例记载的方法中为了提高追踪效率，有向边的属性信息仅仅包含所有交易的首次开始时间和最后一次结束时间，故当每一条第二目标有向边的所有交易的首次开始时间晚于资金流入时间，将第二目标有向边中全部交易数据作为问题交易数据。例如，当节点B与节点T之间交易的首次开始时间晚于目标节点A的资金流入时间，则节点B与节点T之间的交易可能涉及到目标节点A的问题资金流，则此时将节点B与节点T对应的第二目标有向边中全部交易数据作为问题交易数据，以进行后续的进一步监管。在本申请实施例中对问题交易数据的查找过程中，可挂接额外的算法过滤器，剔除一些不满足附加条件的有向边(如陷入循环的有向边)，使算法精准度、效率更高。
作为本发明一个可选实施方式，所述方法还包括：在从图数据模型中的任一目标节点开始查找对应的包含有目标标识的节点的过程中，当连续多次查找到的节点均未包含目标标识，则响应停止对所述目标节点对应的包含有目标标识的节点的查找操作。
示例性地，当问题地址包括多个，为了保证对其他问题地址的关联地址的查找效率，对于任一目标节点，当对其进行关联节点的查找过程中，当连续多次(如3次)查找到的节点均未包含目标标识，则响应停止对该目标节点对应的包含有目标标识的节点的查找操作。
作为本申请一个具体实施方式，本实施例以任一目标区块链为例，对该目标区块链进行异常地址追踪，用于进行数据追踪的追踪平台集成有区块链数据解析程序、交易图谱构建程序、交易数据追踪程序以及用于进行有向边筛选的算法过滤器。该追踪平台可从包含该目标区块链的全量交易数据的数据库(MySQL)获取全量交易数据，并可以将构建的图数据模型存入图数据库(Neo4j)。
步骤一，通过区块链数据解析程序将该目标区块链上的全量交易数据进行解析，以交易哈希为主键，将所有交易数据存入全量交易数据库，每条数据均包含交易哈希、发送地址、接收地址、交易额度、交易时间；
步骤二，通过交易图谱构建程序将全量交易数据库中的数据进行计算，构建交易的图数据模型，并将该模型存入图数据库，并向图数据模型中导入节点以及有向边的属性信息；
步骤三，交易数据追踪程序根据初始目标地址，在图数据库Neo4j中利用图算法，在指定追踪层级内进行交易链路查询，定位到具有特定标注信息(即目标标识)的节点对应的地址，后续可以通过调证该地址对应的实控人信息确定可疑人员；
步骤四，在交易数据追踪程序中输入初始目标地址，确认资金流入时间，以该地址作为输入方，在图数据库Neo4j中利用图算法统计所有交易流出的边，并对边上的首次和末次时间进行计算，剔除所有末次流入时间早于目标地址资金流入时间的边；
步骤五，保留所有首次资金流入时间晚于目标地址资金流入时间的边，可选的，可通过额外的算法过滤器剔除一些不满足条件的边；
步骤六，在剩余有向边中，通过交易数据追踪程序从全量交易数据库MySQL中获取有向边中的所有交易信息，依据时间记录选择所有晚于目标地址资金流入时间的交易进行计算，可选的，可通过额外的算法过滤器剔除一些不满足条件的交易信息；
步骤七，从目标地址中选择一条有向边的交易流出地址作为新的目标地址，依次重复步骤四、五、六，直到全部流出地址均满足层级设定或到达具有特定标注的地址时终止。
从目标节点开始，依次查找通过有向边进行连接的节点，查看这些节点是否带有指定标注，若没有，则重复上述过程，直到找到具有指定标注的节点为止。由于抽象的图结构将大量的交易进行了合并，因此数据总量显著减少，降低了定位到带有指定标注的节点的计算复杂度，提高了数据追踪效率。
本发明实施例还公开了一种区块链数据追踪装置，如图3所示，该装置包括：
遍历模块301，用于对区块链中包含的地址以及地址间的交易数据进行遍历操作；
构建模块302，用于将遍历到的区块链的地址作为图模型的节点以及将任意两个节点对应的地址间的交易数据的流转方向作为图模型的有向边构建得到图数据模型；
配置操作303，用于对所述图数据模型中的节点以及有向边进行属性数据配置操作，所述节点的属性数据包括：节点对应的地址标识；
查找模块304，用于在所述图数据模型中确定问题地址对应的目标节点，从所述目标节点开始根据所述图数据模型的有向边确定与所述目标节点相连接的其他节点，直至查找到包含有目标标识的节点，所述目标标识为用于表明身份信息的标识。
本发明提供的区块链数据追踪装置，通过对区块链中包含的地址以及地址间的交易数据进行遍历操作并构建对应的图数据模型，结合图数据模型中的节点的标识信息对问题地址对应的目标节点进行交易链路查询，直至查找到包含有用于表明身份信息的标识的节点；通过追踪到包含有可用于表明身份信息的标识的节点，可以通过该身份信息对可能是与问题地址相关联地址进行监管，且结合图数据模型进行与问题地址可能存在关联的地址的追踪，提高了对区块链数据追踪的效率。
作为本发明一个可选实施方式，所述查找模块，还用于当所述问题地址包括多个，对每一个所述问题地址对应的目标节点执行查找对应的含有目标标识的节点的操作。
作为本发明一个可选实施方式，所述查找模块，还用于将查找到的所述包含有目标标识的节点作为新的目标节点，重复从所述目标节点开始根据所述图数据模型的有向边确定与所述目标节点相连接的其他节点的步骤，直至查找到所述新的目标节点对应的包含有目标标识的节点。
作为本发明一个可选实施方式，所述有向边的属性数据包括：两个节点之间的总交易次数、总交易金额以及所有交易对应的首次开始时间和最后结束时间；所述装置还包括：第一确定模块，用于当查找到任一目标节点对应的包含有目标标识的节点，在从所述目标节点到所述包含有目标标识的节点之间所有的有向边中，确定所述所有的有向边中流转方向为从目标节点转出的第一目标有向边；第二确定模块，用于根据所述第一目标有向边的属性数据确定每一条所述第一目标有向边的所有交易的最后结束时间是否晚于所述问题地址对应的目标节点的资金流入时间；第三确定模块，用于将最后结束时间晚于所述问题地址对应的目标节点的资金流入时间的第一目标有向边作为第二目标有向边并确定所述每一条所述第二目标有向边的所有交易的首次开始时间是否晚于所述资金流入时间；判定模块，用于若晚于所述资金流入时间，将所述第二目标有向边中全部交易数据作为问题交易数据。
作为本发明一个可选实施方式，所述装置还包括：停止查找模块，用于在从图数据模型中的任一目标节点开始查找对应的包含有目标标识的节点的过程中，当连续多次查找到的节点均未包含目标标识，则响应停止对所述目标节点对应的包含有目标标识的节点的查找操作。
作为本发明一个可选实施方式，所述构建模块还用于将包含有相同地址归属信息的多个地址作为图模型的一个节点。
本发明实施例还提供了一种电子设备，如图4所示，该电子设备可以包括处理器401和存储器402，其中处理器401和存储器402可以通过总线或者其他方式连接，图4中以通过总线连接为例。
处理器401可以为中央处理器(Central Processing Unit，CPU)。处理器401还可以为其他通用处理器、数字信号处理器(Digital Signal Processor，DSP)、专用集成电路(Application Specific Integrated Circuit，ASIC)、现场可编程门阵列(Field-Programmable Gate Array，FPGA)或者其他可编程逻辑器件、分立门或者晶体管逻辑器件、分立硬件组件等芯片，或者上述各类芯片的组合。
存储器402作为一种非暂态计算机可读存储介质，可用于存储非暂态软件程序、非暂态计算机可执行程序以及模块，如本发明实施例中的区块链数据追踪方法对应的程序指令/模块。处理器401通过运行存储在存储器402中的非暂态软件程序、指令以及模块，从而执行处理器的各种功能应用以及数据处理，即实现上述方法实施例中的区块链数据追踪方法。
存储器402可以包括存储程序区和存储数据区，其中，存储程序区可存储操作系统、至少一个功能所需要的应用程序；存储数据区可存储处理器401所创建的数据等。此外，存储器402可以包括高速随机存取存储器，还可以包括非暂态存储器，例如至少一个磁盘存储器件、闪存器件、或其他非暂态固态存储器件。在一些实施例中，存储器402可选包括相对于处理器401远程设置的存储器，这些远程存储器可以通过网络连接至处理器401。上述网络的实例包括但不限于互联网、企业内部网、局域网、移动通信网及其组合。
所述一个或者多个模块存储在所述存储器402中，当被所述处理器401执行时，执行如图1所示实施例中的区块链数据追踪方法。
上述电子设备具体细节可以对应参阅图1所示的实施例中对应的相关描述和效果进行理解，此处不再赘述。
本领域技术人员可以理解，实现上述实施例方法中的全部或部分流程，是可以通过计算机程序来指令相关的硬件来完成，所述的程序可存储于一计算机可读取存储介质中，该程序在执行时，可包括如上述各方法的实施例的流程。其中，所述存储介质可为磁碟、光盘、只读存储记忆体(Read-Only Memory，ROM)、随机存储记忆体(RandomAccessMemory，RAM)、快闪存储器(Flash Memory)、硬盘(Hard Disk Drive，缩写：HDD)或固态硬盘(Solid-State Drive，SSD)等；所述存储介质还可以包括上述种类的存储器的组合。
虽然结合附图描述了本发明的实施例，但是本领域技术人员可以在不脱离本发明的精神和范围的情况下作出各种修改和变型，这样的修改和变型均落入由所附权利要求所限定的范围之内。
Claims (10)
1.一种区块链数据追踪方法，其特征在于，包括：
对区块链中包含的地址以及地址间的交易数据进行遍历操作；
将遍历到的区块链的地址作为图模型的节点以及将任意两个节点对应的地址间的交易数据的流转方向作为图模型的有向边构建得到图数据模型；
对所述图数据模型中的节点以及有向边进行属性数据配置操作，所述节点的属性数据包括：节点对应的地址标识；
在所述图数据模型中确定问题地址对应的目标节点，从所述目标节点开始根据所述图数据模型的有向边确定与所述目标节点相连接的其他节点，直至查找到包含有目标标识的节点，所述目标标识为用于表明身份信息的标识。
2.根据权利要求1所述的方法，其特征在于，所述方法还包括：
当所述问题地址包括多个，对每一个所述问题地址对应的目标节点执行查找对应的含有目标标识的节点的操作。
3.根据权利要求1或2所述的方法，其特征在于，所述方法还包括：
将查找到的所述包含有目标标识的节点作为新的目标节点，重复从所述目标节点开始根据所述图数据模型的有向边确定与所述目标节点相连接的其他节点的步骤，直至查找到所述新的目标节点对应的包含有目标标识的节点。
4.根据权利要求1所述的方法，其特征在于，所述有向边的属性数据包括：两个节点之间的总交易次数、总交易金额以及所有交易对应的首次开始时间和最后结束时间；所述方法还包括：
当查找到任一目标节点对应的包含有目标标识的节点，在从所述目标节点到所述包含有目标标识的节点之间所有的有向边中，确定所述所有的有向边中流转方向为从目标节点转出的第一目标有向边；
根据所述第一目标有向边的属性数据确定每一条所述第一目标有向边的所有交易的最后结束时间是否晚于所述问题地址对应的目标节点的资金流入时间；
将最后结束时间晚于所述问题地址对应的目标节点的资金流入时间的第一目标有向边作为第二目标有向边并确定所述每一条所述第二目标有向边的所有交易的首次开始时间是否晚于所述资金流入时间；
若晚于所述资金流入时间，将所述第二目标有向边中全部交易数据作为问题交易数据。
5.根据权利要求1所述的方法，其特征在于，所述方法还包括：
在从图数据模型中的任一目标节点开始查找对应的包含有目标标识的节点的过程中，当连续多次查找到的节点均未包含目标标识，则响应停止对所述目标节点对应的包含有目标标识的节点的查找操作。
6.根据权利要求1所述的方法，其特征在于，所述将遍历到的区块链的地址作为图模型的节点以及将遍历到的任意两个地址间的交易数据的流转方向作为图模型的有向边构建得到图数据模型，包括：
将包含有相同地址归属信息的多个地址作为图模型的一个节点。
7.一种区块链数据追踪装置，其特征在于，包括：
遍历模块，用于对区块链中包含的地址以及地址间的交易数据进行遍历操作；
构建模块，用于将遍历到的区块链的地址作为图模型的节点以及将任意两个节点对应的地址间的交易数据的流转方向作为图模型的有向边构建得到图数据模型；
配置操作，用于对所述图数据模型中的节点以及有向边进行属性数据配置操作，所述节点的属性数据包括：节点对应的地址标识；
查找模块，用于在所述图数据模型中确定问题地址对应的目标节点，从所述目标节点开始根据所述图数据模型的有向边确定与所述目标节点相连接的其他节点，直至查找到包含有目标标识的节点，所述目标标识为用于表明身份信息的标识。
8.根据权利要求7所述的装置，其特征在于，所述查找模块，还用于当所述问题地址包括多个，对每一个所述问题地址对应的目标节点执行查找对应的含有目标标识的节点的操作。
9.一种电子设备，其特征在于，包括：至少一个处理器；以及与所述至少一个处理器通信连接的存储器；其中，所述存储器存储有可被所述至少一个处理器执行的指令，所述指令被所述至少一个处理器执行，以使所述至少一个处理器执行如权利要求1-6任一所述的区块链数据追踪方法的步骤。
10.一种计算机可读存储介质，其上存储有计算机程序，其特征在于，所述计算机程序被处理器执行时实现如权利要求1-6中任一项所述的区块链数据追踪方法的步骤。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202210776279.7A CN115049493A (zh) | 2022-06-29 | 2022-06-29 | 一种区块链数据追踪方法、装置及电子设备 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202210776279.7A CN115049493A (zh) | 2022-06-29 | 2022-06-29 | 一种区块链数据追踪方法、装置及电子设备 |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN115049493A true CN115049493A (zh) | 2022-09-13 |
Family
ID=83165232
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202210776279.7A Pending CN115049493A (zh) | 2022-06-29 | 2022-06-29 | 一种区块链数据追踪方法、装置及电子设备 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN115049493A (zh) |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN118115160A (zh) * | 2024-04-29 | 2024-05-31 | 中科链安(北京)科技有限公司 | 对多地址在时间区间内区块链交易追溯方法和系统 |
| CN118378204A (zh) * | 2024-06-26 | 2024-07-23 | 中科链安(北京)科技有限公司 | 基于模式匹配的区块链异常交易行为识别方法及设备 |
Citations (18)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20100217695A1 (en) * | 2009-02-26 | 2010-08-26 | Yahoo! Inc. | Edge attribute aggregation in a directed graph |
| CN108537546A (zh) * | 2018-04-11 | 2018-09-14 | 北京奇虎科技有限公司 | 基于地址树的节点身份追踪方法、装置及计算设备 |
| CN109087079A (zh) * | 2018-07-09 | 2018-12-25 | 北京知帆科技有限公司 | 数字货币交易信息分析方法 |
| CN109086630A (zh) * | 2018-07-31 | 2018-12-25 | 温州市图盛科技有限公司 | 一种基于区块链的电力信息溯源追踪方法 |
| WO2019157810A1 (zh) * | 2018-02-13 | 2019-08-22 | 华为技术有限公司 | 一种数据传输方法、装置和网络节点 |
| CN110569246A (zh) * | 2019-07-23 | 2019-12-13 | 腾讯科技（深圳）有限公司 | 区块链节点信息同步方法、装置、计算机设备及存储介质 |
| CN110766384A (zh) * | 2019-09-06 | 2020-02-07 | 安徽高山科技有限公司 | 一种区块链中数字货币流向追踪方法 |
| CN111090651A (zh) * | 2019-12-18 | 2020-05-01 | 深圳前海微众银行股份有限公司 | 数据源的处理方法、装置、设备及可读存储介质 |
| CN111383005A (zh) * | 2018-12-29 | 2020-07-07 | 北京知帆科技有限公司 | 数字货币流向追踪方法及装置 |
| CN111383004A (zh) * | 2018-12-29 | 2020-07-07 | 北京知帆科技有限公司 | 数字货币的实体位置提取方法、信息的提取方法及其装置 |
| CN111680194A (zh) * | 2020-06-11 | 2020-09-18 | 深圳前海微众银行股份有限公司 | 加密货币交易追踪方法、装置、设备及可读存储介质 |
| CN112559771A (zh) * | 2020-12-23 | 2021-03-26 | 信雅达科技股份有限公司 | 基于知识图谱的资金交易智能监测方法及监测系统 |
| CN112650890A (zh) * | 2020-12-28 | 2021-04-13 | 杭州趣链科技有限公司 | 一种基于图数据库的加密货币流向追踪方法与装置 |
| CN113537960A (zh) * | 2021-07-19 | 2021-10-22 | 中国工商银行股份有限公司 | 一种异常资源转移链路的确定方法、装置和设备 |
| CN113888317A (zh) * | 2021-10-20 | 2022-01-04 | 支付宝(杭州)信息技术有限公司 | 用于对信贷资金进行管控的方法及装置 |
| CN114357000A (zh) * | 2022-01-11 | 2022-04-15 | 广州广电运通金融电子股份有限公司 | 一种区块链交易数据检索系统、方法、设备及存储介质 |
| US20220121556A1 (en) * | 2021-12-23 | 2022-04-21 | Intel Corporation | Systems, methods, articles of manufacture, and apparatus for end-to-end hardware tracing in an edge network |
| CN114416819A (zh) * | 2021-12-24 | 2022-04-29 | 中国工商银行股份有限公司 | 一种对公客户的挖掘方法及装置 |
-
2022
- 2022-06-29 CN CN202210776279.7A patent/CN115049493A/zh active Pending
Patent Citations (18)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20100217695A1 (en) * | 2009-02-26 | 2010-08-26 | Yahoo! Inc. | Edge attribute aggregation in a directed graph |
| WO2019157810A1 (zh) * | 2018-02-13 | 2019-08-22 | 华为技术有限公司 | 一种数据传输方法、装置和网络节点 |
| CN108537546A (zh) * | 2018-04-11 | 2018-09-14 | 北京奇虎科技有限公司 | 基于地址树的节点身份追踪方法、装置及计算设备 |
| CN109087079A (zh) * | 2018-07-09 | 2018-12-25 | 北京知帆科技有限公司 | 数字货币交易信息分析方法 |
| CN109086630A (zh) * | 2018-07-31 | 2018-12-25 | 温州市图盛科技有限公司 | 一种基于区块链的电力信息溯源追踪方法 |
| CN111383005A (zh) * | 2018-12-29 | 2020-07-07 | 北京知帆科技有限公司 | 数字货币流向追踪方法及装置 |
| CN111383004A (zh) * | 2018-12-29 | 2020-07-07 | 北京知帆科技有限公司 | 数字货币的实体位置提取方法、信息的提取方法及其装置 |
| CN110569246A (zh) * | 2019-07-23 | 2019-12-13 | 腾讯科技（深圳）有限公司 | 区块链节点信息同步方法、装置、计算机设备及存储介质 |
| CN110766384A (zh) * | 2019-09-06 | 2020-02-07 | 安徽高山科技有限公司 | 一种区块链中数字货币流向追踪方法 |
| CN111090651A (zh) * | 2019-12-18 | 2020-05-01 | 深圳前海微众银行股份有限公司 | 数据源的处理方法、装置、设备及可读存储介质 |
| CN111680194A (zh) * | 2020-06-11 | 2020-09-18 | 深圳前海微众银行股份有限公司 | 加密货币交易追踪方法、装置、设备及可读存储介质 |
| CN112559771A (zh) * | 2020-12-23 | 2021-03-26 | 信雅达科技股份有限公司 | 基于知识图谱的资金交易智能监测方法及监测系统 |
| CN112650890A (zh) * | 2020-12-28 | 2021-04-13 | 杭州趣链科技有限公司 | 一种基于图数据库的加密货币流向追踪方法与装置 |
| CN113537960A (zh) * | 2021-07-19 | 2021-10-22 | 中国工商银行股份有限公司 | 一种异常资源转移链路的确定方法、装置和设备 |
| CN113888317A (zh) * | 2021-10-20 | 2022-01-04 | 支付宝(杭州)信息技术有限公司 | 用于对信贷资金进行管控的方法及装置 |
| US20220121556A1 (en) * | 2021-12-23 | 2022-04-21 | Intel Corporation | Systems, methods, articles of manufacture, and apparatus for end-to-end hardware tracing in an edge network |
| CN114416819A (zh) * | 2021-12-24 | 2022-04-29 | 中国工商银行股份有限公司 | 一种对公客户的挖掘方法及装置 |
| CN114357000A (zh) * | 2022-01-11 | 2022-04-15 | 广州广电运通金融电子股份有限公司 | 一种区块链交易数据检索系统、方法、设备及存储介质 |
Non-Patent Citations (1)
| Title |
|---|
| 田立中;周昭涛;孔昭龙;: "利用有向图解决支付清算中的"三角债"问题", 今日科苑, no. 20, 23 October 2007 (2007-10-23) * |
Cited By (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN118115160A (zh) * | 2024-04-29 | 2024-05-31 | 中科链安(北京)科技有限公司 | 对多地址在时间区间内区块链交易追溯方法和系统 |
| CN118115160B (zh) * | 2024-04-29 | 2024-08-06 | 中科链安(北京)科技有限公司 | 对多地址在时间区间内区块链交易追溯方法和系统 |
| CN118378204A (zh) * | 2024-06-26 | 2024-07-23 | 中科链安(北京)科技有限公司 | 基于模式匹配的区块链异常交易行为识别方法及设备 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US20190286510A1 (en) | Automatic correlation of dynamic system events within computing devices | |
| CN108595157B (zh) | 区块链数据的处理方法、装置、设备和存储介质 | |
| CN110457175B (zh) | 业务数据处理方法、装置、电子设备及介质 | |
| CN111669281B (zh) | 告警分析方法、装置、设备及存储介质 | |
| CN115631039A (zh) | 资金追踪方法、装置及设备 | |
| CN115049493A (zh) | 一种区块链数据追踪方法、装置及电子设备 | |
| CN110647447B (zh) | 用于分布式系统的异常实例检测方法、装置、设备和介质 | |
| CN111966289A (zh) | 基于Kafka集群的分区优化方法和系统 | |
| CN111181800A (zh) | 测试数据处理方法、装置、电子设备及存储介质 | |
| CN114091610A (zh) | 智能决策方法及装置 | |
| CN111327466B (zh) | 一种告警分析方法、系统、设备以及介质 | |
| CN112712125B (zh) | 事件流的模式匹配方法、装置、存储介质及处理器 | |
| WO2024088025A1 (zh) | 一种基于多维数据的5gc网元自动化纳管方法及装置 | |
| CN113138906A (zh) | 一种调用链数据采集方法、装置、设备及存储介质 | |
| CN117271177B (zh) | 基于链路数据的根因定位方法、装置、电子设备及存储介质 | |
| CN112383436A (zh) | 一种网络监控的方法和装置 | |
| CN115484105B (zh) | 攻击树的建模方法、装置、电子设备及可读存储介质 | |
| CN111324583A (zh) | 一种业务日志的分类方法及装置 | |
| CN113052700B (zh) | 一种确定微服务调用链的方法及装置 | |
| CN113076451B (zh) | 异常行为识别和风险模型库的建立方法、装置及电子设备 | |
| CN113285978B (zh) | 基于区块链和大数据的故障识别方法及通用计算节点 | |
| CN114039860A (zh) | 一种用于快速构建服务器网络拓扑图的方法和系统 | |
| CN116882724B (zh) | 一种业务流程优化方案的生成方法、装置、设备及介质 | |
| CN113691423B (zh) | 数据流转路径的绘制方法、装置、存储介质及电子设备 | |
| CN116582462B (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 |