Extracting data from a blockchain network

Patent metadata

Field	Value
Publication number	US-11921682-B2
Application number	US-202217931567-A
Country	US
Kind code	B2
Filing date	Sep 13, 2022
Priority date	Apr 24, 2019
Publication date	Mar 5, 2024
Grant date	Mar 5, 2024

Abstract

According to at least one embodiment, a method, computer system, and computer program product for model-driven extraction of event data by a computational device is provided. The present invention may include transforming event data of an event occurring on a blockchain network using an event schema to comply with a data model of an external data structure; mapping, based on the event schema and the data model, the event data to a logical structure of the external data structure; and loading the transformed event data to the external data structure to modify a data content of the external data structure based on the mapping.

First claim

What is claimed is:

1. A method for performing a model-driven extraction of event data by a computational device, the method comprising:
transforming event data of an event occurring on a blockchain network using an event schema to comply with a data model of an external data structure;
mapping, based on the event schema and the data model, the event data to a logical structure of the external data structure; and
loading the transformed event data to the external data structure to modify a data content of the external data structure based on the mapping.

2. The method of claim 1 , further comprising:
messaging the transformed event data to an external computational device external to the blockchain network, wherein the external computational device manages the external data structure.

3. The method of claim 1 , further comprising:
generating ETL-code for the event using the mapping.

4. The method of claim 1 wherein the computational device is inside the blockchain network as an ETL-peer.

5. The method of claim 4 , wherein the computational device is an external computational device configured to monitor data exchanged on the blockchain network using a cryptographically secured messaging connection to a peer of the blockchain network.

6. The method of claim 4 , wherein the event is detected by identifying the event data being provided by the ETL-peer to be added to a blockchain as part of a block of the blockchain.

7. The method of claim 4 , wherein the event is detected by monitoring data being routed on the blockchain network via the ETL-peer using a communication protocol of the blockchain network.

8. The method of claim 1 , wherein the event schema is determined using a library providing one or more event schemas identifying logical structures of event data representing one or more types of events potentially occurring on the blockchain network.

9. The method of claim 8 , further comprising:
responsive to determining that none of the one or more event schemas provided by the library match the logical structure of the event data of the event, analyzing the logical structure of the event data of the event;
determining an additional event schema matching the logical structure of the event data of the event; and
adding the additional event schema to the library.

10. The method of claim 1 , wherein the event schema is determined based on tagging one or more data elements comprising the event data using the event schema, wherein tags identify one or more structural types of data elements defined by the event schema.

11. The method of claim 10 , wherein the tags map tagged data elements to one or more structural elements defined by the logical structure of the external data structure.

12. The method of claim 1 , wherein the external data structure is provided as a database and a database management system for managing the database using the data model.

13. The method of claim 12 , wherein the data model used by the database management system for managing the database is selected from a list consisting of:
a relational data model, a hierarchical data model, a network data model, an object-oriented data model, a graph data model, an entity-relationship model data model, a key value data model, a multidimensional data model, a column-oriented data model, a document oriented data model, and a data stream data model.

14. The method of claim 1 , wherein the transforming of the event data comprises:
adding one or more structural IDs according to the data model to the event data.

15. The method of claim 1 , further comprising:
responsive to determining that the event comprises a data delete, executing a callback to retrieve a plurality of additional data from the blockchain network;
identifying, based on the additional data, one or more data elements to be deleted from the external data structure to modify the data content of the external data structure in accordance with the data delete.

16. The method of claim 15 , wherein the callback targets a blockchain provided by the blockchain network or a local data collection provided by a peer of the blockchain network.

17. The method of claim 1 , wherein the event data is extracted from a block of a blockchain provided by the blockchain network.

18. The method of claim 17 , wherein the blockchain is a permissioned blockchain with restricted access to extract data from the blockchain, wherein the computational device is registered and comprises access rights enabling the computational device to extract data from the blockchain.

19. The method of claim 17 , wherein the blockchain comprises encrypted data, wherein the computational device has access to a decryption key, and wherein the event data is extracted by decrypting the event data.

20. The method of claim 17 , wherein the event data is extracted based on retrieving a plurality of additional event data from a local data collection provided by a peer of the blockchain network, wherein the additional event data is assigned to the event data extracted from the block of the blockchain.

21. The method of claim 20 , wherein the local data collection is a private data collection shared by a limited set of peers of the blockchain network, and wherein private data of the private data collection is routed using cryptographically secured communication connections restricted to use by one or more peers of the limited set of peers.

22. The method of claim 1 , wherein the loading comprises a write request using the transformed event data.

23. The method of claim 22 , wherein the write request comprises a request selected from a list consisting of:
updating a data element of the data content of the external data structure using the transformed data, deleting a data element of the data content of the external data structure identified by the transformed data, inserting an additional data element provided by the transformed data into the data content of the external data structure.

24. A computer program product for performing a model-driven extraction of event data by a computational device, the computer program product comprising:
one or more computer-readable tangible storage media and program instructions stored on at least one of the one or more tangible storage media, the program instructions executable by a processor to cause the processor to perform a method comprising:
transforming event data of an event occurring on a blockchain network using an event schema to comply with a data model of an external data structure;
mapping, based on the event schema and the data model, the event data to a logical structure of the external data structure; and
loading the transformed event data to the external data structure to modify a data content of the external data structure based on the mapping.

25. A computer system for performing a model-driven extraction of event data by a computational device, the computer system comprising:
one or more processors, one or more computer-readable memories, one or more computer-readable tangible storage medium, and program instructions stored on at least one of the one or more tangible storage medium for execution by at least one of the one or more processors via at least one of the one or more memories, wherein the computer system is capable of performing a method comprising:
transforming event data of an event occurring on a blockchain network using an event schema to comply with a data model

Assignees

• IBM

Inventors

• Oberhofer Martin Anton
• Mentzel Florian
• Pham The Hien
• Thevarajah Thishanth

Classifications

• G06F16/212 Primary

  with details for data modelling support · CPC title

• G06F16/254 Primary

  Extract, transform and load [ETL] procedures, e.g. ETL data flows in data warehouses · CPC title

• G06F16/28

  Databases characterised by their database models, e.g. relational or object models · CPC title

• H04L63/0428

  wherein the data content is protected, e.g. by encrypting or encapsulating the payload · CPC title

• G06Q2220/00

  Business processing using cryptography · CPC title