System and method for blockchain-based data synchronization

Patent metadata

Field	Value
Publication number	US-11429617-B2
Application number	US-202017128244-A
Country	US
Kind code	B2
Filing date	Dec 21, 2020
Priority date	Nov 8, 2019
Publication date	Aug 30, 2022
Grant date	Aug 30, 2022

Abstract

Methods, systems, and apparatus, including computer programs encoded on computer storage media, for blockchain-based data synchronization, are provided. One of the methods includes: obtaining, from one or more blockchain nodes associated with a blockchain, data associated with a plurality of blockchain transactions recorded in one or more blocks of the blockchain; storing the obtained data in one or more data stores, wherein the storing comprises organizing the obtained data according to one or more schemas, at least one of the one or more schemas being different from a data structure of the blockchain; receiving, from a client device, a data query based on one of the one or more schemas; executing the data query on the data in the one or more data stores to obtain a result; and sending, to the client device, a response comprising the obtained result.

First claim

The invention claimed is:

1. A computer-implemented method for blockchain-based data synchronization, comprising:
obtaining, from one or more blockchain nodes associated with a blockchain, data associated with a plurality of blockchain transactions recorded in one or more blocks of the blockchain;
storing the obtained data in one or more data stores, wherein the storing comprises organizing the obtained data according to one or more schemas, at least one of the one or more schemas being different from a data structure of the blockchain, and the organizing the obtained data comprises:
obtaining interface definitions associated with one or more blockchain contracts invoked by a blockchain transaction, wherein one or more blockchain contracts each comprise instructions executable by a virtual machine associated with the blockchain and the interface definitions specify one or more input types and one or more output types associated with the one or more blockchain contracts;
resolving the blockchain transaction based on the obtained interface definitions associated with the one or more blockchain contracts to obtain one or more inputs and one or more return values; and
storing the one or more inputs and the one or more return values in association with the data associated with the blockchain transaction;

receiving, from a client device, a data query based on one of the one or more schemas;
executing the data query on the data in the one or more data stores to obtain a result; and
sending, to the client device, a response comprising the obtained result.

2. A non-transitory computer-readable storage medium for blockchain-based data synchronization, configured with instructions executable by one or more processors to cause the one or more processors to perform operations comprising:
obtaining, from one or more blockchain nodes associated with a blockchain, data associated with a plurality of blockchain transactions recorded in one or more blocks of the blockchain;
storing the obtained data in one or more data stores, wherein the storing comprises organizing the obtained data according to one or more schemas, at least one of the one or more schemas being different from a data structure of the blockchain, and organizing the obtained data comprises:
obtaining interface definitions associated with one or more blockchain contracts invoked by a blockchain transaction, wherein one or more blockchain contracts each comprise instructions executable by a virtual machine associated with the blockchain and the interface definitions specify one or more input types and one or more output types associated with the one or more blockchain contracts;
resolving the blockchain transaction based on the obtained interface definitions associated with the one or more blockchain contracts to obtain one or more inputs and one or more return values; and
storing the one or more inputs and the one or more return values in association with the data associated with the blockchain transaction;

receiving, from a client device, a data query based on one of the one or more schemas;
executing the data query on the data in the one or more data stores to obtain a result; and
sending, to the client device, a response comprising the obtained result.

3. A system for blockchain-based data synchronization, comprising a processor and a non-transitory computer-readable storage medium storing instructions executable by the processor to cause the system to:
obtain, from one or more blockchain nodes associated with a blockchain, data associated with a plurality of blockchain transactions recorded in one or more blocks of the blockchain;
store the obtained data in one or more data stores, wherein the storing comprises organizing the obtained data according to one or more schemas, at least one of the one or more schemas being different from a data structure of the blockchain, and the organizing the obtained data comprises:
obtaining interface definitions associated with one or more blockchain contracts invoked by a blockchain transaction, wherein one or more blockchain contracts each comprise instructions executable by a virtual machine associated with the blockchain and the interface definitions specify one or more input types and one or more output types associated with the one or more blockchain contracts;
resolving the blockchain transaction based on the obtained interface definitions associated with the one or more blockchain contracts to obtain one or more inputs and one or more return values; and
storing the one or more inputs and the one or more return values in association with the data associated with the blockchain transaction;

receive, from a client device, a data query based on one of the one or more schemas;
execute the data query on the data in the one or more data stores to obtain a result; and
send, to the client device, a response comprising the obtained result.

4. The method of claim 1 , wherein the organizing the obtained data according to the one or more schemas comprises:
ordering the data associated with the blockchain transactions based on a height of a block in the blockchain that records each of the blockchain transactions.

5. The method of claim 1 , wherein one or more of the blockchain transactions each invokes one or more blockchain contracts associated with the blockchain, and wherein the organizing the obtained data according to the one or more schemas comprises:
categorizing data associated with the one or more blockchain transactions based on the one or more blockchain contracts.

6. The method of claim 1 , wherein one or more of the blockchain transactions each comprises one or more identifiers respectively associated with one or more blockchain accounts associated with the blockchain, and wherein the organizing the obtained data according to the one or more schemas comprises:
categorizing the data associated with the one or more blockchain transactions based on the one or more identifiers in each of the blockchain transactions.

7. The method of claim 1 , wherein the organizing the obtained data according to the one or more schemas comprises:
categorizing the data associated with the blockchain transactions based on a type of each of the blockchain transactions.

8. The method of claim 1 , further comprising:
determining that a block is newly added to the blockchain;
obtaining data associated with a plurality of blockchain transactions recorded in the newly-added block; and
updating the one or more data stores based on the blockchain transactions recorded in the newly-added block.

9. The method of claim 1 , wherein the storing the obtained data in one or more data stores comprises:
storing the obtained data redundantly according to a hierarchical structure.

10. The method of claim 1 , wherein the organizing the obtained data according to the one or more schemas comprises:
generating one or more indices respectively associated with the one or more schemas; and
storing the one or more indices in the one or more data stores.

11. The method of claim 1 , further comprising, before receiving the data query based on the one of the one or more schemas:
receiving, from the client system, a request for the one of the one or more schemas; and
sending, to the client system, a specification of the one of the one or more schemas.

12. The method of claim 1 , wherein the executing the data query on the data in the one or more data stores to obtain the result comprises:
identifying a subset of the data in the one or more data stores based on the data query;
performing one or more data operations on the identified subset of the data; and
determining the result bas

Assignees

• Alipay Hangzhou Inf Tech Co Ltd

Inventors

• Sun Shanlu
• Li Shubo

Classifications

• G06F16/9014

  hash tables · CPC title

• G06F9/547

  Remote procedure calls [RPC]; Web services · CPC title

• G06Q40/04

  Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange · CPC title

• G06F9/466

  Transaction processing · CPC title

• G06F16/116

  Details of conversion of file system types or formats · CPC title