CN104933083B - A kind of processing method and processing device of sensing data dynamic retractility - Google Patents

Abstract

The invention discloses a processing method and device for dynamic expansion and contraction of sensor data, wherein the method includes: receiving a sensor message, and extracting a sensor ID according to the sensor message, the sensor message includes a sensor message header and sensor data; The mapping relationship between the sensor ID and the sensor structure in the data header determines the sensor structure corresponding to the sensor ID. The sensor structure includes the sensor survival time and the sensor packet header pointer; update the sensor survival time, and locate the sensor according to the sensor packet header pointer The message header, the sensor message header includes the sensor data array start pointer and the sensor data array end pointer; according to the sensor message header including the sensor data array start pointer and the sensor data array end pointer, the sensor data is stored in the sensor data linked list. This realizes the reduction of invalid sensor data and improves the utilization rate of memory space.

Description

A processing method and device for dynamic expansion and contraction of sensor data

technical field

The present invention relates to the technical field of sensor data processing in the field of smart grids, in particular to a processing method and device for dynamic scaling of sensor data.

Background technique

With the rapid development of my country's power grid, equipment and systems in various links such as power generation, transmission, transformation, distribution, consumption, and dispatch are becoming increasingly complex and large; the perception, collection, and aggregation of various basic data have promoted a large number of sensor Use of equipment, measuring tools, smart terminals, etc. From the perspective of current power production and operation, on the one hand, it is necessary to develop various types of sensing equipment to realize the perception and collection of on-site information, and to broaden the depth and breadth of information sources; on the other hand, the increasing number and types of sensors will lead to various The simultaneous use of sensing technology and specifications has led to the inability to achieve a unified data expression (identification, semantics, data expression format, etc.) of various collected data. The resulting massive heterogeneous sensor data processing problem has become a bottleneck for popularization and application.

In the course of realizing the present invention, the inventor finds that there are at least the following problems in the prior art:

(1) The huge amount of sensor data and the data flow impact caused by the convergence of sensor networks, the use of fixed memory data cache is limited by computer hardware resources, and the use of disk cache cannot meet the performance requirements.

(2) With the deepening of sensor applications, new types of sensors are inevitably introduced, and the dynamic processing of new data types limits industry applications.

(3) Due to the external environment and the sensor itself, it is necessary to combine multiple sensors to calculate the measurand, and multi-sensor aggregation analysis improves the index of the target quantity. Due to resource constraints, post-event analysis is mostly used for this kind of business at present, and it is difficult to achieve instant early warning.

Contents of the invention

The purpose of the present invention is to overcome the defect that the processing of mass sensor data in the smart grid is easily limited by resources and cannot meet the performance requirements in the prior art. According to one aspect of the present invention, a processing method for dynamic scaling of sensor data is proposed.

A processing method for dynamic scaling of sensor data provided by an embodiment of the present invention includes: receiving a sensor message, and extracting a sensor ID according to the sensor message, where the sensor message includes a sensor message header and sensor data; The mapping relationship between the sensor ID and the sensor structure determines the sensor structure corresponding to the sensor ID. The sensor structure includes the sensor survival time and the sensor packet header pointer; the sensor survival time is updated, and the sensor packet header is positioned according to the sensor packet header pointer. The sensor message header includes the sensor data array start pointer and the sensor data array end pointer; according to the sensor message header including the sensor data array start pointer and the sensor data array end pointer, the sensor data is stored in the sensor data linked list.

In the above technical solution, when there is no sensor structure corresponding to the sensor ID in the mapping relationship between the sensor ID and the sensor structure, a new sensor structure is assigned to the sensor ID, and the sensor data header is updated.

In the above technical solution, it also includes: traversing the sensor structure according to the total number of sensors and the sensor structure pointer list, monitoring the sensor survival time, the total number of sensors and the sensor structure pointer list are stored in the sensor data header; when the sensor survival time is less than the first preset threshold , determine and delete the corresponding sensor header and sensor data according to the sensor header pointer in the sensor structure; release the resources of the sensor structure, and update the sensor data header.

The purpose of the present invention is to overcome the defect that the processing of mass sensor data in the smart grid is easily limited by resources and cannot meet the performance requirements in the prior art. According to one aspect of the present invention, a processing method for dynamic scaling of sensor data is proposed.

The embodiment of the present invention provides a processing method for dynamic scaling of sensor data, including: regularly traversing the sensor data linked list, when it is determined that there is new cached sensor data, according to the sensor manufacturer type, sensor type and sensor version in the sensor data Find the corresponding sensor data processing method in the data processing library; process the newly cached sensor data according to the sensor data processing method, and update the processing method survival time of the sensor data processing method.

In the above technical solution, it also includes: regularly traversing the sensor data processing methods in the sensor data processing library, and monitoring the survival time of the processing method; when the survival time of the processing method is less than the second preset threshold, delete the corresponding Resources for sensor data processing methods.

In the above technical solution, it also includes: traversing each aggregation processing configuration instance in the configuration library, where the aggregation processing configuration instance includes a sensor ID list and an aggregation processing method ID; checking whether the relevant sensor data of the relevant sensor is updated according to the relevant sensor ID list; When it is determined that the sensor data is updated, look up the corresponding data aggregation processing method in the data aggregation processing library according to the aggregation processing method ID; process the relevant sensor data according to the sensor data aggregation processing method, and update the aggregation processing method survival time of the sensor data aggregation processing method .

In the above technical solution, it also includes: regularly traversing the sensor data aggregation processing method in the sensor data aggregation processing library, monitoring the survival time of the aggregation processing method; when the survival time of the aggregation processing method is less than the third preset threshold, delete and aggregate processing method A resource for sensor data aggregation processing methods corresponding to time-to-live.

The purpose of the present invention is to overcome the defect that the processing of mass sensor data in the smart grid is easily limited by resources and cannot meet the performance requirements in the prior art. According to one aspect of the present invention, a processing device for dynamically scaling sensor data is proposed.

An embodiment of the present invention provides a processing device for dynamically scaling sensor data, including: a data cache engine, a sensor data header, and a sensor data linked list;

The data cache engine is used to receive the sensor message and extract the sensor ID according to the sensor message. The sensor message includes the sensor message header and the sensor data;

Determine the sensor structure corresponding to the sensor ID according to the mapping relationship between the sensor ID and the sensor structure in the sensor data header, the sensor structure includes the sensor survival time and the sensor header pointer;

Update the sensor survival time, and locate the sensor header according to the sensor header pointer, the sensor header includes the sensor data array start pointer and the sensor data array end pointer;

According to the sensor message header including the sensor data array start pointer and the sensor data array end pointer, the sensor data is stored in the sensor data linked list;

The sensor data header is used to store the mapping relationship between the sensor ID and the sensor structure;

The sensor data linked list is used to store sensor data.

In the above technical solution, the data cache engine is also used to allocate a new sensor structure for the sensor ID when there is no sensor structure corresponding to the sensor ID in the mapping relationship between the sensor ID and the sensor structure;

The sensor data header is also used to perform update operations.

In the above technical solution, the data cache engine is also used to traverse the sensor structure according to the total number of sensors and the sensor structure pointer list, and monitor the sensor survival time; when the sensor survival time is less than the first preset threshold, according to the sensor message in the sensor structure The header pointer determines and indicates to delete the corresponding sensor header and sensor data;

Release the resources of the sensor structure and update the sensor data header.

The sensor data header is also used to store the total number of sensors and the sensor structure pointer list, and when the sensor survival time is less than the first preset threshold, release the resources of the sensor structure and perform an update operation;

The sensor data linked list is also used to delete the corresponding sensor packet header and sensor data when the sensor survival time is less than the first preset threshold.

The purpose of the present invention is to overcome the defect that the processing of mass sensor data in the smart grid is easily limited by resources and cannot meet the performance requirements in the prior art. According to one aspect of the present invention, a processing device for dynamically scaling sensor data is proposed.

The embodiment of the present invention provides a processing device for dynamic expansion and contraction of sensor data, which is characterized in that it includes: a data processing engine, a sensor data linked list, and a sensor data processing library;

The data processing engine is used to periodically traverse the sensor data linked list, and when it is determined that there is newly cached sensor data, search for the corresponding sensor data processing method in the sensor data processing library according to the sensor manufacturer type, sensor type and sensor version in the sensor data; Process the newly cached sensor data according to the sensor data processing method and update the processing method lifetime of the sensor data processing method;

The sensor data linked list is used to store sensor data;

The sensor data processing library is used to store sensor data processing methods.

In the above technical solution, the data processing engine is also used to periodically traverse the sensor data processing methods in the sensor data processing library, and monitor the survival time of the processing methods; when the survival time of the processing methods is less than the second preset threshold, instruct to delete and process the method Resources for sensor data processing methods corresponding to time-to-live;

The sensor data processing library is further used for deleting the resource of the sensor data processing method corresponding to the processing method lifetime when the processing method lifetime is less than a second preset threshold.

In the above technical solution, it also includes: an aggregation processing engine, a configuration library and a data aggregation processing library;

The aggregation processing engine is used to traverse each aggregation processing configuration instance in the configuration library. The aggregation processing configuration instance includes a sensor ID list and an aggregation processing method ID; check whether the relevant sensor data of the relevant sensor is updated according to the relevant sensor ID list; when determining the sensor data When updating, search for the corresponding data aggregation processing method in the data aggregation processing library according to the aggregation processing method ID; process related sensor data according to the sensor data aggregation processing method, and update the aggregation processing method survival time of the sensor data aggregation processing method;

The configuration library is used to store an aggregation processing configuration instance including a list of sensor IDs and an aggregation processing method ID;

The data aggregation processing library is used to store data aggregation processing methods.

In the above technical solution, the aggregation processing engine is also used to regularly traverse the sensor data aggregation processing methods in the sensor data aggregation processing library, and monitor the survival time of the aggregation processing method; when the survival time of the aggregation processing method is less than the third preset threshold, indicate Delete the resource of the sensor data aggregation processing method corresponding to the aggregation processing method lifetime;

The data aggregation processing library is also used to delete the resources of the sensor data aggregation processing method corresponding to the aggregation processing method survival time when the aggregation processing method survival time is less than the third preset threshold.

The embodiment of the present invention provides a processing method and device for dynamic expansion and contraction of sensor data, which manages sensor data according to sensor data headers, and realizes fast positioning of sensors through sensor structures; at the same time, deletes overtime sensors from the list according to sensor survival time, thereby Realize the reduction of invalid sensor data and improve the utilization rate of memory space.

Additional features and advantages of the invention will be set forth in the description which follows, and in part will be apparent from the description, or may be learned by practice of the invention. The objectives and other advantages of the invention may be realized and attained by the structure particularly pointed out in the written description and claims hereof as well as the appended drawings.

The technical solutions of the present invention will be described in further detail below with reference to the accompanying drawings and embodiments.

Description of drawings

The accompanying drawings are used to provide a further understanding of the present invention, and constitute a part of the description, and are used together with the embodiments of the present invention to explain the present invention, and do not constitute a limitation to the present invention. In the attached picture:

FIG. 1 is a flow chart of the first processing method for dynamic scaling of sensor data in an embodiment of the present invention;

FIG. 2 is a flow chart of the second processing method for dynamic scaling of sensor data in an embodiment of the present invention;

Fig. 3 is a structural diagram of the first processing device for dynamic expansion and contraction of sensor data in an embodiment of the present invention;

FIG. 4 is a structural diagram of a second processing device for dynamically scaling sensor data in an embodiment of the present invention;

FIG. 5 is a structural diagram of a third processing device for dynamic scaling of sensor data in an embodiment of the present invention.

detailed description

The specific embodiments of the present invention will be described in detail below in conjunction with the accompanying drawings, but it should be understood that the protection scope of the present invention is not limited by the specific embodiments.

Embodiment one

According to an embodiment of the present invention, a processing method for dynamic scaling of sensor data is provided. FIG. 1 is a flow chart of the processing method for dynamic scaling of sensor data, which specifically includes:

Step 101: Receive a sensor message, and extract a sensor ID according to the sensor message. The sensor message includes a sensor message header and sensor data.

The signal collected by the sensor node is transmitted back to the monitoring point in the form of datagram, and the content of the datagram is divided into two parts: the header and the data. The message header contains some communication-related control information, and what is really useful to users is the data part of the message. In this embodiment of the present invention, the sensor message includes a sensor message header and sensor data.

Wherein, the sensor message header includes the sensor ID, and also includes the start pointer of the sensor data array and the end pointer of the sensor data array.

Step 102: Determine the sensor structure corresponding to the sensor ID according to the mapping relationship between the sensor ID and the sensor structure. The sensor structure includes the sensor survival time and the sensor packet header pointer.

The sensor structure is used to store parameters related to the sensor, specifically including: sensor ID, sensor lifetime and sensor header pointer. The sensor lifetime is the criterion for realizing the dynamic expansion and scaling of the sensor cache, and its detailed processing method is detailed in the follow-up description; the sensor packet header pointer is used to quickly locate the sensor packet header, and then quickly find the sensor packet.

When there is no sensor structure corresponding to the sensor ID in the above mapping relationship between the sensor ID and the sensor structure, a new sensor structure is allocated for the sensor ID, and the sensor data header is updated, wherein the sensor data header includes the sensor ID and Mapping relationships between sensor structures. The mapping relationship between the sensor ID and the sensor data structure is used to quickly locate the sensor when receiving the sensor message.

Among them, the sensor data header is the entrance of the sensor and its data management, and also contains the total number of sensors and a list of sensor structure pointers, which are used to traverse all the sensors.

Step 103: Update the sensor survival time, and locate the sensor packet header according to the sensor packet header pointer. The sensor packet header includes a sensor data array start pointer and a sensor data array end pointer.

Step 104: According to the sensor header including the sensor data array start pointer and the sensor data array end pointer, store the sensor data in the sensor data linked list.

Wherein, the sensor data linked list is a list of sensor data queues for storing received sensor data.

Preferably, the method also includes steps A1-A3:

Step A1, traverse the sensor structure according to the total number of sensors and the list of sensor structure pointers, monitor the survival time of the sensors, the total number of sensors and the list of sensor structure pointers are stored in the sensor data header;

Step A2, when the sensor survival time is less than the first preset threshold, determine and delete the corresponding sensor header and sensor data according to the sensor header pointer in the sensor structure;

Step A3, release the resources of the sensor structure, and update the sensor data header.

Wherein, the first preset threshold is an artificially set value, generally set to 0 or 1. Taking the first preset threshold equal to 0 as an example, if the sensor time-to-live (TTL) is 0, retract the sensor header and sensor data resources according to the sensor header pointer, and then release itself That is, the resource of the sensor structure, and updates the sensor data header.

The embodiment of the present invention provides a processing method for dynamic expansion and contraction of sensor data, which manages sensor data according to the sensor data header, realizes fast positioning of sensors through the sensor structure; at the same time, deletes the overtime sensor from the list according to the sensor survival time, thereby realizing invalidation The reduction of sensor data improves the utilization of memory space.

Embodiment two

The embodiment of the present invention also provides another processing method for dynamic scaling of sensor data, as shown in FIG. 2 , the method specifically includes:

Step 201: Periodically traverse the sensor data linked list, and when it is determined that there is newly cached sensor data, search for the corresponding sensor data processing method in the sensor data processing library according to the sensor manufacturer type, sensor type and sensor version in the sensor data.

In the embodiment of the present invention, the sensor processing engine matches the corresponding sensor data processing library according to the sensor manufacturer type, sensor type and sensor version in the sensor message structure. If it cannot match, load the corresponding library file from the configuration library, and the sensor data processing method in this library file can be added online; if the corresponding sensor data processing method cannot be found in the file library, check whether there is a default processing function; if If it still cannot match, use the default library to process or mark the sensor as unrecognizable according to the configuration information of the sensor message.

Step 202: Process the newly cached sensor data according to the sensor data processing method, and update the processing method lifetime of the sensor data processing method.

Step 203: Periodically traverse the sensor data processing methods in the sensor data processing library, and monitor the survival time of the processing methods.

Step 204: When the lifetime of the processing method is less than the second preset threshold, delete the resource of the sensor data processing method corresponding to the lifetime of the processing method.

Wherein, the second preset threshold is an artificially set value, generally set to 0 or 1. Taking the second preset threshold equal to 0 as an example, if the lifetime of the processing method is 0, the resource of the sensor data processing method corresponding to the lifetime of the processing method is reclaimed and removed from the sensor data processing library.

Preferably, for complex sensor data, the method further includes an aggregation process, specifically including steps B1-B4:

Step B1, traversing each aggregation processing configuration instance in the configuration library, where the aggregation processing configuration instance includes a list of sensor IDs and an aggregation processing method ID;

Step B2, check whether the relevant sensor data of the relevant sensor is updated according to the relevant sensor ID list;

Step B3, when it is determined that the sensor data is updated, search for the corresponding data aggregation processing method in the data aggregation processing library according to the aggregation processing method ID;

Step B4: Process the relevant sensor data according to the sensor data aggregation processing method, and update the aggregation processing method survival time of the sensor data aggregation processing method.

Wherein, in step B3, if there is no corresponding data aggregation processing method, the data aggregation processing method is imported from the static file; if it still cannot be found, an alarm prompt is generated.

Preferably, the above-mentioned polymerization treatment method also includes steps C1-C2:

Step C1, periodically traversing the sensor data aggregation processing methods in the sensor data aggregation processing library, and monitoring the survival time of the aggregation processing methods;

Step C2, when the lifetime of the aggregation processing method is less than the third preset threshold, delete the resource of the sensor data aggregation processing method corresponding to the lifetime of the aggregation processing method.

Wherein, the third preset threshold is an artificially set value, generally set to 0 or 1. Taking the third preset threshold equal to 0 as an example, if the lifetime of the aggregation processing method is 0, the resource of the sensor data aggregation processing method corresponding to the lifetime of the aggregation processing method is reclaimed and removed from the sensor data aggregation processing library.

Preferably, in the second embodiment, the sensor data can be cached through the processing method of dynamic scaling of sensor data provided in the first embodiment. That is, the sensor data is stored through the method provided in Embodiment 1, and the sensor data is processed through the method provided in Embodiment 2.

The flow of the processing method for dynamic scaling of sensor data has been introduced in detail above, and this method can also be implemented by a device. The structure and functions of the device will be described in detail below.

An embodiment of the present invention provides a processing device for dynamic expansion and contraction of sensor data, as shown in FIG.

The data cache engine 301 is configured to receive the sensor message, and extract the sensor ID according to the sensor message, and the sensor message includes a sensor message header and sensor data;

Determine the sensor structure corresponding to the sensor ID according to the mapping relationship between the sensor ID in the sensor data header 302 and the sensor structure, the sensor structure includes the sensor survival time and the sensor header pointer;

Update the sensor survival time, and locate the sensor header according to the sensor header pointer, the sensor header includes the sensor data array start pointer and the sensor data array end pointer;

According to the sensor message header including the sensor data array start pointer and the sensor data array end pointer, the sensor data is stored in the sensor data linked list;

The sensor data head 302 is used to store the mapping relationship between the sensor ID and the sensor structure;

The sensor data linked list is used to store sensor data.

Preferably, the data cache engine 301 is also used to allocate a new sensor structure for the sensor ID when there is no sensor structure corresponding to the sensor ID in the mapping relationship between the sensor ID and the sensor structure;

The sensor data head 302 is also used to perform update operations.

Preferably, the data cache engine 301 is also used to traverse the sensor structure according to the total number of sensors and the sensor structure pointer list, and monitor the sensor survival time; when the sensor survival time is less than the first preset threshold, according to the sensor header pointer in the sensor structure Identify and instruct deletion of the corresponding sensor header and sensor data;

The resources of the sensor structure are released and the sensor data header 302 is updated.

The sensor data header 302 is also used to store the total number of sensors and the sensor structure pointer list, and when the sensor survival time is less than the first preset threshold, release the resources of the sensor structure and perform an update operation;

The sensor data linked list is also used to delete the corresponding sensor packet header and sensor data when the sensor survival time is less than the first preset threshold.

The embodiment of the present invention also provides another processing device for dynamic expansion and contraction of sensor data, as shown in FIG.

The data processing engine 401 is used to regularly traverse the sensor data linked list 402, and when it is determined that there is newly cached sensor data, search for corresponding sensor data in the sensor data processing library 403 according to the sensor manufacturer type, sensor type and sensor version in the sensor data processing method; process the newly cached sensor data according to the sensor data processing method, and update the processing method lifetime of the sensor data processing method;

The sensor data linked list 402 is used to store sensor data;

The sensor data processing library 403 is used to store sensor data processing methods.

Preferably, the data processing engine 401 is also used to regularly traverse the sensor data processing methods in the sensor data processing library 403, and monitor the survival time of the processing methods; resources for time-corresponding sensor data processing methods;

The sensor data processing library 403 is further configured to, when the lifetime of the processing method is less than a second preset threshold, delete the resource of the sensor data processing method corresponding to the lifetime of the processing method.

Preferably, as shown in FIG. 5 , the device further includes: an aggregation processing engine 404, a configuration library 405, and a data aggregation processing library 406;

The aggregation processing engine 404 is used to traverse each aggregation processing configuration instance in the configuration storehouse 405, the aggregation processing configuration instance includes a sensor ID list, an aggregation processing method ID; check whether the relevant sensor data of the relevant sensor is updated according to the relevant sensor ID list; When the sensor data is updated, search for the corresponding data aggregation processing method in the data aggregation processing library 406 according to the aggregation processing method ID; process the relevant sensor data according to the sensor data aggregation processing method, and update the aggregation processing method survival time of the sensor data aggregation processing method;

The configuration library 405 is used to store an aggregation processing configuration instance including a list of sensor IDs and an aggregation processing method ID;

The data aggregation processing library 406 is used to store data aggregation processing methods.

Preferably, the aggregation processing engine 404 is also used to periodically traverse the sensor data aggregation processing methods in the sensor data aggregation processing library 406, and monitor the survival time of the aggregation processing method; when the survival time of the aggregation processing method is less than the third preset threshold, instruct to delete A resource for the sensor data aggregation processing method corresponding to the aggregation processing method lifetime;

The data aggregation processing library 406 is further configured to delete the resources of the sensor data aggregation processing method corresponding to the aggregation processing method survival time when the aggregation processing method survival time is less than a third preset threshold.

The embodiment of the present invention provides a processing method and device for dynamic expansion and contraction of sensor data, which manages sensor data according to sensor data headers, and realizes fast positioning of sensors through sensor structures; at the same time, deletes overtime sensors from the list according to sensor survival time, thereby Realize the reduction of invalid sensor data and improve the utilization rate of memory space.

The present invention can have a variety of specific implementations in different forms. The technical solutions of the present invention are illustrated by taking Fig. 1-Fig. 5 as an example in conjunction with the accompanying drawings. In the specific process or embodiment structure, those of ordinary skill in the art should understand that the specific implementations provided above are only some examples of various preferred usages, and any implementation that embodies the claims of the present invention shall be included in the present invention. Within the scope of protection required by the technical solution.

Finally, it should be noted that: the above is only a preferred embodiment of the present invention, and is not intended to limit the present invention. Although the present invention has been described in detail with reference to the foregoing embodiments, for those skilled in the art, it still The technical solutions recorded in the foregoing embodiments may be modified, or some technical features thereof may be equivalently replaced. Any modifications, equivalent replacements, improvements, etc. made within the spirit and principles of the present invention shall be included within the protection scope of the present invention.

Claims (12)

1. A processing method for dynamic expansion and contraction of sensor data, characterized in that, comprising: receiving a sensor message, and extracting a sensor ID according to the sensor message, the sensor message including a sensor message header and sensor data; Determine the sensor structure corresponding to the sensor ID according to the mapping relationship between the sensor ID and the sensor structure in the sensor data header, the sensor structure includes a sensor survival time and a sensor header pointer; Update the sensor survival time, and locate the sensor header according to the sensor header pointer, the sensor header includes a sensor data array start pointer and a sensor data array end pointer; According to the sensor header including the sensor data array start pointer and the sensor data array end pointer, the sensor data is stored in the sensor data linked list; Also includes: Traverse the sensor structure according to the sensor total number and the sensor structure pointer list, and monitor the sensor survival time, and the sensor total number and the sensor structure pointer list are stored in the sensor data header; When the sensor survival time is less than the first preset threshold, determine and delete the corresponding sensor header and sensor data according to the sensor header pointer in the sensor structure; Release the resources of the sensor structure and update the sensor data header. 2. The method according to claim 1, wherein when there is no sensor structure corresponding to the sensor ID in the mapping relationship between the sensor ID and the sensor structure, assigning a new sensor ID to the sensor ID sensor structure, and update the sensor data header. 3. A processing method for dynamic scaling of sensor data, comprising: Timely traversing the sensor data linked list, when it is determined that there is newly cached sensor data, searching for a corresponding sensor data processing method in the sensor data processing library according to the sensor manufacturer type, sensor type and sensor version in the sensor data; Process the newly cached sensor data according to the sensor data processing method, and update the processing method lifetime of the sensor data processing method. 4. The method according to claim 3, further comprising: Periodically traverse the sensor data processing methods in the sensor data processing library, and monitor the survival time of the processing methods; When the lifetime of the processing method is less than the second preset threshold, the resource of the sensor data processing method corresponding to the lifetime of the processing method is deleted. 5. The method according to claim 3 or 4, further comprising: Traversing each aggregation processing configuration instance in the configuration library, the aggregation processing configuration instance includes a list of sensor IDs and an aggregation processing method ID; Check whether the relevant sensor data of the relevant sensor is updated according to the sensor ID list; When determining that the sensor data is updated, search for a corresponding data aggregation processing method in the data aggregation processing library according to the aggregation processing method ID; The associated sensor data is processed according to the sensor data aggregation processing method, and an aggregation processing method lifetime of the sensor data aggregation processing method is updated. 6. The method according to claim 5, further comprising: Periodically traverse the sensor data aggregation processing methods in the sensor data aggregation processing library, and monitor the survival time of the aggregation processing methods; When the survival time of the aggregation processing method is less than the third preset threshold, delete the resource of the sensor data aggregation processing method corresponding to the survival time of the aggregation processing method. 7. A processing device for dynamic expansion and contraction of sensor data, comprising: a data cache engine, a sensor data head and a sensor data linked list; The data cache engine is configured to receive a sensor message, and extract a sensor ID according to the sensor message, and the sensor message includes a sensor message header and sensor data; Determine the sensor structure corresponding to the sensor ID according to the mapping relationship between the sensor ID and the sensor structure in the sensor data header, the sensor structure includes a sensor survival time and a sensor header pointer; Update the sensor survival time, and locate the sensor header according to the sensor header pointer, the sensor header includes a sensor data array start pointer and a sensor data array end pointer; According to the sensor header including the sensor data array start pointer and the sensor data array end pointer, the sensor data is stored in the sensor data linked list; The sensor data head is used to store the mapping relationship between the sensor ID and the sensor structure; The sensor data linked list is used to store sensor data; The data cache engine is also used to traverse the sensor structure according to the total number of sensors and the sensor structure pointer list, and monitor the sensor survival time; when the sensor survival time is less than the first preset threshold, according to the sensor header pointer in the sensor structure Identify and instruct deletion of the corresponding sensor header and sensor data; release the resources of the sensor structure, and update the sensor data header; The sensor data header is also used to store the total number of sensors and a list of sensor structure pointers, and when the sensor survival time is less than a first preset threshold, release the resources of the sensor structure and perform an update operation; The sensor data linked list is also used for deleting the corresponding sensor packet header and sensor data when the sensor survival time is less than a first preset threshold. 8. The device according to claim 7, wherein the data cache engine is further configured to, when there is no sensor structure corresponding to the sensor ID in the mapping relationship between the sensor ID and the sensor structure , assigning a new sensor structure to the sensor ID; The sensor data header is also used to perform update operations. 9. A processing device for dynamically expanding and contracting sensor data, comprising: a data processing engine, a sensor data linked list and a sensor data processing library; The data processing engine is used to regularly traverse the sensor data linked list, and when it is determined that there is newly cached sensor data, search in the sensor data processing library according to the sensor manufacturer type, sensor type and sensor version in the sensor data The corresponding sensor data processing method; process the newly cached sensor data according to the sensor data processing method, and update the processing method survival time of the sensor data processing method; The sensor data linked list is used to store sensor data; The sensor data processing library is used to store sensor data processing methods. 10. The device according to claim 9, wherein the data processing engine is also used to periodically traverse the sensor data processing methods in the sensor data processing library, and monitor the survival time of the processing methods; when the processing method survival time When it is less than the second preset threshold, instruct to delete the resource of the sensor data processing method corresponding to the lifetime of the processing method; The sensor data processing library is further configured to, when the survival time of the processing method is less than a second preset threshold, delete the resource of the sensor data processing method corresponding to the survival time of the processing method. 11. The device according to claim 9 or 10, further comprising: an aggregation processing engine, a configuration library, and a data aggregation processing library; The aggregation processing engine is used to traverse each aggregation processing configuration instance in the configuration library, and the aggregation processing configuration instance includes a sensor ID list and an aggregation processing method ID; check related sensor data of related sensors according to the sensor ID list whether to update; when determining that the sensor data is updated, search for a corresponding data aggregation processing method in the data aggregation processing library according to the aggregation processing method ID; process the relevant sensor data according to the sensor data aggregation processing method, And update the aggregation processing method survival time of the sensor data aggregation processing method; The configuration library is used to store an aggregation processing configuration instance including a list of sensor IDs and an aggregation processing method ID; The data aggregation processing library is used to store data aggregation processing methods. 12. The device according to claim 11, wherein the aggregation processing engine is also used to periodically traverse the sensor data aggregation processing methods in the sensor data aggregation processing library, and monitor the survival time of the aggregation processing methods; When the processing method survival time is less than the third preset threshold, instruct to delete the resource of the sensor data aggregation processing method corresponding to the aggregation processing method survival time; The data aggregation processing library is further configured to, when the survival time of the aggregation processing method is less than a third preset threshold, delete the resource of the sensor data aggregation processing method corresponding to the survival time of the aggregation processing method.