CN-121691192-B - Industrial data acquisition method and system based on edge calculation

CN121691192BCN 121691192 BCN121691192 BCN 121691192BCN-121691192-B

Abstract

The invention relates to the technical field of industrial Internet of things edge calculation, and discloses an industrial data acquisition method and system based on edge calculation. The method comprises the steps of dividing edge domains according to target industrial scene configuration parameters, dynamically configuring data acquisition nodes for each edge domain, dynamically adjusting communication links between the data acquisition nodes and edge gateways according to real-time data flow characteristics reported by the data acquisition nodes, carrying out real-time analysis and load balancing processing on heterogeneous data received by the edge gateways, carrying out performance evaluation and anomaly detection on the processed data flow by utilizing a multi-layer evaluation strategy deployed at the edge gateways, and finally dynamically optimizing the configuration parameters and the communication strategy of the data acquisition nodes according to evaluation and detection results. The invention improves the reliability, the real-time performance and the system self-adaptability of the industrial data acquisition through the dynamic adaptation and the multilayer collaborative evaluation of the communication link.

Inventors

ZHAO HONGBO
Ruan Hangjian

Assignees

杭州赫迈思科技有限公司

Dates

Publication Date: 20260508
Application Date: 20260210

Claims (8)

1. An industrial data acquisition method based on edge calculation, the method comprising: Acquiring configuration parameters of a target industrial scene, dividing the industrial scene into a plurality of edge domains according to the configuration parameters, and comprising: collecting equipment layout information, a communication network topological structure and real-time service requirements of an industrial field as configuration parameters; assigning a unique domain identifier to each edge domain, and establishing an edge domain management list; Dynamically configuring at least one data acquisition node for each edge domain based on the physical topology of each edge domain; according to the real-time data flow characteristics reported by the data acquisition nodes, dynamically adjusting the communication links between the data acquisition nodes and the edge gateway; based on the adjusted communication link, carrying out real-time analysis and load balancing processing on heterogeneous data received by the edge gateway, wherein the real-time analysis and load balancing processing comprises the following steps: Carrying out protocol analysis on the data packet received by the edge gateway, identifying an edge domain identifier of a data source, and classifying the data packet into different processing queues according to the edge domain identifier; Monitoring the load state of each processing queue, dynamically scheduling partial data packets of the queues to idle processing queues when the load of a certain processing queue reaches the upper limit of the processing capacity, recording the processing path of each data packet and updating the processing path to a data flow tracking table; The protocol analysis is performed on the data packet received by the edge gateway, and the identification of the edge domain identifier of the data source comprises the following steps: extracting a protocol header field of a data packet, and analyzing a protocol type, wherein the protocol type comprises a Modbus protocol or an OPCUA protocol; According to the protocol type, matching a predefined protocol template, and acquiring the storage position offset of the edge domain identifier from the protocol template; reading a binary value of the edge field identifier from a payload of the data packet based on the storage location offset; Converting the binary value into a character string format, and verifying whether the character string format accords with the coding rule of the edge domain identifier; if the verification is passed, the edge domain identifier is used for classifying the data packet, otherwise, the data packet is marked as invalid and discarded; Performing performance evaluation and anomaly detection on the data stream subjected to load balancing processing through a multi-layer evaluation strategy deployed at an edge gateway; And dynamically optimizing configuration parameters and communication strategies of the data acquisition node according to the results of performance evaluation and anomaly detection.
2. The method for collecting industrial data based on edge calculation according to claim 1, wherein the step of obtaining the configuration parameters of the target industrial scene, and dividing the industrial scene into a plurality of edge fields according to the configuration parameters, comprises: Determining equipment clusters adjacent to the physical position according to the equipment layout information; each device cluster and its associated communication network are divided into an independent edge domain in combination with the communication network topology.
3. The method for collecting industrial data based on edge computing according to claim 2, wherein the dynamically configuring at least one data collecting node for each edge domain based on the physical topology of each edge domain comprises: analyzing the physical topological structure of each edge domain in the edge domain management list; according to the equipment distribution density in the physical topological structure, calculating the number of data acquisition nodes required by each edge domain; Configuring a device discovery protocol and a data acquisition frequency for each data acquisition node, and establishing a mapping relation table of the data acquisition nodes and an edge domain management list; The method comprises the steps of obtaining physical position coordinates of all industrial equipment in an edge domain, calculating Euclidean distance among the equipment, counting the equipment distribution density based on the Euclidean distance, wherein the equipment distribution density is the equipment number in a unit area, inquiring a preset density and node number mapping table, obtaining basic node number based on the equipment distribution density, combining historical data flow peaks of the edge domain, adjusting the basic node number to obtain final data acquisition node number, and storing the final data acquisition node number into an edge domain management list.
4. The industrial data collection method based on edge computing according to claim 3, wherein dynamically adjusting the communication link between the data collection node and the edge gateway according to the real-time data flow characteristics reported by the data collection node comprises: monitoring a time stamp, data quantity and transmission rate of a data packet reported by a data acquisition node, and starting a link quality evaluation flow when the monitored data quantity exceeds a preset threshold value; And according to the link quality evaluation result, selecting an optimal communication path to establish a standby link between the data acquisition node and the edge gateway, and after the standby link is successfully established, shunting the real-time data stream to the main link and transmitting the real-time data stream to the standby link simultaneously.
5. The method for collecting industrial data based on edge computation according to claim 4, wherein the performing performance evaluation and anomaly detection on the data stream after load balancing processing by using a multi-layer evaluation policy deployed in an edge gateway comprises: in the first tier evaluation, statistics of data throughput and processing delay for each processing queue; In the second layer of evaluation, analyzing the time sequence characteristics of the data packet and detecting an abnormal fluctuation mode; In the third layer evaluation, comparing the characteristic difference degree of the real-time data stream and the historical normal data stream; And summarizing the results of the three-layer evaluation to generate a comprehensive evaluation report.
6. The method for collecting industrial data based on edge computing according to claim 5, wherein dynamically optimizing configuration parameters and communication strategies of the data collecting node according to the results of performance evaluation and anomaly detection comprises: Analyzing the identified performance bottleneck region in the comprehensive evaluation report; Calculating optimal configuration parameters of the data acquisition nodes again aiming at the edge domain corresponding to the performance bottleneck region; Updating the equipment discovery protocol and the data acquisition frequency of the data acquisition node according to the recalculated optimal configuration parameters; And synchronously adjusting the priority of the communication link between the data acquisition node and the edge gateway.
7. The edge computing-based industrial data collection method of claim 6, wherein the parsing the identified performance bottleneck region in the comprehensive assessment report comprises: Extracting performance index data from the comprehensive evaluation report, wherein the performance index data comprises data throughput, processing delay and abnormal detection results; comparing the performance index data with a preset threshold, and identifying an edge domain identifier lower than the threshold; Locating a physical device cluster and a communication path corresponding to the performance bottleneck region based on the edge domain identifier; a detailed analysis report of the performance bottleneck region is generated, including bottleneck causes and optimization suggestions.
8. An industrial data collection system based on edge computing, comprising a memory, a processor and a computer program stored in the memory and running on the processor, characterized in that the processor, when executing the computer program, realizes the steps of the industrial data collection method based on edge computing according to any of the preceding claims 1 to 7.

Description

Industrial data acquisition method and system based on edge calculation Technical Field The invention relates to the technical field of industrial Internet of things edge calculation, in particular to an industrial data acquisition method and system based on edge calculation. Background In an industrial internet of things scene, a large number of sensors and actuators are required to be deployed on an industrial site for data acquisition in order to realize state sensing and intelligent control of the whole production process. The existing typical data acquisition scheme generally adopts a layered and concentrated architecture, and a data acquisition node on site is responsible for collecting equipment data and uploading the data to an edge gateway or a cloud processing center through a pre-planned fixed communication path. The reliability of the communication path and the real-time performance of the data transmission of the immobilized link configuration mode are difficult to be effectively ensured when facing the industrial environment with complex and changeable working conditions and frequent fluctuation. Network congestion or single-point failure is very easy to cause data loss or increase in transmission delay, and the real-time accurate judgment of the upper layer application on the field state is affected. The prior art monitoring and management of data quality has focused on a single dimension. The common practice is to monitor the network on-off state or the bandwidth occupancy of data transmission, and lack a multi-dimensional, cross-layer collaborative analysis and evaluation mechanism from data generation and transmission to convergence full flow. The single-point or single-layer monitoring mode is difficult to accurately identify the complex problems caused by slight equipment faults, network jitter or data self abnormality, and cannot provide a sufficient and accurate decision basis for the self-adaptive optimization of the data acquisition system. In industrial field, there are heterogeneous devices with different communication protocols and data formats, when the edge gateway gathers the data, static load balancing strategies are difficult to cope with dynamic fluctuation of data flow caused by change of production rhythm, uneven load of gateway processing units is easy to cause, performance bottleneck is formed, and overall efficiency of data processing is affected. Disclosure of Invention The invention aims to provide an industrial data acquisition method and system based on edge calculation, so as to solve the problems in the background technology. To achieve the above object, the present invention provides an industrial data acquisition method based on edge calculation, the method comprising: acquiring configuration parameters of a target industrial scene, and dividing the industrial scene into a plurality of edge domains according to the configuration parameters; Dynamically configuring at least one data acquisition node for each edge domain based on the physical topology of each edge domain; according to the real-time data flow characteristics reported by the data acquisition nodes, dynamically adjusting the communication links between the data acquisition nodes and the edge gateway; based on the adjusted communication link, carrying out real-time analysis and load balancing processing on heterogeneous data received by the edge gateway; Performing performance evaluation and anomaly detection on the data stream subjected to load balancing processing through a multi-layer evaluation strategy deployed at an edge gateway; And dynamically optimizing configuration parameters and communication strategies of the data acquisition node according to the results of performance evaluation and anomaly detection. Preferably, the obtaining the configuration parameter of the target industrial scene, dividing the industrial scene into a plurality of edge domains according to the configuration parameter, includes: collecting equipment layout information, a communication network topological structure and real-time service requirements of an industrial field as configuration parameters; Determining equipment clusters adjacent to the physical position according to the equipment layout information; Dividing each equipment cluster and the associated communication network into an independent edge domain by combining a communication network topology structure; Each edge domain is assigned a unique domain identifier and an edge domain management list is built. Preferably, the dynamically configuring at least one data collection node for each edge domain based on the physical topology structure of each edge domain includes: analyzing the physical topological structure of each edge domain in the edge domain management list; according to the equipment distribution density in the physical topological structure, calculating the number of data acquisition nodes required by each edge domain; Configuring a device disc