CN112667661B - Tracing information correlation query method and device - Google Patents

Abstract

The present application provides a traceability information correlation query method and device, which obtains data labels corresponding to the data to be queried, obtains query conditions based on the data labels, and starts to query the traceability information corresponding to the query conditions from the blockchain based on the data labels. The traceability information corresponding to the query condition is queried in a block of the chain, the traceability information corresponding to the query condition is used as the current traceability information, and the storage identifier of another traceability information related to the current traceability information is obtained from the block that stores the current traceability information. , based on the storage identifier of another traceability information, obtain another traceability information from the block pointed to by the storage identifier, use the other traceability information as the current traceability information, and return to execute the current traceability information obtained from the block where the current traceability information is stored. The storage identifier of another piece of traceability information related to the information is empty until the value of the storage identifier obtained from the block is empty, and all the traceability information queried is output to realize the related query of traceability information.

Description

A traceability information correlation query method and device

technical field

The present application belongs to the technical field of data processing, and in particular relates to a method and device for associative query of traceability information.

Background technique

Data traceability is to obtain the evolution process of the original data through the collection of the historical evolution process of the data, and store the traceability information after the traceability information is generated to ensure the reliability of the source of the original data; through the query of the traceability information, the source of the original data is verified.

At present, in the process of querying the traceability information, the hash value of the original data is used to trace the source, but the original data with high continuity, high timeliness and high information content will be fragmented due to the large amount of data, and the fragmented data The hash value has nothing to do with each other, so that only one piece of traceability information pointed to by the hash value can be obtained in the process of obtaining traceability information based on the hash value.

SUMMARY OF THE INVENTION

In view of this, the purpose of this application is to provide a traceability information associated query method and device, which can be used to obtain all relevant traceability information during the query process based on the query conditions obtained by data labeling.

On the one hand, the present application provides a method for associating query of traceability information, the method comprising:

Obtaining data annotations corresponding to the data to be queried, and obtaining query conditions based on the data annotations;

Based on the query conditions, starting to query the traceability information corresponding to the query conditions from the block chain;

If the traceability information corresponding to the query condition is found from a block of the blockchain, the traceability information corresponding to the query condition is used as the current traceability information;

Obtain the storage identifier of another piece of traceability information related to the current traceability information from the block storing the current traceability information;

Based on the storage identifier of the other piece of traceability information, obtain the other piece of traceability information from the block pointed to by the storage identifier, and use the other piece of traceability information as the current traceability information, and return to continue execution from storing the current traceability information. Obtain the storage identifier of another piece of traceability information related to the current traceability information in the block of the traceability information until the value of the storage identifier obtained from the block is empty;

Output all traceability information queried.

Optionally, the method also includes:

After currently obtaining a piece of traceability information containing the data label corresponding to the original data, query whether the data label corresponding to the original data is stored in the block of the block chain;

If the data label corresponding to the original data is not stored in the block of the block chain, the currently obtained traceability information and storage identification containing the data mark corresponding to the original data are stored in one of the block chain in the block, and the storage identifier in the block is empty;

If the data label corresponding to the original data is stored in the block of the blockchain, the storage identification of the block that stores the traceability information of the previous data label corresponding to the original data is obtained, and the acquired storage The identifier and the currently obtained traceability information containing the data label corresponding to the original data are stored in a block of the blockchain.

Optionally, the obtaining the storage identifier of the block storing the last piece of traceability information containing the data label corresponding to the original data includes:

Obtain the data label corresponding to the stored original data and the block number of the block where the previous traceability information containing the data label corresponding to the original data is located, and use the block number as the last data containing the original data corresponding The storage identifier of the marked traceability information block.

Optionally, the process of generating the data annotation includes:

Acquiring attribute information of original data, stream feature parameter information of the original data, upper-level data identification information of the original data, and verification information of the original data, where the stream feature parameter information is used to indicate that the original In the data transmission and creation process, the upper-level data identification information is used to indicate the upper-level data that generates the original data, and the verification information of the original data is used to verify the integrity of the original data;

Based on the attribute information, the stream characteristic parameter information, the upper-level data identification information and the verification information, generate the data annotation of the original data.

Optionally, the method further includes: writing the data annotation of the original data into the file attribute of the original data.

Optionally, the generating the data annotation of the original data based on the attribute information, the stream characteristic parameter information, the upper-level data identification information and the verification information includes:

The data annotation of the original data is generated based on the following manner:

Annotation{IP,Port,Creator,Hash,Time,Attrib,Patent};

IP, Port, Creator, and Time are flow feature parameter information, IP represents the source IP address corresponding to the original data, Port represents the source port number corresponding to the original data, Creator represents the creator of the original data, and Time represents the The creation time of the original data, Attrib is the attribute information, Patent is the upper-level data identification information, and Hash is the verification information.

Optionally, the outputting all traceability information queried includes: integrating all the traceability information according to the query order of all traceability information, and outputting all the traceability information after integration, and the query order of all traceability information is in the order of traceability The storage identifier corresponding to the information is determined.

Optionally, the query conditions obtained based on the data annotation include:

determining the data annotation as the query condition;

or

The query condition is obtained based on the parameter value in the data annotation.

On the other hand, the present application also provides a traceability information association query device, the device includes:

A condition obtaining unit, configured to obtain data annotations corresponding to the data to be queried, and obtain query conditions based on the data annotations;

The first query unit is configured to start querying the traceability information corresponding to the query condition from the block chain based on the query condition;

A determining unit, configured to use the traceability information corresponding to the query condition as the current traceability information if the traceability information corresponding to the query condition is found from a block of the blockchain;

The second query unit is used to obtain the storage identifier of another piece of traceability information related to the current traceability information from the block storing the current traceability information; based on the storage identifier of the other piece of traceability information, from the stored Obtain the other piece of traceability information from the block pointed to by the identifier, and use the other piece of traceability information as the current traceability information, and return to continue execution to obtain the information related to the current traceability information from the block storing the current traceability information. The storage identifier of another piece of traceability information until the value of the storage identifier obtained from the block is empty;

The output unit is used to output all traceability information queried.

In another aspect, the present application also provides a server, including:

processor;

memory for storing said processor-executable instructions;

Wherein, the processor is configured to execute the instructions, so as to realize the above-mentioned source tracing information association query method.

In yet another aspect, the present application also provides a storage medium, in which computer program codes are stored, and when the computer program codes are executed, the above-mentioned traceability information correlation query method is realized.

With the above technical solution, the data label corresponding to the data to be queried is obtained, and the query condition is obtained based on the data label. Based on the query condition, the traceability information corresponding to the query condition is queried from the blockchain. If you query from a block of the blockchain Find the traceability information corresponding to the query condition, take the traceability information corresponding to the query condition as the current traceability information, and obtain the storage identifier of another piece of traceability information related to the current traceability information from the block storing the current traceability information, based on the other piece of traceability information Store the ID, get another piece of traceability information from the block pointed to by the storage ID, and use another piece of traceability information as the current traceability information, and return to continue execution to obtain another piece of traceability information related to the current traceability information from the block that stores the current traceability information From the storage identifier of the information until the value of the storage identifier obtained from the block is empty, all the traceability information queried is output, so that all relevant traceability information can be obtained during the query process based on the query conditions obtained from the data annotation. That is, all relevant traceability information can be queried during a traceability information query process. In this way, for the data to be queried through sharding, even if the hash values of each data to be queried are different, the data corresponding to one piece of data to be queried By marking the query conditions, all relevant traceability information can be obtained, and the associated query of traceability information can be realized.

Description of drawings

In order to more clearly illustrate the technical solutions in the embodiments of the present application or the prior art, the following will briefly introduce the drawings that need to be used in the description of the embodiments or the prior art. Obviously, the accompanying drawings in the following description are For some embodiments of the present application, those of ordinary skill in the art can also obtain other drawings based on these drawings without creative effort.

FIG. 1 is a flow chart of a method for associating a traceability information query provided by an embodiment of the present application;

Fig. 2 is a flow chart of data annotation generation provided by the embodiment of the present application;

Fig. 3 is a schematic diagram of traceability information query provided by the embodiment of the present application;

Fig. 4 is a flow chart of another method for associating query of traceability information provided by the embodiment of the present application;

Fig. 5 is a schematic structural diagram of a block chain containing traceability information provided by the embodiment of the present application;

Fig. 6 is a structural flow chart of a device for associating source tracing information provided by an embodiment of the present application.

Detailed ways

In order to make the purposes, technical solutions and advantages of the embodiments of the present application clearer, the technical solutions in the embodiments of the present application will be clearly and completely described below in conjunction with the drawings in the embodiments of the present application. Obviously, the described embodiments It is a part of the embodiments of this application, not all of them. Based on the embodiments in this application, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts belong to the scope of protection of this application.

Please refer to Fig. 1, which shows a flow chart of a traceability information association query method provided by the embodiment of the present application, which may include the following steps:

101: Obtain data annotations corresponding to the data to be queried, and obtain query conditions based on the data annotations.

In this embodiment, the data label is used as the identifier of the data to be queried, and is used to uniquely point to the data to be queried. The data label is at least used to indicate the data source of the data to be queried, the attributes of the data to be queried, etc., and the Data annotation is generated when the data to be queried is obtained. If the data to be queried is received and generated during storage, the data to be queried can be regarded as the original data. For any piece of original data, the corresponding data annotation generation process is as follows:

Obtain the attribute information of the original data, the flow characteristic parameter information of the original data, the upper-level data identification information of the original data, and the verification information of the original data. The flow characteristic parameter information is used to indicate the transmission and creation process of the original data, and the upper level The data identification information is used to indicate the upper-level data that generates the original data, and the verification information of the original data is used to verify the integrity of the original data; based on attribute information, flow characteristic parameter information, upper-level data identification information and verification information, Generate data annotations for raw data.

The data source is usually the device from which the original data is obtained (or which device is transmitted), the creation information and the data generated by it. The flow characteristic parameter information and the upper-level data identification information can represent these contents, such as The stream characteristic parameter information is used to indicate which device the original data is transmitted from and the creation information of the original data, and the upper-level data identification information is used to indicate the upper-level data that generates the original data, such as the original data is the data obtained by fragmentation stream, the upper-level data identification information points to the data stream set, and if the original data is obtained by intercepting the fragmented data stream, the upper-level data identification information points to the data stream targeted by the interception operation.

In this embodiment, a feasible way to generate data annotations is to generate data annotations of original data based on the following method:

Annotation {IP, Port, Creator, Hash, Time, Attrib, Patent}.

IP, Port, Creator, and Time are stream characteristic parameter information, IP indicates the source IP address corresponding to the original data, Port indicates the source port number corresponding to the original data, Creator indicates the creator of the original data, Time indicates the creation time of the original data, and Attrib It is attribute information, Patent is upper-level data identification information, which can be expanded, and Hash is verification information.

Binding of IP and Creator is used to check whether the data source is correct and whether there is any counterfeit data; when the original data is wrong, the Creator is used to locate and check the device that created the original data; Hash protects the integrity of the original data to prevent The original data has been tampered with; Attrib is used as the attribute information of the original data, and the attribute information of different original data may be the same, so that the same data stream can be found by having the same attribute information (multiple original data are obtained by operating the same data stream) or the same data stream Traceability information of a collection (multiple pieces of original data are obtained by operating on the same data stream collection). For a data stream uploaded by an IoT device, the value of Creator can be the IoT device number, and the value of Patent can be empty; for the data stream uploaded by a user, the value of Creator can be the user name, and the value of Patent can be It can be empty, or it can be the upper-level data that generated this data, such as the data stream collection generated by IoT devices, or the analysis data generated by data analysis, represented by Hash, Time, and Attrib in the data annotation corresponding to the upper-level data , such as Patent=(Hash, Time, Attrib), note that Hash, Time and Attrib in Patent=(Hash, Time, Attrib) are all upper-level data.

The attribute information of the original data is determined when the original data is grouped. After the original data is obtained, the original data is automatically divided into corresponding data groups by using but not limited to the clustering algorithm, and the attribute information of the original data is assigned. The original data in the same data group have similar or similar attribute information, while the original data in different data groups have little similar attribute information. For example, the data stream is used as the original data. After the data stream is received, the data stream is clustered and analyzed, and the clustering algorithm is used to automatically divide the data stream into different data groups, and the corresponding attribute information is assigned to the data stream. In this embodiment, the attribute information of the original data is divided into but not limited to the following types of attribute information according to the source or usage: attributes such as monitoring data, processing data, and analysis data.

Because the attribute information between the original data may be similar or similar, there is a problem that the original data cannot be uniquely identified through the attribute information. Therefore, in order to ensure the uniqueness of the original data, in addition to the attribute information in the data annotation, this embodiment also adds stream For feature parameter information, etc., please refer to the above description for details.

After the data annotation of the original data is generated, the unforgeability and confidentiality of the data annotation are guaranteed by encrypting the data annotation. For example, a symmetric cryptographic algorithm such as AES (Advanced Encryption Standard, Advanced Encryption Standard) is used, but not limited to, to encrypt the data annotation. All blocks corresponding to the blockchain share the AES key, which is to ensure that other blocks can read the data annotation through decryption during the propagation of the original data.

After the data annotation of the original data is generated, the data annotation is embedded into the original data, so that the data annotation is invisible and closely integrated with the original data, becoming an inseparable part of the original data, reducing the cost of repeatedly generating data annotations, and facilitating traceability information records The interactive process of raw data. However, considering that the hidden embedding method of data annotation strengthens the protection of data annotation and does not affect the viewing of original data, it will change the original data and may cause integrity problems. In order not to affect the use of the original data after the data annotation is embedded and to operate the original data without affecting the integrity of the data annotation, this embodiment relies on the file format where the original data is located, and writes the annotation in the remark of the detailed information of the file attribute. It not only facilitates the reading of data annotations, but also avoids damage to the original data.

Taking the original data obtained by fragmenting the data stream as an example, the process from fragmenting the data stream to writing the data label to the original data is shown in Figure 2, which may include the following steps:

201: When the data stream is obtained through monitoring, segment the data stream to obtain original data in multiple preset formats. For example, use but not limited to use the FileSystemWatcher class provided by .net to monitor data stream uploads. When a data stream upload is detected (that is, it is regarded as a data stream), ffmpeg is used to fragment the data stream to form multiple mp4 format raw data. Fragmenting a data stream can be to fragment a data stream set composed of multiple data streams to obtain a data stream as the original data; or to fragment a data stream to obtain multiple fragments of a data stream, Each fragment is considered a data stream.

202: Obtain the IP and Port of the uploaded data stream, such as using but not limited to .net to obtain the IP and Port of the file data stream.

203: Obtain the creation time Time and creator Creator of the data flow, for example, use but not limited to Microsoft.WindowsAPICodePack.Shell to obtain the creation time Time and creator Creator of the data flow.

204: Use a clustering analysis algorithm to group the original data, and assign the corresponding attribute information to the original data based on the data group where the original data is located. For example, use a clustering analysis algorithm to group the original data based on but not limited to IP, Port and Creator.

205: Determine the Hash of the original data, such as using but not limited to the md5 algorithm in Security.Cryptography to hash the original data to obtain the Hash.

206: Determine the Patent of the original data.

207: Connect IP, Port, Creator, Hash, Time, Attrib and Patent together to form a data Annotation in string format, that is, Annotation {IP, Port, Creator, Hash, Time, Attrib, Patent}.

208: Encrypt the Annotation, for example, encrypt the generated Annotation by using but not limited to AES.

209: Use Microsoft.WindowsAPICodePack.Shell to modify the remark in the detailed information of the file attribute, and write the encrypted data annotation into the remark.

From the generation process of the data label shown in Figure 2, it can be seen that the data label in this embodiment has: (1) uniqueness, (2) unforgeability, (3) confidentiality, (4) the original data will not be affected after embedding Use, (5) operations on the original data do not affect the integrity of the label.

In this embodiment, methods for obtaining query conditions based on data annotation include but are not limited to the following methods:

One method is to determine the data annotation as the query condition; the other method is to obtain the query condition based on the parameter value in the data annotation, such as selecting at least one parameter value from the data annotation as the query condition, such as selecting Time from the data annotation At least one parameter among , Attrib, etc. is used as a query condition.

102: Based on the query conditions, start to query the traceability information corresponding to the query conditions from the blockchain. In this embodiment, each block of the blockchain stores traceability information containing data annotations corresponding to the original data, so the traceability information corresponding to the query conditions is the traceability information in the block where the data annotations containing the query conditions are located.

For example, the blockchain includes N blocks. In the process of querying the traceability information corresponding to the query condition from the blockchain, if a storage identifier corresponding to the data marked by the query condition is i, then query the i-th block of the blockchain The traceability information stored in the block, and obtain the storage identifier stored in this block, which is j; then query the traceability information stored in the jth block of the blockchain, and obtain the storage identifier stored in this block, Then query the block of the corresponding blockchain according to the storage identifier until the value of the storage identifier stored in the obtained block is empty.

103: If the traceability information corresponding to the query condition is queried from a block of the blockchain, use the traceability information corresponding to the query condition as the current traceability information.

104: Obtain the storage identifier of another piece of traceability information related to the current traceability information from the block storing the current traceability information.

In this embodiment, during the storage process, any block in the blockchain not only stores traceability information containing data annotations, but also stores another piece of traceability information that contains the same data annotations as the traceability information stored in the block. After the traceability information is queried based on the query conditions, the storage identifier of another piece of traceability information related to it can be obtained from the block that stores the queried traceability information, so as to obtain another piece of traceability information from the block pointed to by the storage identifier. A piece of traceability information, so that traceability information can be obtained directly based on the storage identifier, eliminating the need to traverse all blocks in the blockchain and improving query efficiency.

105: Based on the storage identifier of another piece of traceability information, obtain another piece of traceability information from the block pointed to by the storage identifier, and use another piece of traceability information as the current traceability information, return and continue to execute the acquisition from the block that stores the current traceability information. The storage identifier of another piece of traceability information related to the current traceability information until the value of the storage identifier obtained from the block is empty.

106: Output all the traceability information found in the query. For example, one way to output all traceability information queried is to integrate all traceability information according to the query order of all traceability information, and output all traceability information after integration. The query order of all traceability information is based on the storage ID corresponding to the traceability information Sure. For example, the above-mentioned storage identifiers can indicate the query order of the traceability information, so based on the storage identifier corresponding to each traceability information, the query sequence can be obtained, thereby determining the arrangement order of the traceability information, and based on the arrangement information between the traceability information. information is integrated.

In order to improve the confidentiality and query efficiency of traceability information, this embodiment builds an index database, which is used to store each data label and the storage identifier corresponding to the previous traceability information, such as the block number of the block where it is located, and the block number of the block where it is located. The block number of the block is stored in the index database as an index value, and the last traceability information is relative to the currently obtained traceability information, which is the traceability stored in the block last time and corresponding to the same data label as the currently obtained traceability information information.

If the data annotation is used as the query condition, the query process based on the index database is shown in Figure 3: the index value corresponding to the data annotation used as the query condition is obtained from the index database, and the index value corresponding to the obtained index value is determined from the blockchain. block, and obtain the traceability information and the block number of the block where the previous traceability information is located from the block; according to the block number of the block where the last traceability information is located, obtain the traceability information and another block from the corresponding block block number, and so on, until the block number of the obtained block is empty, indicating that all traceability information of this query has been obtained, and the query is stopped. The query based on the index value can avoid the query of useless data when traversing the query blockchain, and improve the speed of traceability information query.

In addition, in addition to using data annotations as query conditions, query conditions can also be obtained based on data annotations, such as selecting at least one parameter value from data annotations as query conditions, such as the same field in data annotations as a storage association, such as a time or The same creator, etc., so that the query conditions obtained based on data annotation realize the query of traceability information from multiple aspects, such as traceability for the same data stream (such as through the Patent), and for the same task (such as through the creator and IP, etc.), for the traceability of data in the same period of time, etc., trace the data from multiple aspects, connect the traceability information in parallel, and complete the full use of the traceability information, such as analyzing the traceability information after query to clarify the data flow path to assess the reliability of the data.

And the hash value of the original data is included in the data label, and the traceability information cannot be obtained when the original data is tampered with; when the original data is not tampered with, the complete and true traceability information can be obtained from the blockchain, so that the traceability information The verification of the authenticity of the original data is also included in the query process. The data annotation also includes the upper-level data identification information. For some analytical data, the upper-level data identification information can be used to know what kind of data it is analyzed from, so that it can also be inferred whether the analysis of these data is correct. Correct the problem and determine the responsibility for the error.

With the above technical solution, the data label corresponding to the data to be queried is obtained, and the query condition is obtained based on the data label. Based on the query condition, the traceability information corresponding to the query condition is queried from the blockchain. If you query from a block of the blockchain Find the traceability information corresponding to the query condition, take the traceability information corresponding to the query condition as the current traceability information, and obtain the storage identifier of another piece of traceability information related to the current traceability information from the block storing the current traceability information, based on the other piece of traceability information Store the ID, get another piece of traceability information from the block pointed to by the storage ID, and use another piece of traceability information as the current traceability information, and return to continue execution to obtain another piece of traceability information related to the current traceability information from the block that stores the current traceability information From the storage identifier of the information until the value of the storage identifier obtained from the block is empty, all the traceability information queried is output, so that all relevant traceability information can be obtained during the query process based on the query conditions obtained from the data annotation. That is, all relevant traceability information can be queried during a traceability information query process. In this way, for the data to be queried through sharding, even if the hash values of each data to be queried are different, the data corresponding to one piece of data to be queried By marking the query conditions, all relevant traceability information can be obtained, and the associated query of traceability information can be realized.

Please refer to Fig. 4, which shows a flow chart of another traceability information association query method provided by the embodiment of the present application, and illustrates the process of storing data annotation and traceability information, which may include the following steps:

301: After obtaining a piece of traceability information containing the data label corresponding to the original data, query whether the data label corresponding to the original data is stored in the block of the blockchain. It is understandable that traceability information is a record of a certain processing process of raw data, so each time a piece of raw data is processed, a piece of traceability information will be generated. The purpose of querying whether the original data corresponding to the original data is stored in the block of the blockchain is to obtain the storage identifier of the block that stores the same original data in the process of storing the traceability information, so that the query process can be based on a Data labeling queries all relevant traceability information.

302: If there is no data label corresponding to the original data stored in the block of the blockchain, the traceability information and storage identification containing the data label corresponding to the original data are stored in a block of the blockchain, and the Storage ID is empty.

If the data label corresponding to the original data is not stored in the block of the blockchain, it means that the data label corresponding to the original data has not been stored in the blockchain, and it is the first time to store traceability information containing the data label corresponding to the original data. And there is no data annotation corresponding to the original data stored in the block of the blockchain before, which means that the value of the storage identifier cannot be obtained, and the storage identifier is empty.

303: If there is a data label corresponding to the original data stored in the block of the blockchain, obtain the storage identifier of the block that stores the traceability information of the previous data label corresponding to the original data, and combine the acquired storage identifier with the currently obtained The traceability information containing the data annotation corresponding to the original data is stored in a block of the blockchain.

If the data label corresponding to the original data is stored in the block of the blockchain, it means that the data label corresponding to the original data has been stored in the blockchain, which also means that the traceability information of the original data is stored in the blockchain, and you can obtain Store the storage identifier of the previous traceability information containing the data annotation corresponding to the original data, and store the obtained storage identifier and the currently obtained traceability information containing the data annotation corresponding to the original data in a block of the blockchain. Among them, the previous traceability information containing the data annotation corresponding to the original data is relative to the currently obtained traceability information. If the traceability information containing data label A is currently obtained, by searching the blocks of the blockchain, it is determined that the traceability information of the last stored data label A is stored in the block of the blockchain for the jth time, and then the jth time is obtained The stored data is marked with the storage identifier of the block of A's traceability information.

In this embodiment, but not limited to, the index database can be used to store each data label and the storage identifier corresponding to the traceability information. The block number of the block where the traceability information is located is used as a form of storage identifier, and the corresponding query Whether the data label corresponding to the original data is stored in the block of the blockchain can be found from the index database. If the data label corresponding to the original data is stored in the index database, the data label corresponding to the stored original data and The block number of the previous block containing the traceability information corresponding to the original data, and the block number is used as the storage identifier of the latest block containing the traceability information corresponding to the original data, and the acquired block The serial number storage identifier and the currently obtained traceability information containing the data annotation corresponding to the original data are stored in a block of the blockchain.

In the process of storing the obtained block number storage identifier and the traceability information containing the data label corresponding to the original data in the block of the blockchain, the index database is updated, and the index value of the currently stored data marked in the index database is updated It is the block number of the block that stores the traceability information this time/currently, so that all relevant traceability information can be queried based on a data label during the query process.

During the storage process, the smart contract can be called to store the traceability information and the storage identifier containing the data label together in the block body of the blockchain, and the return function in the smart contract can be called to return the current storage traceability information and the storage identifier. The block number of the block, the corresponding index value marked in the index database is updated to the block number of the block returned by the return function at this time, and a traceability generated by each operation of each original data The information is stored in a block, and finally forms a traceability chain, as shown in Figure 5.

304: Obtain data annotations corresponding to the data to be queried, and obtain query conditions based on the data annotations. The data annotation corresponding to the data to be queried may be the data annotation corresponding to a piece of original data stored in the blockchain.

305: Based on the query conditions, start to query the traceability information corresponding to the query conditions from the blockchain.

306: Query the traceability information corresponding to the query condition from a block of the blockchain, and use the traceability information corresponding to the query condition as the current traceability information.

307: Obtain the storage identifier of another piece of traceability information related to the current traceability information from the block storing the current traceability information.

308: Based on the storage identifier of another piece of traceability information, obtain another piece of traceability information from the block pointed to by the storage identifier, and use another piece of traceability information as the current traceability information, return and continue to execute the acquisition from the block storing the current traceability information. The storage identifier of another piece of traceability information related to the current traceability information until the value of the storage identifier obtained from the block is empty.

309: Output all traceability information found in the query.

With the above technical solution, the storage of traceability information labeled with each piece of data containing original data is realized through the block chain, and the association between the traceability information of the same original data is established through the storage identification, so as to facilitate the traceability of the traceability information. Association query. And in the process of using blockchain technology to store traceability information, all blocks on the chain store traceability information. Once the traceability information in a block is tampered with, it can pass the verification information in other blocks (the area of the block) The block header carries verification information, and the block body stores data labeling and traceability information) for verification. Through this decentralized blockchain technology, the reliability of traceability information is improved.

For the aforementioned method embodiments, for the sake of simple description, they are expressed as a series of action combinations, but those skilled in the art should know that the application is not limited by the described action sequence, because according to the application, Certain steps may be performed in other orders or simultaneously. Secondly, those skilled in the art should also know that the embodiments described in the specification belong to preferred embodiments, and the actions and modules involved are not necessarily required by this application.

Please refer to FIG. 6, which shows an optional structure of a traceability information association query device provided by the embodiment of the present application, which may include: a condition obtaining unit 10, a first query unit 20, a determination unit 30, and a second query unit 40 and output unit 50 .

The condition obtaining unit 10 is used to obtain the data annotation corresponding to the data to be queried, and obtain the query condition based on the data annotation; wherein the way for the condition obtaining unit 10 to obtain the query condition includes but is not limited to: determining the data annotation as the query condition; or based on the data annotation Parameter values in to get the query conditions.

The generation process of data annotation includes: obtaining the attribute information of the original data, the flow characteristic parameter information of the original data, the upper-level data identification information of the original data and the verification information of the original data, and the flow characteristic parameter information is used to indicate the transmission of the original data and creation process, the upper-level data identification information is used to indicate the upper-level data that generates the original data, and the verification information of the original data is used to verify the integrity of the original data; based on attribute information, flow characteristic parameter information, and upper-level data Identification information and verification information to generate data annotations for original data. One way of writing the data annotation is: writing the data annotation of the original data into the file attribute of the original data.

The data annotation of the original data can be generated based on the following methods:

Annotation{IP,Port,Creator,Hash,Time,Attrib,Patent};

IP, Port, Creator, and Time are stream characteristic parameter information, IP indicates the source IP address corresponding to the original data, Port indicates the source port number corresponding to the original data, Creator indicates the creator of the original data, Time indicates the creation time of the original data, and Attrib is attribute information, Patent is upper-level data identification information, and Hash is verification information.

The first query unit 20 is configured to start querying the traceability information corresponding to the query condition from the block chain based on the query condition;

The determining unit 30 is configured to use the traceability information corresponding to the query condition as the current traceability information if the traceability information corresponding to the query condition is found from a block of the blockchain.

The second query unit 40 is used to obtain the storage identifier of another piece of traceability information related to the current traceability information from the block storing the current traceability information; based on the storage identifier of another piece of traceability information, obtain from the block pointed to by the storage identifier Another piece of traceability information, and take another piece of traceability information as the current traceability information, return and continue to execute from the block storing the current traceability information to obtain the storage identifier of another piece of traceability information related to the current traceability information until the storage obtained from the block The value of the ID is empty.

The output unit 50 is configured to output all traceability information found in the query. One output method is: according to the query sequence of all traceability information, integrate all traceability information, and output all the traceability information after integration, and the query sequence of all traceability information is determined by the storage identifier corresponding to the traceability information.

The above-mentioned traceability information association query device also includes: a storage unit, which is used to store the current The obtained traceability information and storage identifier containing the data label corresponding to the original data are stored in a block of the blockchain, and the storage identifier in the block is empty, and if the original data is stored in the block of the blockchain For the corresponding data annotation, obtain the storage ID of the block that stores the traceability information of the previous data annotation corresponding to the original data, and store the obtained storage ID and the currently obtained traceability information containing the data annotation corresponding to the original data in the block in a block of the blockchain.

One way to obtain the storage identifier of the block that stores the last traceability information that contains the data label corresponding to the original data is to obtain the location where the data label corresponding to the original data and the last traceability information that contains the data label corresponding to the original data are located The block number of the block, the block number is used as the storage identifier of the last block containing the traceability information of the data label corresponding to the original data.

The above traceability information associated query device obtains the data annotation corresponding to the data to be queried, obtains the query condition based on the data annotation, and starts to query the traceability information corresponding to the query condition from the blockchain based on the query condition. If from a block of the blockchain Query the traceability information corresponding to the query condition, use the traceability information corresponding to the query condition as the current traceability information, and obtain the storage identifier of another traceability information related to the current traceability information from the block storing the current traceability information, based on another traceability information storage ID, obtain another piece of traceability information from the block pointed to by the storage ID, and use another piece of traceability information as the current traceability information, and return to continue execution to obtain another piece of traceability information related to the current traceability information from the block that stores the current traceability information From the storage identifier of the traceability information until the value of the storage identifier obtained from the block is empty, output all the traceability information queried, so that all relevant traceability information can be obtained during the query process based on the query conditions obtained from the data annotation , that is, all relevant traceability information can be queried during a traceability information query process. In this way, for the data to be queried through sharding, even if the hash values of each data to be queried are different, the corresponding hash value of a piece of data to be queried The query conditions obtained by data annotation can obtain all relevant traceability information and realize the associated query of traceability information.

An embodiment of the present application also provides a server, including: a processor and a memory for storing processor-executable instructions; wherein, the processor is configured to execute the instructions, so as to implement the above-mentioned traceability information association query method.

The embodiment of the present application also provides a storage medium, in which computer program codes are stored, and when the computer program codes are executed, the above-mentioned source tracing information correlation query method is implemented.

It should be noted that each embodiment in this specification can be described in a progressive manner, and the features recorded in each embodiment in this specification can be replaced or combined with each other, and each embodiment focuses on the difference with other embodiments. For differences, the same and similar parts of the various embodiments may be referred to each other. As for the device-type embodiments, since they are basically similar to the method embodiments, the description is relatively simple, and for related parts, please refer to part of the description of the method embodiments.

Finally, it should also be noted that in this text, relational terms such as first and second etc. are only used to distinguish one entity or operation from another, and do not necessarily require or imply that these entities or operations, any such actual relationship or order exists. Moreover, the terms "comprising", "comprising" or any other variation thereof are intended to encompass a non-exclusive inclusion such that a process, method, article or device that includes a list of elements includes not only those elements, but also includes not explicitly listed or other elements inherent to such a process, method, article or apparatus. Without further limitation, an element qualified by the phrase "comprising a..." does not preclude the presence of additional identical elements in a process, method, article or apparatus that includes the element.

The above description of the disclosed embodiments is provided to enable any person skilled in the art to make or use the present application. Various modifications to these embodiments will be readily apparent to those skilled in the art, and the general principles defined herein may be implemented in other embodiments without departing from the spirit or scope of the application. Therefore, this application is not intended to be limited to the embodiments shown herein, but is to be accorded the widest scope consistent with the principles and novel features disclosed herein.

The above description is only the preferred embodiment of the present application. It should be pointed out that for those of ordinary skill in the art, without departing from the principle of the present application, some improvements and modifications can also be made. These improvements and modifications are also It should be regarded as the protection scope of this application.

Claims (9)

1. A method for associative query of traceability information, characterized in that the method comprises: Obtaining data annotations corresponding to the data to be queried, and obtaining query conditions based on the data annotations; Based on the query conditions, starting to query the traceability information corresponding to the query conditions from the block chain; If the traceability information corresponding to the query condition is found from a block of the blockchain, the traceability information corresponding to the query condition is used as the current traceability information; Obtain the storage identifier of another piece of traceability information related to the current traceability information from the block storing the current traceability information; Based on the storage identifier of the other piece of traceability information, obtain the other piece of traceability information from the block pointed to by the storage identifier, and use the other piece of traceability information as the current traceability information, and return to continue execution from storing the current traceability information. Obtain the storage identifier of another piece of traceability information related to the current traceability information in the block of the traceability information until the value of the storage identifier obtained from the block is empty; Output all traceability information queried; Wherein, the generating process of the data annotation includes: obtaining the attribute information of the original data, the flow characteristic parameter information of the original data, the upper-level data identification information of the original data, and the verification information of the original data, so The stream characteristic parameter information is used to indicate the transmission and creation process of the original data, the upper-level data identification information is used to indicate the upper-level data that generates the original data, and the verification information of the original data is used for Verifying the integrity of the original data; generating data annotations of the original data based on the attribute information, the stream characteristic parameter information, the upper-level data identification information, and the verification information. 2. The method according to claim 1, characterized in that the method further comprises: After currently obtaining a piece of traceability information containing the data label corresponding to the original data, query whether the data label corresponding to the original data is stored in the block of the block chain; If the data label corresponding to the original data is not stored in the block of the block chain, the currently obtained traceability information and storage identification containing the data mark corresponding to the original data are stored in one of the block chain in the block, and the storage identifier in the block is empty; If the data label corresponding to the original data is stored in the block of the blockchain, the storage identification of the block that stores the traceability information of the previous data label corresponding to the original data is obtained, and the acquired storage The identification and the currently obtained traceability information containing the data label corresponding to the original data are stored in a block of the blockchain. 3. The method according to claim 2, wherein said obtaining and storing the storage identifier of the block containing the traceability information corresponding to the data label corresponding to the original data comprises: Obtain the data label corresponding to the stored original data and the block number of the block where the previous traceability information containing the data label corresponding to the original data is located, and use the block number as the last data containing the original data corresponding The storage identifier of the marked traceability information block. 4. The method according to claim 1, further comprising: writing the data annotation of the original data into the file attribute of the original data. 5. The method according to claim 4, wherein the original data is generated based on the attribute information, the stream characteristic parameter information, the upper-level data identification information and the verification information The data annotations include: The data annotation of the original data is generated based on the following manner: Annotation{IP, Port, Creator, Hash, Time, Attrib, Patent }; IP, Port, Creator, and Time are flow feature parameter information, IP represents the source IP address corresponding to the original data, Port represents the source port number corresponding to the original data, Creator represents the creator of the original data, and Time represents the The creation time of the original data, Attrib is the attribute information, Patent is the upper-level data identification information, and Hash is the verification information. 6. The method according to any one of claims 1 to 5, wherein said outputting all traceability information queried comprises: integrating all traceability information according to the query order of all traceability information, and outputting For all traceability information after integration, the query order of all traceability information is determined by the storage identifier corresponding to the traceability information. 7. The method according to any one of claims 1 to 5, wherein said obtaining query conditions based on said data annotation comprises: determining the data annotation as the query condition; or The query condition is obtained based on the parameter value in the data annotation. 8. A traceability information association query device, characterized in that the device comprises: A condition obtaining unit, configured to obtain data annotations corresponding to the data to be queried, and obtain query conditions based on the data annotations; The first query unit is configured to start querying the traceability information corresponding to the query condition from the block chain based on the query condition; A determining unit, configured to use the traceability information corresponding to the query condition as the current traceability information if the traceability information corresponding to the query condition is found from a block of the blockchain; The second query unit is used to obtain the storage identifier of another piece of traceability information related to the current traceability information from the block storing the current traceability information; based on the storage identifier of the other piece of traceability information, from the stored Obtain the other piece of traceability information from the block pointed to by the identifier, and use the other piece of traceability information as the current traceability information, and return to continue execution to obtain the information related to the current traceability information from the block storing the current traceability information. The storage identifier of another piece of traceability information until the value of the storage identifier obtained from the block is empty; The output unit is used to output all traceability information found in the query; Wherein, the generating process of the data annotation includes: obtaining the attribute information of the original data, the flow characteristic parameter information of the original data, the upper-level data identification information of the original data, and the verification information of the original data, so The stream characteristic parameter information is used to indicate the transmission and creation process of the original data, the upper-level data identification information is used to indicate the upper-level data that generates the original data, and the verification information of the original data is used for Verifying the integrity of the original data; generating a data annotation of the original data based on the attribute information, the stream characteristic parameter information, the upper-level data identification information and the verification information. 9. A server, characterized in that, comprising: processor; memory for storing said processor-executable instructions; Wherein, the processor is configured to execute the instructions, so as to realize the traceability information association query method according to any one of claims 1-7.

Images