DATA PROCESSING METHOD, APPARATUS, AND DEVICE

• US 20200133949A1
• Filed: 09/13/2019
• Published: 04/30/2020
• Est. Priority Date: 10/26/2018
• Status: Active Grant

• Current Assignee: Advanced New Technologies Company Limited (Ant Group Co., Ltd.)
• Original Assignee: Alibaba Group Holding Ltd.
• Inventors: ZHUO, Haizhen, QIU, Honglin
• Granted Patent: US 11,216,476 B2
• Time in Patent Office: Days
• CPC Class Codes: G06F 16/2471 Distributed queries
• CPC Class Codes: G06F 16/25 Integrating or interfacing systems involving database management systems
• CPC Class Codes: G06F 16/254 Extract, transform and load [ETL] procedures, e.g. ETL data flows in data warehouses
• CPC Class Codes: G06F 16/27 Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
• CPC Class Codes: G06F 16/283 Multi-dimensional databases or data warehouses, e.g. MOLAP or ROLAP
• CPC Class Codes: G06F 21/64 Protecting data integrity, e.g. using checksums, certificates or signatures
• CPC Class Codes: G06Q 20/401 Transaction verification
• CPC Class Codes: G06Q 20/4016 involving fraud or risk level assessment in transaction processing
• CPC Class Codes: G06Q 20/405 Establishing or using transaction specific rules
• CPC Class Codes: H04L 9/32 including means for verifying the identity or authority of a user of the system or for message authentication, e.g. authorization, entity authentication, data integrity or data verification, non-repudiation, key authentication or verification of credentials
• CPC Class Codes: H04L 9/3239 involving non-keyed hash functions, e.g. modification detection codes [MDCs], MD5, SHA or RIPEMD
• CPC Class Codes: H04L 9/3247 involving digital signatures
• CPC Class Codes: H04L 9/3263 involving certificates, e.g. public key certificate [PKC] or attribute certificate [AC]; Public key infrastructure [PKI] arrangements network architectures or network communication protocols for supporting authentication of entities using certificates in a packet data network H04L63/0823
• CPC Class Codes: H04L 9/50 using hash chains, e.g. blockchains or hash trees

Abstract

Methods, systems, and devices, including computer programs encoded on computer storage media, for data processing are provided. One of the methods includes: receiving a query parameter; obtaining query result data from each of one or more predetermined data sources according to the query parameter; converting the query result data into target reliable data conforming to a predetermined data reliability protocol; and sending the target reliable data to a blockchain node.

Claims

1. A data processing method, comprising:

receiving a query parameter;

obtaining query result data from each of one or more predetermined data sources according to the query parameter;

converting the query result data into target reliable data conforming to a predetermined data reliability protocol; and

sending the target reliable data to a blockchain node.

2. The method according to claim 1, wherein the predetermined data sources include one or more of:

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 one or more of:

ReadWriteSet data in a Fabric cluster node, simplified payment verification (SPV) data in an 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 the target reliable data from the decentralized node by the blockchain node;

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.

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

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

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

6. The method according to claim 4, after the parsing the target reliable data to obtain the query result data, further comprising:

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.

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

8. The method according to claim 1, wherein the method is implemented by a decentralized node having a decentralized application (DApp) installed thereon.

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

10. The method according to claim 1, wherein the predetermined data reliability protocol includes a Merkle DAG protocol.

11. A data processing device, 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;

obtaining query result data from each of one or more predetermined data sources according to the query parameter;

converting the query result data into target reliable data conforming to a predetermined data reliability protocol; and

sending the target reliable data to a blockchain node.

12. The device according to claim 11, wherein the predetermined data sources include one or more of:

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 one or more of:

ReadWriteSet data in a Fabric cluster node, simplified payment verification (SPV) data in an 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 by the blockchain node;

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 by the blockchain node 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 after the parsing the target reliable data to obtain the query result data, the operations further comprise:

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 data processing, storing instructions executable by one or more processors to cause the one or more processors to perform operations comprising:

receiving a query parameter;

obtaining query result data from each of one or more predetermined data sources according to the query parameter;

converting the query result data into target reliable data conforming to a predetermined data reliability protocol; and

sending the target reliable data to a blockchain node.

19. The non-transitory computer-readable storage medium according to claim 18, wherein the predetermined data sources include one or more of:

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 one or more of:

ReadWriteSet data in a Fabric cluster node, simplified payment verification (SPV) data in an ETH cluster node, transaction information stored on a consortium blockchain of a non-account model, and corresponding data in an OSS cluster.