CN-116743662-B - Data processing method, device, equipment and storage medium

CN116743662BCN 116743662 BCN116743662 BCN 116743662BCN-116743662-B

Abstract

The application provides a data processing method, a device, equipment and a storage medium, which relate to the technical field of communication and are used for improving the data processing efficiency. The method comprises the steps that a central gateway device receives first data information sent by a first edge gateway device, the data information is used for representing data acquired by an acquisition device, and waiting time delay corresponding to the first data information is determined. Further, the center gateway device receives second data information sent by a second edge gateway device, wherein the second edge gateway device is edge gateway devices except the first edge gateway device in the plurality of edge gateway devices, the second data information is data information received by the center gateway device in waiting time delay, fusion processing is conducted on the first data information and the second data information, target fusion data is obtained, and the target fusion data are used for representing data characteristics of the first data information and the second data information.

Inventors

JIA ZIXIANG
ZHANG CHENGYU

Assignees

中国联合网络通信集团有限公司

Dates

Publication Date: 20260512
Application Date: 20230612

Claims (8)

1. A data processing method, which is applied to a central gateway device in a data processing system, wherein the data processing system further comprises a plurality of edge gateway devices and a plurality of acquisition devices, the plurality of edge gateway devices are in one-to-one correspondence with the plurality of acquisition devices, and the method comprises: Receiving first data information sent by first edge gateway equipment, wherein the data information is used for representing data acquired by acquisition equipment, and the first edge gateway equipment is any one of the plurality of edge gateway equipment; Determining the time delay corresponding to the time delay requirement of first acquisition equipment and the difference value of preset processing time delay and preset fusion time delay as waiting time delay corresponding to the first data information, wherein the waiting time delay is smaller than the time delay requirement of the first acquisition equipment, and the first acquisition equipment is acquisition equipment connected with first edge gateway equipment; Receiving second data information sent by second edge gateway equipment, wherein the second edge gateway equipment is edge gateway equipment except the first edge gateway equipment in the plurality of edge gateway equipment, and the second data information is data information received by the central gateway equipment in the waiting time delay; Updating the waiting time delay corresponding to the first data information into the waiting time delay corresponding to the second data information under the condition that the waiting time delay corresponding to the second data information is smaller than the waiting time delay corresponding to the first data information; And carrying out fusion processing on the first data information and the second data information to obtain target fusion data, wherein the target fusion data is used for representing the data characteristics of the first data information and the second data information.
2. The method of claim 1, wherein receiving the second data information sent by the second edge gateway device comprises: Receiving third data information sent by third edge gateway equipment in the waiting time delay; And determining the third edge gateway device as a second edge gateway device and determining the third data information as the second data information when the third edge gateway device is different from the first edge gateway device and the second edge gateway device.
3. The method of claim 1, wherein receiving the second data information sent by the second edge gateway device comprises: Receiving third data information sent by third edge gateway equipment in the waiting time delay; and determining the third edge gateway device as the first edge gateway device and the third data information as the first data information when the third edge gateway device is one of the first edge gateway device and the second edge gateway device.
4. The data processing device is characterized by being arranged in a central gateway device in a data processing system, the data processing system also comprises a plurality of edge gateway devices and a plurality of acquisition devices, the plurality of edge gateway devices are in one-to-one correspondence with the plurality of acquisition devices, and the data processing device comprises a receiving unit, a determining unit and a processing unit; The receiving unit is used for receiving first data information sent by first edge gateway equipment, the data information is used for representing data acquired by acquisition equipment, and the first edge gateway equipment is any one of the plurality of edge gateway equipment; The determining unit is configured to determine a delay corresponding to a delay requirement of a first acquisition device, and a difference value between a preset processing delay and a preset fusion delay as a waiting delay corresponding to the first data information, where the waiting delay is smaller than the delay requirement of the first acquisition device, and the first acquisition device is an acquisition device connected with the first edge gateway device; The receiving unit is further configured to receive second data information sent by a second edge gateway device, where the second edge gateway device is an edge gateway device other than the first edge gateway device in the plurality of edge gateway devices, and the second data information is data information received by the central gateway device in the waiting time delay; The processing unit is further configured to update the latency corresponding to the first data information to the latency corresponding to the second data information when the latency corresponding to the second data information is less than the latency corresponding to the first data information; The processing unit is used for carrying out fusion processing on the first data information and the second data information to obtain target fusion data, and the target fusion data is used for representing the data characteristics of the first data information and the second data information.
5. The data processing apparatus according to claim 4, wherein the receiving unit is specifically configured to receive, during the waiting time delay, third data information sent by a third edge gateway device; The determining unit is further configured to determine the third edge gateway device as a second edge gateway device and determine the third data information as the second data information when the third edge gateway device is different from the first edge gateway device and the second edge gateway device.
6. The data processing apparatus according to claim 4, wherein the receiving unit is specifically configured to receive, during the waiting time delay, third data information sent by a third edge gateway device; The determining unit is further configured to determine, when the third edge gateway device is one of the first edge gateway device and the second edge gateway device, the third edge gateway device as the first edge gateway device, and determine the third data information as the first data information.
7. A network device comprising a memory and a processor; The memory is coupled to the processor; the memory is used for storing computer program codes, and the computer program codes comprise computer instructions; the network device performing the data processing method of any of claims 1-3 when the processor executes the computer instructions.
8. A computer readable storage medium having instructions stored therein, which when run on a network device, cause the network device to perform the data processing method of any of claims 1-3.

Description

Data processing method, device, equipment and storage medium Technical Field The present application relates to the field of communications technologies, and in particular, to a data processing method, apparatus, device, and storage medium. Background The edge computing model is a miniature server/processor with computing capability deployed on a data side, an application side and an equipment side, so that the service processing load of the central cloud is shared, the service application side automatically processes required data or service through the edge server, the information transmission delay is further reduced, and the data processing efficiency is improved. In an actual production scene, a system constructed by informatization and intelligent means is often supported by massive data, and the traditional center cloud uniformly processes data of the data sources, however, along with the exponential promotion of the data scale, the data processing is difficult to be efficiently ensured by the storage and calculation resources of the center cloud alone. Disclosure of Invention The application provides a data processing method, a device, equipment and a storage medium, which are used for improving the efficiency of data processing. In order to achieve the above purpose, the application adopts the following technical scheme: The first aspect provides a data processing method, which is applied to a central gateway device in a data processing system, wherein the data processing system further comprises a plurality of edge gateway devices and a plurality of acquisition devices, the plurality of edge gateway devices are in one-to-one correspondence with the plurality of acquisition devices, the method comprises the steps that the central gateway device receives first data information sent by a first edge gateway device, the data information is used for representing data acquired by the acquisition devices, and the first edge gateway device is any one of the plurality of edge gateway devices; and determining a waiting time delay corresponding to the first data information, wherein the waiting time delay is smaller than a time delay requirement of the first acquisition equipment, and the first acquisition equipment is the acquisition equipment connected with the first edge gateway equipment. Further, the center gateway device receives second data information sent by a second edge gateway device, wherein the second edge gateway device is edge gateway devices except the first edge gateway device in the plurality of edge gateway devices, the second data information is data information received by the center gateway device in waiting time delay, fusion processing is conducted on the first data information and the second data information, target fusion data is obtained, and the target fusion data are used for representing data characteristics of the first data information and the second data information. In the data processing method provided by the application, the acquisition equipment in the data processing system can process the acquired data to obtain corresponding data information in the process of acquiring the data and reporting the data to the server through the edge gateway equipment, so that the data acquired by a plurality of acquisition equipment are fused in the central gateway equipment and reported to the server, the data processing efficiency is improved, and the efficient fusion of the data is realized in the time delay requirement. In one possible design, the central gateway device receives the second data information sent by the second edge gateway device, and the central gateway device receives the third data information sent by the third edge gateway device in a waiting time delay, and determines the third edge gateway device as the second edge gateway device and determines the third data information as the second data information when the third edge gateway device is different from the first edge gateway device and the second edge gateway device. The design provides a specific implementation mode for receiving the second data information sent by the second edge gateway device. In one possible design, the central gateway device receives the second data information sent by the second edge gateway device, and the central gateway device receives the third data information sent by the third edge gateway device in a waiting time delay, and determines the third edge gateway device as the first edge gateway device and determines the third data information as the first edge information when the third edge gateway device is one of the first edge gateway device and the second edge gateway device. According to the design, the purpose that waiting is finished when waiting for time delay is achieved, and if data information sent by the same edge device is received, the first data information and the second data information which are determined before are fused. In one possible design, the central gateway