CN-121391123-B - Wine bin blockchain service system based on layered elastic expansion architecture and data processing method

CN121391123BCN 121391123 BCN121391123 BCN 121391123BCN-121391123-B

Abstract

The invention relates to the technical field of blockchain data processing, in particular to a wine bin blockchain service system and a data processing method based on a layered elastic expansion framework, wherein the method comprises the steps of constructing the layered elastic expansion framework based on the information of the wine bin blockchain service requirement; the method comprises the steps of establishing an elastic expansion pool comprising block chain nodes and an Internet of things gateway, carrying out data conversion on wine bin uplink data acquired by an equipment access layer, preprocessing the wine bin uplink data after data conversion, generating a certification contract matched with a data block to be uplink based on a pluggable intelligent contract template library, carrying out identity verification on a corresponding node role in the data block to be uplink, carrying out transaction verification analysis on the data block to be uplink, and carrying out data uplink on the data block to be uplink which meets preset transaction verification analysis conditions. According to the invention, distributed evidence storage and elastic expansion of data are realized through the blockchain, multi-source heterogeneous data in the wine bin are integrated efficiently, and the uplink efficiency of high-frequency data of the wine bin is improved remarkably.

Inventors

HAN YUNJIE
CHEN FENG
LEI HONGFEI
LI CHANG

Assignees

贵州中科享链云科技有限公司

Dates

Publication Date: 20260505
Application Date: 20251226

Claims (6)

1. The wine bin blockchain service data processing method based on the layered elastic expansion architecture is characterized by comprising the following steps of: S1, constructing a layered elastic expansion framework based on wine bin blockchain service demand information, wherein the layered elastic expansion framework comprises an infrastructure layer and a core engine layer, and the core engine layer comprises an equipment access layer, a data processing layer and a blockchain service layer; S2, deploying a Docker containerized cluster according to an infrastructure layer, and establishing an elastic expansion pool containing block chain nodes and an Internet of things gateway through a preset dynamic resource allocation mechanism and the Docker containerized cluster; S3, carrying out data conversion on the wine bin uplink data acquired by the equipment access layer based on the elastic expansion pool and the protocol conversion rule in the equipment access layer to obtain wine bin uplink data after data conversion; S4, preprocessing the wine bin uplink data after data conversion in a data processing layer according to a preset data processing rule to obtain a preprocessed data set conforming to a message middleware transmission mechanism, and sending the preprocessed data set to a block chain service layer through a message middleware to obtain a data block to be uplink; S5, generating a certificate storing contract matched with the data block to be uplinked based on a pluggable intelligent contract template library, carrying out identity verification on a corresponding node role in the data block to be uplinked according to the certificate storing contract and a dynamic alliance mechanism, and adding the node role meeting preset identity verification conditions into a blockchain service network to obtain a dynamic alliance network; S6, carrying out transaction verification analysis on the data blocks to be uplink through a hierarchical consensus mechanism and a dynamic alliance network, and carrying out data uplink on the data blocks to be uplink which meet preset transaction verification analysis conditions; the step S2 comprises the following steps: S21, quantitatively evaluating computing resources, storage resources and network resources of an infrastructure layer to obtain a resource evaluation parameter set, and configuring the operation environment parameters of the Docker containerized cluster based on the resource evaluation parameter set to obtain a configured Docker operation environment; S22, determining the quantity and type distribution of initial container examples of the blockchain nodes and the gateway of the Internet of things according to the configured resource threshold parameters in the Docker operation environment, and deploying container examples in the configured Docker operation environment according to the quantity and type distribution of the initial container examples to form an initial Docker container cluster; S23, based on a load threshold algorithm in a preset dynamic resource allocation mechanism, monitoring node load parameters of an initial Docker containerized cluster in real time, generating a resource demand prediction model, setting dynamic expansion trigger conditions of container instances according to the resource demand prediction model, and determining a resource expansion rule set based on the dynamic expansion trigger conditions; s24, carrying out elastic expansion processing on container examples in the initial Docker containerization cluster according to a resource expansion rule set to form an elastic expansion pool comprising a block chain node container capable of being dynamically adjusted and an Internet of things gateway container; the step S5 comprises the following steps: s51, carrying out structural analysis on the data block to be uplinked to obtain a characteristic parameter set, inputting the characteristic parameter set into a pluggable intelligent contract template library for analysis, and generating a certificate-storing contract matched with the data block to be uplinked; s52, resolving the certificate storing contract to obtain a certificate storing contract resolving result, and determining each identity verification dimension of the node role in the dynamic alliance mechanism and a weight distribution rule corresponding to each identity verification dimension according to the certificate storing contract resolving result; S53, carrying out structural analysis on the data block to be uplink to obtain corresponding node role information, wherein the node role information comprises attribute values corresponding to each identity verification dimension of each node role in a dynamic alliance mechanism; s54, obtaining attribute values corresponding to all the identity verification dimensions in the node role information, mapping the attribute values corresponding to all the identity verification dimensions into a preset numerical interval to obtain standardized attribute values corresponding to all the identity verification dimensions, and determining weight coefficients of all the identity verification dimensions according to weight distribution rules; S55, calculating the identity verification comprehensive score S of the node role according to the standardized attribute value corresponding to each identity verification dimension and the weight coefficient of each identity verification dimension, wherein the mathematical expression of the identity verification comprehensive score S is as follows: Where n represents the number of authentication dimensions, A normalized attribute value representing the i-th authentication dimension, , A weight coefficient representing the i-th authentication dimension, , ; S56, comparing the identity verification comprehensive score S with a preset identity verification comprehensive score threshold S0, judging the identity verification condition of each node role according to the comparison result, and obtaining a dynamic alliance network according to the judgment result, wherein the dynamic alliance network comprises the following steps: when S is more than or equal to S0, judging that the authentication condition of the node role is up to standard, and adding the node role with the authentication condition judged as up to standard into the dynamic alliance network; When S < S0, judging that the authentication condition of the node role is an unqualified condition, and carrying out authentication on the node role of which the authentication condition is judged to be an unqualified condition again until S is more than or equal to S0; The step S6 comprises the following steps: s61, preliminarily verifying format normalization and digital signature validity of the data block to be uplink through a base layer consensus node in a layered consensus mechanism, and generating a first verification result; S62, performing secondary verification on service relevance of the data block to be uplink based on a role authority rule in the dynamic alliance network and a node role identity in a first verification result, and generating a second verification result, wherein the role authority rule comprises a service participation range and an operation authority of the node role in the dynamic alliance network; And S63, carrying out final transaction verification on the data block to be uplink through an application layer consensus node in the hierarchical consensus mechanism by combining a second verification result and a real-time node state of the dynamic alliance network, and adding the data block to be uplink meeting the preset transaction verification analysis conditions into a chain structure of the blockchain service layer when the preset transaction verification analysis conditions are met.
2. The wine bin blockchain service data processing method based on the hierarchical elastic expansion architecture of claim 1, wherein the step S1 comprises the following steps: s11, analyzing the storage capacity, the access scale of the equipment of the Internet of things and the dynamic expansion requirement of the blockchain nodes according to the information of the blockchain service requirement of the wine bin, and determining a hardware resource allocation strategy of an infrastructure layer and a functional module division scheme of a core engine layer; S12, determining a resource calling interface between an infrastructure layer and a core engine layer and a data interaction interface among a device access layer, a data processing layer and a blockchain service layer in the core engine layer based on the hardware resource allocation strategy and the function module division scheme; S13, establishing a dynamic resource allocation and data flow mechanism among all layers through the resource calling interface and the data interaction interface to form a layered elastic expansion framework.
3. The wine bin blockchain service data processing method based on the hierarchical elastic expansion architecture of claim 1, wherein the step S3 comprises the following steps: S31, determining a communication protocol adapted to external monitoring equipment based on a universal Internet of things protocol conversion module in an equipment access layer, collecting original multi-source heterogeneous data from the external monitoring equipment according to the communication protocol, and inputting the original multi-source heterogeneous data into an elastic expansion pool, wherein the original multi-source heterogeneous data comprises wine bin environment data and monitoring data of a digital wine bin integrated management system; S32, carrying out data conversion on the original multi-source heterogeneous data through a protocol conversion rule in the equipment access layer to obtain the wine bin uplink data after the data conversion.
4. The wine bin blockchain service data processing method based on the hierarchical elastic expansion architecture of claim 1, wherein the step S4 comprises the following steps: S41, preprocessing the converted wine bin uplink data based on preset data processing rules in a data processing layer, outputting a preprocessed data set conforming to a message middleware transmission mechanism, wherein the preset data processing rules comprise data field mapping rules, outlier filtering thresholds and a data format conversion protocol, and according to the data field mapping rules, the original fields in the converted wine bin uplink data and target fields in a block chain are corresponding and adjusted to obtain mapped data, range detection is carried out on the mapped data according to the outlier filtering thresholds, outliers exceeding the preset data range are filtered, filtered data are obtained, and the filtered data are converted into data formats conforming to the message middleware transmission mechanism according to the data format conversion protocol; S42, the preprocessed data set is sent to a data receiving port of the block chain service layer through the message middleware, transaction verification, time stamp addition and Merkel tree node calculation are carried out on the preprocessed data set through the block chain service layer, and a data block to be uplinked comprising a data hash value pointer and a preamble block reference is generated.
5. The method for processing the wine bin blockchain service data based on the hierarchical elastic expansion architecture of claim 1, wherein the step S63 comprises the following steps: S631, performing association analysis on the second verification result and the real-time node state of the dynamic alliance network through the application layer consensus node to obtain a verification input information set; s632, carrying out final transaction verification on the consistency of transaction logic of the data block to be uplink and the matching of the node authority and the real-time node state based on the verification input information set, and generating a verification conclusion; S633, comparing the verification conclusion with a preset transaction verification analysis condition, and adding the data block to be uplink meeting the preset transaction verification analysis condition into a chain structure of the block chain service layer through a Merker tree algorithm.
6. The wine bin blockchain service system based on the layered elastic expansion architecture is applied to the wine bin blockchain service data processing method based on the layered elastic expansion architecture, and is characterized by comprising the following steps: The system comprises a layered elastic expansion framework construction module, a storage module and a storage module, wherein the layered elastic expansion framework construction module is used for constructing a layered elastic expansion framework based on the information of the wine bin blockchain service requirement, the layered elastic expansion framework comprises an infrastructure layer and a core engine layer, and the core engine layer comprises an equipment access layer, a data processing layer and a blockchain service layer; the elastic expansion pool building module is used for deploying the Docker containerized cluster according to the infrastructure layer and building an elastic expansion pool comprising block chain nodes and an Internet of things gateway through a preset dynamic resource allocation mechanism and the Docker containerized cluster; the data conversion module is used for carrying out data conversion on the wine bin uplink data acquired by the equipment access layer based on the elastic expansion pool and the protocol conversion rules in the equipment access layer to obtain wine bin uplink data after data conversion; The data transmission module is used for preprocessing the wine bin uplink data after data conversion in the data processing layer according to a preset data processing rule to obtain a preprocessed data set conforming to a message middleware transmission mechanism, and transmitting the preprocessed data set to the blockchain service layer through the message middleware to obtain a data block to be uplink; The dynamic alliance network construction module is used for generating a certificate storing contract matched with the data block to be uplinked based on the pluggable intelligent contract template library, carrying out identity verification on the corresponding node role in the data block to be uplinked according to the certificate storing contract and the dynamic alliance mechanism, and adding the node role meeting the preset identity verification condition into the blockchain service network to obtain a dynamic alliance network; the data uplink module is used for carrying out transaction verification analysis on the data blocks to be uplink through a hierarchical consensus mechanism and a dynamic alliance network, and carrying out data uplink on the data blocks to be uplink which meet the preset transaction verification analysis conditions.

Description

Wine bin blockchain service system based on layered elastic expansion architecture and data processing method Technical Field The invention relates to the technical field of blockchain data processing, in particular to a wine bin blockchain service system based on a layered elastic expansion architecture and a data processing method. Background Under the background of digital transformation acceleration in the wine industry, a digital wine warehouse management system has become a core hub for connecting production, quality inspection, distribution and allocation of full chains. The current system realizes basic functions such as tracing of brewing raw materials, monitoring of fermentation process, detection of wine components, storage inventory management, distribution path optimization and the like through tools such as an Internet of things sensor and ERP software, and remarkably improves industry operation efficiency. For example, the production link can monitor key indexes such as fermentation temperature and humidity of the wine body through real-time data, the quality inspection link generates a standardized detection report by means of spectrum analysis and other technologies, and the distribution link tracks the transportation track of the wine through the logistics management module. However, as wine markets scale up and supply chain complexity increases, digital wine warehouse management systems increasingly expose deep technical bottlenecks, particularly when fused with blockchain technology. On the one hand, the difficulty of multi-source heterogeneous data integration is derived from fragmentation of the data ecology. The wine bin data comprise Internet of things equipment logs (such as fermenter sensor data) of the production end, laboratory analysis reports (such as alcohol concentration and ester substance content) of the quality inspection end, logistics GPS track and order data of the distribution end, secret formula parameters of the allocation link and the like. The data come from different main bodies such as industrial equipment, detection instruments, third party logistics systems and the like respectively, the characteristics of coexistence of structuring (such as numerical detection results) and unstructured (such as formula documents and imaging quality inspection reports) exist, and data standards of all links are independently formulated by enterprises, lack of uniform standards of the industries, cause incompatibility of data formats and poor semantic intercommunication, and are difficult to realize efficient association and integration in the traditional centralized database. On the other hand, the underadaptability of the blockchain technology is due to the limitation of the underlying architecture. The distributed certification of the blockchain depends on a node consensus mechanism, and the high frequency data (such as actual stock change and update of the logistics nodes) in the wine bin needs second-level uplink, and the consensus algorithm (such as bitcoin and ethernet) of the existing mainstream blockchain (such as workload certification PoW and rights certification PoS) has the problems of low transaction throughput (only tens of pens per second) and long confirmation delay, so that the real-time writing requirement of the high frequency data is difficult to bear. Meanwhile, the elastic expansion is limited by a rigid framework of the blockchain, wherein the increase and decrease of the network nodes of the traditional blockchain are required to be subjected to a complex consensus process, storage and calculation resources cannot be dynamically adjusted according to the peak and valley of wine warehouse service (such as data volume surge caused by the rapid increase of orders in a strong season), and when the data volume exceeds a preset threshold, storage congestion on the chain is easy to occur, so that the uplink efficiency is further reduced. Chinese patent publication No. CN114091858a discloses a wine management method and system based on a blockchain technology, including a central server, the connection end of the central server is provided with a production line module, a detection module, a cargo allocation module and a distribution module, the detection module includes a production condition detection unit, a stock period detection unit and a cargo accumulation detection unit, the cargo allocation module includes an area allocation unit and a reserve early warning unit, and the distribution module includes an old customer reservation unit and a new customer reservation unit. According to the scheme, although wine production supervision, quality detection, distribution and allocation can be realized, data distributed storage and elastic expansion cannot be realized through a block chain, and multi-source heterogeneous data in a wine bin are difficult to integrate efficiently, so that the uplink efficiency of high-frequency data of the wine bin is reduced. Discl