Data processing method, apparatus, and device

1. A data processing method for transferring data from different predetermined data sources that employ different data storage technologies to a blockchain for storage and for improving reliability, comprising:

receiving, by a decentralized node, a query parameter corresponding to target data;

obtaining, by the decentralized node, different pieces of query result data corresponding to the target data from each of the different predetermined data sources that employ different data storage technologies according to the query parameter;

converting, by the decentralized node, the different pieces of query result data into target reliable data conforming to a predetermined data reliability protocol by converting a data format of each of the different pieces of query result data; and

sending, by the decentralized node, the target reliable data to a blockchain node for storage in the blockchain.

2. The method according to claim 1 , wherein the predetermined data sources that employ different data storage technologies include: a data source based on an operation support system (OSS), a data source based on a hadoop distributed file system (HDFS), a data source based on a private blockchain, a data source based on a consortium blockchain, and a data source based on a public blockchain.

3. The method according to claim 1 , wherein the query result data includes: ReadWriteSet data in a Fabric cluster node, simplified payment verification (SPV) data in an Ethereum (ETH) cluster node, transaction information stored on a consortium blockchain of a non-account model, and corresponding data in an OSS cluster.

4. The method according to claim 1 , further comprising:

receiving, by the blockchain node, the target reliable data from the decentralized node;

parsing, by the blockchain node, the target reliable data to obtain the query result data; and

performing, by the blockchain node, computing on the query result data to obtain a target query result corresponding to the query parameter.

5. The method according to claim 4 , further comprising:

receiving, by the blockchain node from a user, a query request comprising the query parameter; and

sending, by the blockchain node, the target query result corresponding to the query parameter to the user.

6. The method according to claim 4 , wherein performing the computing on the query result data to obtain the target query result corresponding to the query parameter comprises:

verifying, by the blockchain node, the query result data; and

when determining the query result data passes the verification, performing, by the blockchain node, the computing on the query result data to obtain the target query result corresponding to the query parameter.

7. The method according to claim 6 , wherein the computing includes multi-dimensional computing.

8. The method according to claim 1 , further comprising storing, by the blockchain node, the target reliable data in a smart contract in the blockchain.

9. The method according to claim 1 , wherein the predetermined data reliability protocol includes a unified directed acyclic graph (UDAG) protocol or a Merkle DAG protocol.

10. The method according to claim 9 , wherein the target reliable data is a UDAG request or a Merkle DAG request.

11. A data processing device for transferring data from different predetermined data sources that employ different data storage technologies to a blockchain for storage and for improving reliability, comprising one or more processors and one or more non-transitory computer-readable memories coupled to the one or more processors and configured with instructions executable by the one or more processors to perform operations comprising:

receiving a query parameter corresponding to target data;

obtaining different pieces of query result data corresponding to the target data from each of the different predetermined data sources that employ different data storage technologies according to the query parameter;

converting the different pieces of query result data into target reliable data conforming to a predetermined data reliability protocol by converting a data format of each of the different pieces of query result data; and

sending the target reliable data to a blockchain node for storage in the blockchain.

12. The device according to claim 11 , wherein the predetermined data sources that employ different data storage technologies include: a data source based on an operation support system (OSS), a data source based on a hadoop distributed file system (HDFS), a data source based on a private blockchain, a data source based on a consortium blockchain, and a data source based on a public blockchain.

13. The device according to claim 11 , wherein the query result data includes: ReadWriteSet data in a Fabric cluster node, simplified payment verification (SPV) data in an Ethereum (ETH) cluster node, transaction information stored on a consortium blockchain of a non-account model, and corresponding data in an OSS cluster.

14. The device according to claim 11 , wherein the operations further comprise:

receiving the target reliable data;

parsing the target reliable data to obtain the query result data; and

performing computing on the query result data to obtain a target query result corresponding to the query parameter.

15. The device according to claim 14 , wherein the operations further comprise:

receiving a query request comprising the query parameter from a user; and

sending the target query result corresponding to the query parameter to the user.

16. The device according to claim 14 , wherein performing the computing on the query result data to obtain the target query result corresponding to the query parameter comprises:

verifying the query result data; and

when determining the query result data passes the verification, performing computing on the query result data to obtain the target query result corresponding to the query parameter.

17. The device according to claim 16 , wherein the computing includes multi-dimensional computing.

18. A non-transitory computer-readable storage medium for transferring data from different predetermined data sources that employ different data storage technologies to a blockchain for storage and for improving reliability, the non-transitory computer-readable storage medium storing instructions executable by one or more processors to cause the one or more processors to perform operations comprising:

receiving a query parameter corresponding to target data;

obtaining different pieces of query result data corresponding to the target data from each of the different predetermined data sources that employ different data storage technologies according to the query parameter;

converting the different pieces of query result data into target reliable data conforming to a predetermined data reliability protocol by converting a data format of each of the different pieces of query result data; and

sending the target reliable data to a blockchain node for storage in the blockchain.

19. The non-transitory computer-readable storage medium according to claim 18 , wherein the predetermined data sources that employ different data storage technologies include: a data source based on an operation support system (OSS), a data source based on a hadoop distributed file system (HDFS), a data source based on a private blockchain, a data source based on a consortium blockchain, and a data source based on a public blockchain.

20. The non-transitory computer-readable storage medium according to claim 18 , wherein the query result data includes: ReadWriteSet data in a Fabric cluster node, simplified payment verification (SPV) data in an Ethereum (ETH) cluster node, transaction information stored on a consortium blockchain of a non-account model, and corresponding data in an OSS cluster.