CN114663080B - Data processing method, device, equipment and medium based on block chain system - Google Patents
Data processing method, device, equipment and medium based on block chain system Download PDFInfo
- Publication number
- CN114663080B CN114663080B CN202210371601.8A CN202210371601A CN114663080B CN 114663080 B CN114663080 B CN 114663080B CN 202210371601 A CN202210371601 A CN 202210371601A CN 114663080 B CN114663080 B CN 114663080B
- Authority
- CN
- China
- Prior art keywords
- blockchain
- block
- target
- ledger
- processing
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000003672 processing method Methods 0.000 title claims abstract description 18
- 238000012545 processing Methods 0.000 claims abstract description 108
- 238000000034 method Methods 0.000 claims abstract description 78
- 230000004044 response Effects 0.000 claims abstract description 10
- 230000008569 process Effects 0.000 claims description 33
- 238000004590 computer program Methods 0.000 claims description 25
- 230000015654 memory Effects 0.000 claims description 11
- 238000012856 packing Methods 0.000 claims description 5
- 230000000977 initiatory effect Effects 0.000 claims description 4
- 238000010586 diagram Methods 0.000 description 14
- 238000005111 flow chemistry technique Methods 0.000 description 9
- 230000006870 function Effects 0.000 description 8
- 230000007246 mechanism Effects 0.000 description 8
- 238000004891 communication Methods 0.000 description 7
- 238000005516 engineering process Methods 0.000 description 5
- 230000004048 modification Effects 0.000 description 4
- 238000012986 modification Methods 0.000 description 4
- 230000005540 biological transmission Effects 0.000 description 3
- 230000003287 optical effect Effects 0.000 description 3
- 238000004806 packaging method and process Methods 0.000 description 3
- 238000009472 formulation Methods 0.000 description 2
- 239000000203 mixture Substances 0.000 description 2
- 239000000758 substrate Substances 0.000 description 2
- 108010001267 Protein Subunits Proteins 0.000 description 1
- 230000000903 blocking effect Effects 0.000 description 1
- 238000011161 development Methods 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 230000009969 flowable effect Effects 0.000 description 1
- 239000003999 initiator Substances 0.000 description 1
- 230000003993 interaction Effects 0.000 description 1
- 239000004973 liquid crystal related substance Substances 0.000 description 1
- 239000004065 semiconductor Substances 0.000 description 1
- 230000001360 synchronised effect Effects 0.000 description 1
- 230000001960 triggered effect Effects 0.000 description 1
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
- G06Q20/00—Payment architectures, schemes or protocols
- G06Q20/08—Payment architectures
- G06Q20/10—Payment architectures specially adapted for electronic funds transfer [EFT] systems; specially adapted for home banking systems
- G06Q20/102—Bill distribution or payments
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/24—Querying
- G06F16/245—Query processing
- G06F16/2458—Special types of queries, e.g. statistical queries, fuzzy queries or distributed queries
- G06F16/2471—Distributed queries
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/27—Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
Landscapes
- Engineering & Computer Science (AREA)
- Theoretical Computer Science (AREA)
- Business, Economics & Management (AREA)
- Accounting & Taxation (AREA)
- Physics & Mathematics (AREA)
- Finance (AREA)
- Databases & Information Systems (AREA)
- General Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- Data Mining & Analysis (AREA)
- Strategic Management (AREA)
- Computing Systems (AREA)
- General Business, Economics & Management (AREA)
- Economics (AREA)
- Development Economics (AREA)
- Fuzzy Systems (AREA)
- Mathematical Physics (AREA)
- Probability & Statistics with Applications (AREA)
- Software Systems (AREA)
- Computational Linguistics (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The present disclosure provides a data processing method, apparatus, electronic device and storage medium implemented based on a blockchain system, the blockchain system including a plurality of blockchain nodes, the blockchain nodes configured with a first blockchain ledger, a first intelligent contract and a second intelligent contract, the method comprising: for each blockchain node in the blockchain system, invoking a first intelligent contract in response to triggering a timing task to query a first blockchain ledger to obtain at least one first block associated with the blockchain link point; under the condition that the first target block exists in at least one first block, analyzing and processing the first target block to obtain target data; and invoking a second intelligent contract to perform circulation processing on the target data.
Description
Technical Field
The present disclosure relates to the field of blockchain technology, and more particularly, to a blockchain system-based data processing method, apparatus, electronic device, readable storage medium, and computer program product.
Background
With the rapid development of internet technology, business cooperation between enterprises is more frequent, and more businesses need to be completed by cooperation of a plurality of business participants. In the related art, a centralized flow control center is generally set up to control service circulation of an enterprise service among a plurality of service participants.
In the process of implementing the disclosed concept, the inventor finds that at least the following problems exist in the related art: when a plurality of business participants perform data processing circulation, the business participants need to remotely interact with a flow control center, single-point problems exist, and the stability of data processing is poor.
Disclosure of Invention
In view of this, the present disclosure provides a data processing method, apparatus, electronic device, readable storage medium, and computer program product implemented based on a blockchain system.
One aspect of the present disclosure provides a data processing method implemented based on a blockchain system including a plurality of blockchain nodes configured with a first blockchain ledger, a first smart contract, and a second smart contract, the method comprising: for each of the blockchain nodes in the blockchain system, invoking the first intelligent contract in response to triggering a timing task to query the first blockchain ledger to obtain at least one first block associated with the blockchain node; under the condition that a first target block exists in at least one first block, analyzing and processing the first target block to obtain target data; and calling the second intelligent contract to perform circulation processing on the target data.
According to an embodiment of the present disclosure, the blockchain node is further configured with a second blockchain ledger; wherein the calling the second smart contract to perform a stream processing on the target data includes: determining a service identifier based on the target data; determining a first flow definition file associated with the service identifier from the second blockchain ledger; determining a first target blockchain node based on the first procedure definition file; generating a second block based on the target data and the first target blockchain node; writing the second block into the first block chain account book.
According to an embodiment of the present disclosure, the determining, from the second blockchain ledger, the first flow definition file associated with the service identifier includes: acquiring at least one third block associated with the service identifier from the second blockchain ledger; determining a second target block from at least one of the third blocks; and analyzing the second target block to obtain the first process definition file.
According to an embodiment of the present disclosure, the determining a second target block from at least one third block includes: and determining the third block located at the end of the second blockchain ledger among at least one third block as the second target block.
According to an embodiment of the present disclosure, the blockchain node is further configured with a third smart contract; the method further comprises the following steps: in response to receiving a second process definition file, determining a plurality of second target blockchain nodes associated with the second process definition file; invoking a third intelligent contract to initiate a first consensus proposal to a plurality of the second target blockchain nodes; packing the second process definition file into the third block if it is determined that the plurality of second target blockchain nodes agree on the first consensus proposal; writing the third block into the second blockchain ledger.
According to an embodiment of the disclosure, the first block is configured with a processing state identifier; the method further comprises the following steps: in the case that the processing state identification is determined to be the unprocessed first block in the at least one first block, the first target block is determined to be the first target block in the at least one first block.
According to an embodiment of the present disclosure, the above method further includes: for each of the blockchain nodes, initiating a second consensus proposal to other blockchain nodes of the blockchain system when writing a third target block into a first blockchain ledger or a second blockchain ledger of the blockchain node; and writing the third target block into a first blockchain ledger or a second blockchain ledger of other blockchain nodes of the blockchain system when the other blockchain nodes are determined to agree on the second consensus proposal.
Another aspect of the present disclosure provides a data processing apparatus implemented based on a blockchain system including a plurality of blockchain nodes configured with a first blockchain ledger, a first smart contract, and a second smart contract, the apparatus comprising: the query module is used for responding to the triggering timing task for each block chain node in the block chain system, calling the first intelligent contract to query the first block chain account book and obtaining at least one first block associated with the block chain node; the first processing module is used for analyzing and processing the first target block to obtain target data under the condition that the first target block exists in at least one first block; and the second processing module is used for calling the second intelligent contract so as to carry out circulation processing on the target data.
Another aspect of the present disclosure provides an electronic device, comprising: one or more processors; and a memory for storing one or more instructions that, when executed by the one or more processors, cause the one or more processors to implement the method as described above.
Another aspect of the present disclosure provides a computer-readable storage medium storing computer-executable instructions that, when executed, are configured to implement a method as described above.
Another aspect of the present disclosure provides a computer program product comprising computer executable instructions which, when executed, are for implementing a method as described above.
According to the embodiment of the disclosure, because the blockchain system is adopted to realize the circulation control of data processing, each blockchain node can check whether a first target block exists in a first block associated with the blockchain link point in a locally stored first blockchain account book by calling a first intelligent contract, and analyze and process the first target block to obtain target data under the condition that the first target block exists, and realize the circulation processing of the target data by calling a second intelligent contract. By the technical means, the single-point problem in the flow processing frame of the related technology is at least partially overcome, the problem that the flow processing frame is unavailable due to the failure of the centralized node is avoided, and the stability of data processing is effectively improved.
Drawings
The above and other objects, features and advantages of the present disclosure will become more apparent from the following description of embodiments thereof with reference to the accompanying drawings in which:
FIG. 1 schematically illustrates an exemplary system architecture to which the blockchain-based system implemented data processing methods and apparatus may be applied, in accordance with embodiments of the present disclosure.
FIG. 2 schematically illustrates a flow diagram of a data processing method implemented based on a blockchain system in accordance with an embodiment of the present disclosure.
Fig. 3 schematically illustrates a flow chart of a target data flow processing method according to an embodiment of the disclosure.
Fig. 4 schematically illustrates a flowchart of a process definition file publishing method according to an embodiment of the present disclosure.
Fig. 5A schematically illustrates a schematic diagram of a data processing system of a service participant according to an embodiment of the disclosure.
Fig. 5B schematically illustrates a schematic diagram of a blockchain system in accordance with embodiments of the present disclosure.
FIG. 6 schematically illustrates a block diagram of a data processing apparatus implemented based on a blockchain system in accordance with an embodiment of the present disclosure.
Fig. 7 schematically illustrates a block diagram of an electronic device adapted to implement a data processing method implemented based on a blockchain system in accordance with an embodiment of the disclosure.
Detailed Description
Hereinafter, embodiments of the present disclosure will be described with reference to the accompanying drawings. It should be understood that the description is only exemplary and is not intended to limit the scope of the present disclosure. In the following detailed description, for purposes of explanation, numerous specific details are set forth in order to provide a thorough understanding of the embodiments of the present disclosure. It may be evident, however, that one or more embodiments may be practiced without these specific details. In addition, in the following description, descriptions of well-known structures and techniques are omitted so as not to unnecessarily obscure the concepts of the present disclosure.
The terminology used herein is for the purpose of describing particular embodiments only and is not intended to be limiting of the disclosure. The terms "comprises," "comprising," and/or the like, as used herein, specify the presence of stated features, steps, operations, and/or components, but do not preclude the presence or addition of one or more other features, steps, operations, or components.
All terms (including technical and scientific terms) used herein have the same meaning as commonly understood by one of ordinary skill in the art unless otherwise defined. It should be noted that the terms used herein should be construed to have meanings consistent with the context of the present specification and should not be construed in an idealized or overly formal manner.
Where a convention analogous to "at least one of A, B and C, etc." is used, in general such a convention should be interpreted in accordance with the meaning of one of skill in the art having generally understood the convention (e.g., "a system having at least one of A, B and C" would include, but not be limited to, systems having a alone, B alone, C alone, a and B together, a and C together, B and C together, and/or A, B, C together, etc.). Where a formulation similar to at least one of "A, B or C, etc." is used, in general such a formulation should be interpreted in accordance with the ordinary understanding of one skilled in the art (e.g. "a system with at least one of A, B or C" would include but not be limited to systems with a alone, B alone, C alone, a and B together, a and C together, B and C together, and/or A, B, C together, etc.).
In the related art, the flow of the data processing involving multiple parties is mostly implemented based on a flow engine such as Activiti, flowable, camunda. The specific implementation method comprises the following steps: a centralized flow control center is built by using a flow engine, a flow definition file is formulated, and then the flow control center is responsible for controlling the circulation of data processing steps among a plurality of participants.
The adoption of a flow engine to build a flow control center to control the circulation of data processing among multiple participants has a single point problem. For example, due to technical limitations, there is a greater probability of failure of the hardware device throughout its lifecycle, which can result in the entire data processing flow framework being unavailable when the flow control center fails; for another example, since the flow definition file is also generally stored in the flow control center, if a certain service participant issues or modifies the flow definition file in a unilateral manner without notifying other service participants, normal operation of the service flow is affected; or because all the flow scheduling information is stored in the flow control center, the data has the problem of unreliability; for another example, when a plurality of service participants perform data processing circulation, the service participants need to interact with the flow control center remotely, so that a large time delay and errors possibly caused by network transmission are caused.
In view of this, the embodiments of the present disclosure implement distributed deployment of frames based on the distributed node mechanism of the blockchain network, and the centralized flow control center node is no longer needed to implement the purpose of decentralization. In particular, embodiments of the present disclosure provide a data processing method, apparatus, seed electronic device, readable storage medium, and computer program product implemented based on a blockchain system. The blockchain system includes a plurality of blockchain nodes, the blockchain nodes configured with a first blockchain ledger, a first smartcontract, and a second smartcontract, the method comprising: for each blockchain node in the blockchain system, invoking a first intelligent contract in response to triggering a timing task to query a first blockchain ledger to obtain at least one first block associated with the blockchain link point; under the condition that the first target block exists in at least one first block, analyzing and processing the first target block to obtain target data; and invoking a second intelligent contract to perform circulation processing on the target data.
FIG. 1 schematically illustrates an exemplary system architecture to which the blockchain-based system implemented data processing methods and apparatus may be applied, in accordance with embodiments of the present disclosure. It should be noted that fig. 1 is only an example of a system architecture to which embodiments of the present disclosure may be applied to assist those skilled in the art in understanding the technical content of the present disclosure, but does not mean that embodiments of the present disclosure may not be used in other devices, systems, environments, or scenarios.
As shown in fig. 1, a system architecture 100 according to this embodiment may include blockchain nodes 101, 102, 103, 104, 105, 106, a network 107.
The blockchain nodes 101, 102, 103, 104, 105, 106 are deployed in terminal devices, servers or server clusters of the corresponding service participants.
The network 107 is used as a medium to provide communication links between the blockchain nodes 101, 102, 103, 104, 105, 106. The network 107 may include various connection types, such as wired and/or wireless communication links, etc.
The blockchain nodes 101, 102, 103, 104, 105 and 106 form a blockchain system, each blockchain node is provided with an intelligent contract and a blockchain account book, each blockchain node shares the same right and obligation as those of all other blockchain nodes, each blockchain node can determine some blockchain nodes to be used as the consensus blockchain nodes through a consensus mechanism, any one blockchain node performs read-write operation in a corresponding blockchain database, and other blockchain nodes can complete synchronization according to a mechanism, so that the data in the blockchain databases corresponding to all the blockchain nodes in the blockchain network are completely consistent.
It should be noted that, the data processing method implemented based on the blockchain system provided in the embodiments of the present disclosure may be generally performed by the blockchain nodes 101, 102, 103, 104, 105, 106. Accordingly, the data processing apparatus implemented based on a blockchain system provided by embodiments of the present disclosure may be generally disposed in blockchain nodes 101, 102, 103, 104, 105, 106.
It should be understood that the number of blockchain nodes and networks in fig. 1 is merely illustrative. There may be any number of blockchain nodes and networks as desired for an implementation.
FIG. 2 schematically illustrates a flow diagram of a data processing method implemented based on a blockchain system in accordance with an embodiment of the present disclosure.
As shown in fig. 2, the method includes operations S201 to S203.
In operation S201, for each blockchain node in the blockchain system, in response to triggering the timing task, a first smart contract is invoked to query a first blockchain ledger to obtain at least one first block associated with the blockchain node.
In operation S202, in the case that it is determined that the first target block exists in the at least one first block, the first target block is parsed and processed to obtain the target data.
In operation S203, a second smart contract is invoked to perform a stream processing on the target data.
According to embodiments of the present disclosure, each business participant may join the blockchain system by installing blockchain nodes.
According to the embodiment of the disclosure, when installing the blockchain node, the business participant can download the first blockchain ledger and the like to the local and install a plurality of intelligent contracts such as a first intelligent contract and a second intelligent contract.
According to embodiments of the present disclosure, the timed tasks may be tasks triggered at intervals for invoking a preset program or implementing a preset function. The triggering time interval of the timing task may be, for example, 5 seconds, 30 seconds, etc., which is not limited herein.
According to embodiments of the present disclosure, a plurality of sub-links may be included in the first blockchain ledger, each of which may correspond to a respective one of the blockchain link points. The at least one first chunk may be all chunks included in the sub-chain of the first blockchain ledger corresponding to the blockchain link point.
According to embodiments of the present disclosure, traffic data associated with the blockchain node may be included in the first block. The first target block may include pending traffic data associated with the blockchain node.
According to an embodiment of the present disclosure, a first smart contract may be used to query a first blockchain ledger local to the blockchain node in response to a timing task to determine whether there is traffic data to be processed associated with the blockchain link point in the first blockchain ledger, i.e., whether there is a first target block.
According to the embodiment of the disclosure, the content in the first blockchain ledger can be synchronized to the first blockchain ledgers local to the blockchain nodes of all business participants in real time by means of a ledger data synchronization mechanism of the blockchain system.
According to an embodiment of the present disclosure, parsing and processing the first target block may be understood as: and analyzing the first target block to acquire service data to be processed contained in the first target block, and processing the service data by utilizing the service logic of the service participant corresponding to the blockchain node. The target data may be output data of the service participant after processing the service data.
According to the embodiment of the disclosure, the second intelligent contract can be used for realizing data flow among the block chain link points, namely, the second intelligent contract can process target data processed by the block chain node so as to facilitate the subsequent processing of the target data by another block chain node.
According to the embodiment of the disclosure, because the blockchain system is adopted to realize the circulation control of data processing, each blockchain node can check whether a first target block exists in a first block associated with the blockchain link point in a locally stored first blockchain account book by calling a first intelligent contract, and analyze and process the first target block to obtain target data under the condition that the first target block exists, and realize the circulation processing of the target data by calling a second intelligent contract. By the technical means, the single-point problem in the flow processing frame of the related technology is at least partially overcome, the problem that the flow processing frame is unavailable due to the failure of the centralized node is avoided, and the stability of data processing is effectively improved.
The method illustrated in fig. 2 is further described below with reference to fig. 3,4, 5A and 5B in conjunction with the exemplary embodiments.
According to embodiments of the present disclosure, the first block may be configured with a processing state identification.
According to an embodiment of the present disclosure, whether the first target block is present may be determined by traversing the processing state identification of the at least one first block, i.e. in case it is determined that the processing state identification is characteristic of an unprocessed first block, the first target block is present in the at least one first block.
According to an embodiment of the present disclosure, the blockchain node may also be configured with a second blockchain ledger.
According to embodiments of the present disclosure, each block of the second blockchain ledger may be parsed into a flow definition file that may be used to set the order in which business data flows between the various blockchain nodes. For example, the order of the flows of service a may be set to be performed sequentially by blockchain nodes a, b, and c. For another example, the order of the flows of service B may be set to be performed by blockchain node a first and then by blockchain nodes B and c in parallel.
Fig. 3 schematically illustrates a flow chart of a target data flow processing method according to an embodiment of the disclosure.
As shown in fig. 3, the method includes operations S301 to S304.
In operation S301, a service identification is determined based on the target data.
In operation S302, a first flow definition file associated with a business identity is determined from a second blockchain ledger.
In operation S303, determining a first target blockchain node based on the first procedure definition file; a second block is generated based on the target data and the first target blockchain node.
In operation S304, the second block is written into the first blockchain ledger.
According to embodiments of the present disclosure, the service identification may be a unique identification for determining the service associated with the target data.
According to embodiments of the present disclosure, the first target blockchain node may be one or more blockchain nodes located after the blockchain node in the first flow definition file.
According to embodiments of the present disclosure, a second chunk may be generated by packing target data, after which the second chunk may be written into a sub-chain in the first blockchain ledger that corresponds to the first target blockchain node. Or, the identification information associated with the link point of the first target block may be added to the second block, and then the second block added with the identification information may be written into the first blockchain ledger.
According to an embodiment of the present disclosure, operation S302 may include the following operations:
Acquiring at least one third block associated with the service identifier from the second blockchain ledger; determining a second target block from the at least one third block; and analyzing the second target block to obtain the first process definition file.
According to an embodiment of the present disclosure, at least one third block associated with the service identifier may be obtained by determining a flow definition file associated with the service identifier in the second blockchain ledger, i.e. the flow definition file in each third block is characterized as a current flow definition file or a historical flow definition file of the service indicated by the service identifier.
According to an embodiment of the present disclosure, the first flow definition file may refer to a newly agreed-upon flow definition file of a plurality of flow definition files associated with the service identification.
According to an embodiment of the present disclosure, since the newly added block in the blockchain ledger is typically located at the end of the blockchain ledger, determining the second target block from the at least one third block may include the following operations:
and determining a third block located at the tail end of the second blockchain ledger in the at least one third block as a second target block.
In accordance with embodiments of the present disclosure, the blockchain node may also be configured with a third smart contract. The third smart contract may be used to implement a consensus mechanism for the new flow definition file.
According to the embodiment of the disclosure, the distributed storage of all data is realized based on a shared ledger of a blockchain and a data synchronization mechanism. In the dispatching process, all the participants can complete the processes of acquiring data and submitting data only by interacting with a local account book, and the blockchain network can automatically and synchronously update the data to the account books of other participants, so that network delay, network transmission errors and the like are reduced.
Fig. 4 schematically illustrates a flowchart of a process definition file publishing method according to an embodiment of the present disclosure.
As shown in fig. 4, the method includes operations S401 to S404.
In response to receiving the second process definition file, a plurality of second target blockchain nodes associated with the second process definition file are determined in operation S401.
In operation S402, a third smart contract is invoked to initiate a first consensus proposal to a plurality of second target blockchain nodes.
In operation S403, the second process definition file is packaged into a third block in case it is determined that the plurality of second target blockchain nodes agree on the first consensus proposal.
In operation S404, the third chunk is written into the second blockchain ledger.
According to embodiments of the present disclosure, the second flow definition file may have an associated target service. The second flow definition file may be uploaded by any service participant related to the target service, or may be uploaded by any other blockchain node, which is not limited herein.
According to embodiments of the present disclosure, the plurality of second target blockchain nodes may be blockchain nodes configured by a plurality of service participants associated with the target service.
In accordance with an embodiment of the present disclosure, consensus on the first consensus proposal may be that all business participants acknowledge the second flow definition file. Or the first consensus proposal can be agreed with, and the second flow definition file can be confirmed by the business participants with preset proportions among all the business participants. The preset proportion may be 80%, 90%, etc., and may be set according to a specific application scenario, which is not limited herein.
According to the embodiment of the disclosure, when the first consensus proposal does not agree, feedback information which does not agree can be sent to the initiator of the first consensus proposal, that is, the blockchain node which receives the second flow definition file, so that the service participant to which the blockchain node belongs can modify the second flow definition file.
According to the embodiment of the disclosure, the version control of the flow definition file is realized through the multiparty consensus mechanism of the blockchain, so that the release or modification operation of the flow definition file can be performed after the consensus of all the participants is acquired, the unilateral release modification of a certain participant is avoided, and the normal operation of the whole scheduling process is ensured.
Fig. 5A schematically illustrates a schematic diagram of a data processing system of a service participant according to an embodiment of the disclosure.
As shown in fig. 5A, each service participant's data processing system 500A may include a service layer 510, a call layer 520, and a blockchain layer 530.
The service layer 510 may be a data processing module of a service participant, and the service participant may utilize local hardware resources to process a service, or may initiate a release flow of a flow definition file, a flow of data processing, a process flow of receiving a task, etc. through the call layer 520.
Call layer 520 may be used to enable information interaction between business layer 510 and blockchain layer 530.
The blockchain layer 530 may act as a blockchain node in a blockchain system. The blockchain layer 530 may implement the issuing process of the process definition file, the circulation process of data processing, the processing process of receiving tasks, etc. by invoking the intelligent contracts, where the configured intelligent contracts include a timed task intelligent contract, a business circulation intelligent contract, a file issuing intelligent contract, etc. The business is processed by configuring the intelligent contract, so that the reliability of data processing can be improved, and the complexity of upper-layer application can be reduced.
Blockchain layer 530 may include a blockchain ledger, where each business participant's blockchain ledger includes all data information, such as flow definition files, flow information, task information for the node, etc. Because all the circulation information is stored in the blockchain account book of all the participants, all the flow scheduling processes can be traced based on the characteristics of the blockchain network, such as non-falsifiability, traceability and the like of the data.
Fig. 5B schematically illustrates a schematic diagram of a blockchain system in accordance with embodiments of the present disclosure.
As shown in FIG. 5B, blockchain system 500B may be comprised of a blockchain layer 530 of a plurality of data processing systems 500A.
According to an embodiment of the present disclosure, when a service participant issues a flow definition file, the service layer 510 may issue the flow definition file to the call layer 520, and then the call layer 520 issues the flow definition file to the blockchain layer 530, and then the blockchain layer 530 performs a chaining operation of the flow definition file. The uplink operation may include: the blockchain layer 530 initiates a consensus proposal for consensus by all business participants associated with the flow definition file fulfilling the intelligent contracts; and after the consensus is completed, packaging the flow definition file into blocks, and then blocking the blocks into a blockchain account book.
In accordance with embodiments of the present disclosure, upon processing of traffic data, blockchain layer 530 may respond to triggering timing tasks to fulfill a smart contract, querying whether there is traffic data in the local blockchain ledger that needs to be processed locally, i.e., to flow to the pending traffic flow of the blockchain node. In the case of querying the service data, the blockchain layer 530 may send the service data to the service layer 510 through the call layer 520, and after the service layer 510 processes the service data, a flow processing flow is performed.
In accordance with an embodiment of the present disclosure, when performing a stream processing procedure, the service layer 510 may send target data generated after processing a service to the blockchain layer 530 through the call layer 520. Blockchain layer 530 may obtain the latest flow definition file associated with the service from the blockchain ledger based on the service indicated by the target data, and determine the next blockchain node of the flow from the flow definition file. The blockchain layer 530 may then package the information and target data for the next blockchain node into blocks and drop the blocks into a blockchain ledger.
According to the embodiment of the disclosure, when there is a blockfall in the blockchain ledger of any one blockchain layer 530, the intelligent contract can be fulfilled, and the data synchronization operation of the blockchain ledgers of the blockchain layers 530 of the respective business participants is performed. Specifically, the method comprises the following operations:
For each blockchain node, initiating a second consensus proposal to other blockchain nodes of the blockchain system with a third target block written into either the first blockchain ledger or the second blockchain ledger of the blockchain node; and writing the third target block into the first blockchain ledger or the second blockchain ledger of the other blockchain nodes of the blockchain system under the condition that the other blockchain nodes are determined to agree on the second consensus proposal.
According to the embodiment of the disclosure, by adding the blockchain layer in the data processing system of the service participants into the blockchain system as the blockchain link point, the changed data can be synchronously updated to the blockchain account book of each service participant by depending on a reliable data synchronization mechanism of the blockchain network, and all the service participants only need to interact with the local blockchain account book, thereby reducing network delay, network transmission errors and the like.
FIG. 6 schematically illustrates a block diagram of a data processing apparatus implemented based on a blockchain system in accordance with an embodiment of the present disclosure.
As shown in fig. 6, the blockchain system-based implemented data processing device 600 includes a query module 610, a first processing module 620, and a second processing module 630.
The query module 610 is configured to, for each blockchain node in the blockchain system, invoke a first intelligent contract to query a first blockchain ledger to obtain at least one first block associated with the blockchain node in response to triggering the timing task.
The first processing module 620 is configured to parse and process the first target block to obtain target data if it is determined that the first target block exists in the at least one first block.
And the second processing module 630 is configured to invoke a second smart contract to perform a stream processing on the target data.
According to the embodiment of the disclosure, because the blockchain system is adopted to realize the circulation control of data processing, each blockchain node can check whether a first target block exists in a first block associated with the blockchain link point in a locally stored first blockchain account book by calling a first intelligent contract, and analyze and process the first target block to obtain target data under the condition that the first target block exists, and realize the circulation processing of the target data by calling a second intelligent contract. By the technical means, the single-point problem in the flow processing frame of the related technology is at least partially overcome, the problem that the flow processing frame is unavailable due to the failure of the centralized node is avoided, and the stability of data processing is effectively improved.
According to an embodiment of the present disclosure, a blockchain system includes a plurality of blockchain nodes configured with a first blockchain ledger, a first smart contract, and a second smart contract.
According to an embodiment of the present disclosure, the blockchain node is further configured with a second blockchain ledger.
According to an embodiment of the present disclosure, the second processing module 630 includes a first processing sub-module, a second processing sub-module, a third processing sub-module, a fourth processing sub-module, and a fifth processing sub-module.
And the first processing sub-module is used for determining the service identification based on the target data.
And the second processing submodule is used for determining a first flow definition file associated with the service identifier from the second blockchain ledger.
And a third processing sub-module for determining a first target blockchain node based on the first procedure definition file.
And a fourth processing sub-module for generating a second block based on the target data and the first target blockchain node.
And the fifth processing submodule is used for writing the second block into the first blockchain ledger.
According to an embodiment of the present disclosure, the second processing sub-module includes a first processing unit, a second processing unit, and a third processing unit.
The first processing unit is used for acquiring at least one third block associated with the service identifier from the second blockchain ledger.
And the second processing unit is used for determining a second target block from the at least one third block.
And the third processing unit is used for analyzing the second target block to obtain the first flow definition file.
According to an embodiment of the present disclosure, the second processing unit comprises a processing subunit.
And the processing subunit is used for determining a third block positioned at the tail end of the second blockchain ledger in the at least one third block as a second target block.
According to an embodiment of the present disclosure, the blockchain node is also configured with a third smart contract.
According to an embodiment of the present disclosure, the data processing apparatus 600 further includes a first determination module, a first consensus module, a packaging module, and a first writing module.
The first determination module is configured to determine a plurality of second target blockchain nodes associated with the second process definition file in response to receiving the second process definition file.
And the first consensus module is used for calling a third intelligent contract to initiate a first consensus proposal to a plurality of second target blockchain nodes.
And the packing module is used for packing the second flow definition file into a third block under the condition that the plurality of second target blockchain nodes reach consensus on the first consensus proposal.
The first writing module is used for writing the third block into the second blockchain ledger.
According to an embodiment of the present disclosure, the first block is configured with a processing state identification.
According to an embodiment of the present disclosure, the data processing apparatus 600 further comprises a second determination module.
And a second determining module for determining that the first target block exists in the at least one first block if it is determined that the processing state identifier is characterized as an unprocessed first block.
According to an embodiment of the present disclosure, the data processing apparatus 600 further comprises a second consensus module and a second writing module.
And the second consensus module is used for initiating a second consensus proposal to other blockchain nodes of the blockchain system under the condition that a third target block is written into the first blockchain account book or the second blockchain account book of the blockchain nodes for each blockchain node.
And the second writing module is used for writing the third target block into the first blockchain account book or the second blockchain account book of other blockchain nodes of the blockchain system under the condition that the other blockchain nodes reach consensus on the second consensus proposal.
Any number of modules, sub-modules, units, sub-units, or at least some of the functionality of any number of the sub-units according to embodiments of the present disclosure may be implemented in one module. Any one or more of the modules, sub-modules, units, sub-units according to embodiments of the present disclosure may be implemented as split into multiple modules. Any one or more of the modules, sub-modules, units, sub-units according to embodiments of the present disclosure may be implemented at least in part as a hardware circuit, such as a Field Programmable Gate Array (FPGA), a Programmable Logic Array (PLA), a system-on-chip, a system-on-substrate, a system-on-package, an Application Specific Integrated Circuit (ASIC), or in any other reasonable manner of hardware or firmware that integrates or encapsulates the circuit, or in any one of or a suitable combination of three of software, hardware, and firmware. Or one or more of the modules, sub-modules, units, sub-units according to embodiments of the present disclosure may be at least partially implemented as computer program modules, which, when executed, may perform the corresponding functions.
For example, any of the query module 610, the first processing module 620, and the second processing module 630 may be combined in one module/unit/sub-unit or any of the modules/units/sub-units may be split into multiple modules/units/sub-units. Or at least some of the functionality of one or more of these modules/units/sub-units may be combined with at least some of the functionality of other modules/units/sub-units and implemented in one module/unit/sub-unit. According to embodiments of the present disclosure, at least one of the query module 610, the first processing module 620, and the second processing module 630 may be implemented at least in part as hardware circuitry, such as a Field Programmable Gate Array (FPGA), a Programmable Logic Array (PLA), a system on a chip, a system on a substrate, a system on a package, an Application Specific Integrated Circuit (ASIC), or may be implemented in hardware or firmware in any other reasonable way of integrating or packaging circuitry, or in any one of or a suitable combination of any of the three. Or at least one of the query module 610, the first processing module 620 and the second processing module 630 may be at least partially implemented as a computer program module which, when executed, may perform the corresponding functions.
It should be noted that, in the embodiment of the present disclosure, the data processing apparatus portion implemented based on the blockchain system corresponds to the data processing method portion implemented based on the blockchain system in the embodiment of the present disclosure, and the description of the data processing apparatus portion implemented based on the blockchain system specifically refers to the data processing method portion implemented based on the blockchain system, which is not described herein again.
Fig. 7 schematically illustrates a block diagram of an electronic device adapted to implement a data processing method implemented based on a blockchain system in accordance with an embodiment of the disclosure. The electronic device shown in fig. 7 is merely an example and should not be construed to limit the functionality and scope of use of the disclosed embodiments.
As shown in fig. 7, a computer electronic device 700 according to an embodiment of the present disclosure includes a processor 701 that can perform various appropriate actions and processes according to a program stored in a Read Only Memory (ROM) 702 or a program loaded from a storage section 708 into a Random Access Memory (RAM) 703. The processor 701 may include, for example, a general purpose microprocessor (e.g., a CPU), an instruction set processor and/or an associated chipset and/or a special purpose microprocessor (e.g., an Application Specific Integrated Circuit (ASIC)), or the like. The processor 701 may also include on-board memory for caching purposes. The processor 701 may comprise a single processing unit or a plurality of processing units for performing different actions of the method flows according to embodiments of the disclosure.
In the RAM 703, various programs and data necessary for the operation of the electronic apparatus 700 are stored. The processor 701, the ROM 702, and the RAM 703 are connected to each other through a bus 704. The processor 701 performs various operations of the method flow according to the embodiments of the present disclosure by executing programs in the ROM 702 and/or the RAM 703. Note that the program may be stored in one or more memories other than the ROM 702 and the RAM 703. The processor 701 may also perform various operations of the method flow according to embodiments of the present disclosure by executing programs stored in the one or more memories.
According to an embodiment of the present disclosure, the electronic device 700 may further include an input/output (I/O) interface 705, the input/output (I/O) interface 705 also being connected to the bus 704. The electronic device 700 may also include one or more of the following components connected to the I/O interface 705: an input section 706 including a keyboard, a mouse, and the like; an output portion 707 including a Cathode Ray Tube (CRT), a Liquid Crystal Display (LCD), and the like, a speaker, and the like; a storage section 708 including a hard disk or the like; and a communication section 709 including a network interface card such as a LAN card, a modem, or the like. The communication section 709 performs communication processing via a network such as the internet. The drive 710 is also connected to the I/O interface 705 as needed. A removable medium 711 such as a magnetic disk, an optical disk, a magneto-optical disk, a semiconductor memory, or the like is mounted on the drive 710 as necessary, so that a computer program read therefrom is mounted into the storage section 708 as necessary.
According to embodiments of the present disclosure, the method flow according to embodiments of the present disclosure may be implemented as a computer software program. For example, embodiments of the present disclosure include a computer program product comprising a computer program embodied on a computer readable storage medium, the computer program comprising program code for performing the method shown in the flowcharts. In such an embodiment, the computer program may be downloaded and installed from a network via the communication portion 709, and/or installed from the removable medium 711. The above-described functions defined in the system of the embodiments of the present disclosure are performed when the computer program is executed by the processor 701. The systems, devices, apparatus, modules, units, etc. described above may be implemented by computer program modules according to embodiments of the disclosure.
The present disclosure also provides a computer-readable storage medium that may be embodied in the apparatus/device/system described in the above embodiments; or may exist alone without being assembled into the apparatus/device/system. The computer-readable storage medium carries one or more programs which, when executed, implement methods in accordance with embodiments of the present disclosure.
According to embodiments of the present disclosure, the computer-readable storage medium may be a non-volatile computer-readable storage medium. Examples may include, but are not limited to: a portable computer diskette, a hard disk, a Random Access Memory (RAM), a read-only memory (ROM), an erasable programmable read-only memory (EPROM or flash memory), a portable compact disc read-only memory (CD-ROM), an optical storage device, a magnetic storage device, or any suitable combination of the foregoing. In the context of this disclosure, a computer-readable storage medium may be any tangible medium that can contain, or store a program for use by or in connection with an instruction execution system, apparatus, or device.
For example, according to embodiments of the present disclosure, the computer-readable storage medium may include ROM 702 and/or RAM 703 and/or one or more memories other than ROM 702 and RAM 703 described above.
Embodiments of the present disclosure also include a computer program product comprising a computer program comprising program code for performing the methods provided by the embodiments of the present disclosure, the program code for causing an electronic device to implement the blockchain system-implemented data processing method provided by the embodiments of the present disclosure when the computer program product is run on the electronic device.
The above-described functions defined in the system/apparatus of the embodiments of the present disclosure are performed when the computer program is executed by the processor 701. The systems, apparatus, modules, units, etc. described above may be implemented by computer program modules according to embodiments of the disclosure.
In one embodiment, the computer program may be based on a tangible storage medium such as an optical storage device, a magnetic storage device, or the like. In another embodiment, the computer program may also be transmitted, distributed over a network medium in the form of signals, downloaded and installed via the communication section 709, and/or installed from the removable medium 711. The computer program may include program code that may be transmitted using any appropriate network medium, including but not limited to: wireless, wired, etc., or any suitable combination of the foregoing.
According to embodiments of the present disclosure, program code for performing computer programs provided by embodiments of the present disclosure may be written in any combination of one or more programming languages, and in particular, such computer programs may be implemented in high-level procedural and/or object-oriented programming languages, and/or assembly/machine languages. Programming languages include, but are not limited to, such as Java, c++, python, "C" or similar programming languages. The program code may execute entirely on the user's computing device, partly on the user's device, partly on a remote computing device, or entirely on the remote computing device or server. In the case of remote computing devices, the remote computing device may be connected to the user computing device through any kind of network, including a Local Area Network (LAN) or a Wide Area Network (WAN), or may be connected to an external computing device (e.g., connected via the Internet using an Internet service provider).
The flowcharts and block diagrams in the figures illustrate the architecture, functionality, and operation of possible implementations of systems, methods and computer program products according to various embodiments of the present disclosure. In this regard, each block in the flowchart or block diagrams may represent a module, segment, or portion of code, which comprises one or more executable instructions for implementing the specified logical function(s). It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or the blocks may sometimes be executed in the reverse order, depending upon the functionality involved. It will also be noted that each block of the block diagrams or flowchart illustration, and combinations of blocks in the block diagrams or flowchart illustration, can be implemented by special purpose hardware-based systems which perform the specified functions or acts, or combinations of special purpose hardware and computer instructions. Those skilled in the art will appreciate that the features recited in the various embodiments of the disclosure and/or in the claims may be combined in various combinations and/or combinations, even if such combinations or combinations are not explicitly recited in the disclosure. In particular, the features recited in the various embodiments of the present disclosure and/or the claims may be variously combined and/or combined without departing from the spirit and teachings of the present disclosure. All such combinations and/or combinations fall within the scope of the present disclosure.
The embodiments of the present disclosure are described above. These examples are for illustrative purposes only and are not intended to limit the scope of the present disclosure. Although the embodiments are described above separately, this does not mean that the measures in the embodiments cannot be used advantageously in combination. The scope of the disclosure is defined by the appended claims and equivalents thereof. Various alternatives and modifications can be made by those skilled in the art without departing from the scope of the disclosure, and such alternatives and modifications are intended to fall within the scope of the disclosure.
Claims (10)
1. A blockchain system implementation-based data processing method, the blockchain system including a plurality of blockchain nodes configured with a first blockchain ledger, a second blockchain ledger, a first smart contract, and a second smart contract, the method comprising:
For each blockchain node in the blockchain system, responding to a trigger timing task, and calling the first intelligent contract to inquire the first blockchain ledger so as to obtain at least one first block associated with the blockchain node;
under the condition that a first target block exists in at least one first block, analyzing and processing the first target block to obtain target data;
Determining a service identifier based on the target data;
determining a first flow definition file associated with the service identifier from the second blockchain ledger;
Determining a first target blockchain node based on the first procedure definition file;
Generating a second block based on the target data and the first target blockchain node; and
Writing the second block into the first blockchain ledger.
2. The method of claim 1, wherein the determining, from the second blockchain ledger, a first flow definition file associated with the service identity comprises:
acquiring at least one third block associated with the service identifier from the second blockchain ledger;
determining a second target block from at least one of the third blocks; and
And analyzing the second target block to obtain the first flow definition file.
3. The method of claim 2, wherein the determining a second target block from at least one of the third blocks comprises:
and determining the third block located at the tail end of the second blockchain ledger in at least one third block as the second target block.
4. The method of claim 2, wherein the blockchain node is further configured with a third smart contract;
The method further comprises the steps of:
In response to receiving a second process definition file, determining a plurality of second target blockchain nodes associated with the second process definition file;
invoking a third smart contract to initiate a first consensus proposal to a plurality of the second target blockchain nodes;
packing the second process definition file into the third block if it is determined that a plurality of the second target blockchain nodes agree on the first consensus proposal; and
Writing the third block into the second blockchain ledger.
5. The method of claim 1, wherein the first block is configured with a processing state identification;
The method further comprises the steps of:
In the case that the processing state identification is determined to be the unprocessed first block, the first target block is determined to be the first target block.
6. The method of any one of claims 1-5, further comprising:
For each blockchain node, initiating a second consensus proposal to other blockchain nodes of the blockchain system with a third target block written into a first blockchain ledger or a second blockchain ledger of the blockchain node; and
And writing the third target block into a first blockchain ledger or a second blockchain ledger of other blockchain nodes of the blockchain system under the condition that the other blockchain nodes reach consensus on the second consensus proposal.
7. A blockchain system implementation-based data processing apparatus, the blockchain system including a plurality of blockchain nodes configured with a first blockchain ledger, a second blockchain ledger, a first smart contract, and a second smart contract, the apparatus comprising:
The query module is used for responding to the triggering timing task for each blockchain node in the blockchain system, calling the first intelligent contract to query the first blockchain account book and obtaining at least one first block associated with the blockchain node;
the first processing module is used for analyzing and processing the first target block to obtain target data under the condition that the first target block exists in at least one first block;
the first processing sub-module is used for determining a service identifier based on the target data;
a second processing sub-module, configured to determine a first flow definition file associated with the service identifier from the second blockchain ledger;
A third processing sub-module for determining a first target blockchain node based on the first procedure definition file;
A fourth processing sub-module for generating a second block based on the target data and the first target blockchain node; and
And a fifth processing sub-module, configured to write the second block into the first blockchain ledger.
8. An electronic device, comprising:
One or more processors;
a memory for storing one or more instructions,
Wherein the one or more instructions, when executed by the one or more processors, cause the one or more processors to implement the method of any of claims 1 to 6.
9. A computer readable storage medium having stored thereon executable instructions which when executed by a processor cause the processor to implement the method of any of claims 1 to 6.
10. A computer program product comprising computer-executable instructions, the computer executable instructions, when executed, are for implementing the method of any one of claims 1 to 6.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202210371601.8A CN114663080B (en) | 2022-04-08 | 2022-04-08 | Data processing method, device, equipment and medium based on block chain system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202210371601.8A CN114663080B (en) | 2022-04-08 | 2022-04-08 | Data processing method, device, equipment and medium based on block chain system |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN114663080A CN114663080A (en) | 2022-06-24 |
| CN114663080B true CN114663080B (en) | 2024-10-18 |
Family
ID=82035838
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202210371601.8A Active CN114663080B (en) | 2022-04-08 | 2022-04-08 | Data processing method, device, equipment and medium based on block chain system |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN114663080B (en) |
Citations (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107807991A (en) * | 2017-11-07 | 2018-03-16 | 泰康保险集团股份有限公司 | For handling the method and device of block chain data |
Family Cites Families (20)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US10135607B1 (en) * | 2017-08-11 | 2018-11-20 | Dragonchain, Inc. | Distributed ledger interaction systems and methods |
| CN109086325A (en) * | 2018-06-29 | 2018-12-25 | 阿里巴巴集团控股有限公司 | Data processing method and device based on block chain |
| CN109246197B (en) * | 2018-08-15 | 2021-10-15 | 交通银行股份有限公司 | Data processing method and device based on intelligent contract |
| CN109379418A (en) * | 2018-10-09 | 2019-02-22 | 上海点融信息科技有限责任公司 | Method, equipment and the storage medium of file based on block chain processing business system |
| CN110059495B (en) * | 2018-12-14 | 2020-11-17 | 创新先进技术有限公司 | Data sharing method, device and system and electronic equipment |
| CN110032568B (en) * | 2018-12-20 | 2020-05-12 | 阿里巴巴集团控股有限公司 | Data structure reading and updating method and device, and electronic equipment |
| CA3057385C (en) * | 2019-03-01 | 2023-02-14 | Alibaba Group Holding Limited | Methods and devices for protecting sensitive data of transaction activity based on smart contract in blockchain |
| CN110245506B (en) * | 2019-05-30 | 2020-09-01 | 阿里巴巴集团控股有限公司 | Intelligent contract management method and device based on block chain and electronic equipment |
| CN110633323B (en) * | 2019-09-16 | 2023-10-20 | 腾讯科技（深圳）有限公司 | Service data storage method, device, storage medium and computer equipment |
| CN111178892B (en) * | 2019-12-31 | 2023-04-18 | 上海能塔智能科技有限公司 | Block chain-based data flow processing method and device and block chain system |
| CN111339141B (en) * | 2020-02-25 | 2024-10-15 | 腾讯科技（深圳）有限公司 | Data transmission method, block chain node equipment and medium |
| CN111400399B (en) * | 2020-03-04 | 2023-11-14 | 链农(深圳)信息科技有限公司 | Ledger synchronization method, device and hardware equipment of blockchain system |
| CN111416808B (en) * | 2020-03-13 | 2021-04-13 | 财付通支付科技有限公司 | Cross-block-chain data mutual storage method, device, equipment and storage medium |
| CN113824755A (en) * | 2020-06-19 | 2021-12-21 | 华为技术有限公司 | Method, system and related device for processing block chain data |
| CN111931220B (en) * | 2020-09-24 | 2021-01-01 | 腾讯科技（深圳）有限公司 | Consensus processing method, device, medium and electronic equipment for block chain network |
| CN112613877B (en) * | 2020-12-17 | 2021-12-07 | 腾讯科技（深圳）有限公司 | Intelligent contract triggering method and device applied to block chain network and related equipment |
| CN112651741B (en) * | 2021-01-04 | 2024-06-18 | 北京京东乾石科技有限公司 | Block chain-based data processing method and device |
| CN113010561B (en) * | 2021-03-31 | 2022-09-06 | 工银科技有限公司 | Data acquisition method and device based on super account book and computer system |
| CN113596010B (en) * | 2021-07-23 | 2023-04-28 | 腾讯科技（深圳）有限公司 | Data processing method, device, node equipment and computer storage medium |
| CN113612766B (en) * | 2021-07-30 | 2023-04-28 | 北京锐安科技有限公司 | Data management device, method, computer equipment and storage medium |
-
2022
- 2022-04-08 CN CN202210371601.8A patent/CN114663080B/en active Active
Patent Citations (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107807991A (en) * | 2017-11-07 | 2018-03-16 | 泰康保险集团股份有限公司 | For handling the method and device of block chain data |
Also Published As
| Publication number | Publication date |
|---|---|
| CN114663080A (en) | 2022-06-24 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US11004024B2 (en) | Service and resource orchestration system and method, and apparatus | |
| US11716264B2 (en) | In situ triggered function as a service within a service mesh | |
| WO2019144761A1 (en) | Data synchronization method, distributed system and device | |
| CN113032166B (en) | Inter-core communication method, processor, inter-core communication system, and computer-readable storage medium | |
| CN110413676A (en) | The access method and its device of database, electronic equipment and medium | |
| CN111027936A (en) | Workflow realization method, equipment and medium based on intelligent contract in alliance network | |
| CN111526049B (en) | Operation and maintenance system, operation and maintenance method, electronic device and storage medium | |
| CN111277639A (en) | Method and device for maintaining data consistency | |
| CN111208992A (en) | System scheduling workflow generation method and system | |
| US20200322444A1 (en) | Transparent pattern processing in a service mesh | |
| CN108959139A (en) | A kind of CPLD pin multiplexing method and device | |
| US9386010B2 (en) | Abstracted authenticated client connectivity application programming interface (API) | |
| CN114663080B (en) | Data processing method, device, equipment and medium based on block chain system | |
| CN112565340B (en) | Service scheduling method, device, computer system and medium for distributed application | |
| CN110324194B (en) | Method, apparatus, system and medium for load balancing | |
| CN113191889A (en) | Wind control configuration method, configuration system, electronic device and readable storage medium | |
| CN110417597B (en) | Method and device for monitoring certificate, electronic equipment and readable storage medium | |
| CN110968147B (en) | Timer creating method and device, electronic equipment and medium | |
| CN116755799A (en) | Service arrangement system and method | |
| CN112118567A (en) | Device upgrading method, electronic device and medium | |
| CN115599507B (en) | Data processing method, execution workstation, electronic device and storage medium | |
| CN110751560B (en) | Transaction processing method and device, electronic equipment and readable storage medium | |
| CN113595795A (en) | Network communication method, device, system, equipment and medium | |
| CN113778631A (en) | Distributed transaction compensation method and device, electronic equipment and readable storage medium | |
| CN115994022B (en) | Algorithm service calling method and device, electronic equipment and storage medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| TA01 | Transfer of patent application right | ||
| TA01 | Transfer of patent application right |
Effective date of registration: 20221226 Address after: 6 / F, 76 Zhichun Road, Haidian District, Beijing 100086 Applicant after: Beijing Jingdong Zhenshi Information Technology Co.,Ltd. Applicant after: Beijing Jingdong Qianshi Technology Co.,Ltd. Address before: Room a1905, 19 / F, building 2, No. 18, Kechuang 11th Street, Daxing District, Beijing, 100176 Applicant before: Beijing Jingdong Qianshi Technology Co.,Ltd. |
|
| GR01 | Patent grant | ||
| GR01 | Patent grant |