CN115996228B - Energy data processing method and system based on Internet of things - Google Patents
Energy data processing method and system based on Internet of things Download PDFInfo
- Publication number
- CN115996228B CN115996228B CN202310281499.7A CN202310281499A CN115996228B CN 115996228 B CN115996228 B CN 115996228B CN 202310281499 A CN202310281499 A CN 202310281499A CN 115996228 B CN115996228 B CN 115996228B
- Authority
- CN
- China
- Prior art keywords
- processing
- energy data
- node
- nodes
- condition
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
- 238000003672 processing method Methods 0.000 title claims abstract description 9
- 238000000034 method Methods 0.000 claims abstract description 17
- 230000003247 decreasing effect Effects 0.000 claims description 6
- 230000006855 networking Effects 0.000 claims 1
- 239000002699 waste material Substances 0.000 abstract description 6
- 230000005540 biological transmission Effects 0.000 description 5
- VNWKTOKETHGBQD-UHFFFAOYSA-N methane Chemical compound C VNWKTOKETHGBQD-UHFFFAOYSA-N 0.000 description 4
- 238000012217 deletion Methods 0.000 description 3
- 230000037430 deletion Effects 0.000 description 3
- 238000001514 detection method Methods 0.000 description 3
- 230000009286 beneficial effect Effects 0.000 description 2
- 239000003245 coal Substances 0.000 description 2
- 239000010779 crude oil Substances 0.000 description 2
- 239000003345 natural gas Substances 0.000 description 2
- 238000006467 substitution reaction Methods 0.000 description 2
- 230000002159 abnormal effect Effects 0.000 description 1
- 230000005856 abnormality Effects 0.000 description 1
- 238000007792 addition Methods 0.000 description 1
- 238000006243 chemical reaction Methods 0.000 description 1
- 238000010586 diagram Methods 0.000 description 1
- 239000002360 explosive Substances 0.000 description 1
Images
Classifications
-
- Y—GENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
- Y02—TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
- Y02D—CLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
- Y02D10/00—Energy efficient computing, e.g. low power processors, power management or thermal management
Landscapes
- Management, Administration, Business Operations System, And Electronic Commerce (AREA)
- Power Sources (AREA)
Abstract
The application discloses a processing method and a processing system of energy data based on the Internet of things, wherein the processing method of the energy data based on the Internet of things specifically comprises the following steps: acquiring energy data; determining a processing node according to the acquired energy data; judging whether the number of the processing nodes needs to be changed or not; if the change is needed, carrying out change processing on the processing nodes, and carrying out energy data processing by using the changed processing nodes; if the change is not needed, the determined processing nodes are utilized to process the energy data. After the data are acquired, the data are selected to be proper nodes to perform data processing to further measure the number of the nodes, so that the data processing is performed by the nodes with the most proper number as much as possible, the resource waste is avoided, and the data processing can be performed safely and stably.
Description
Technical Field
The application relates to the field of data processing, in particular to an energy data processing method and system based on the Internet of things.
Background
Along with explosive growth of data, the flow of data processing in the internet of things is more and more complicated. At present, in the processing process, the detection of the abnormality of the data and the detection of the transmission process of the data are included, and the detection modes can be performed by using the virtual nodes, but when the data are processed by using the virtual nodes, whether the virtual nodes are suitable for the data processing is not considered, so that hidden danger exists in the selection of the virtual nodes, and the hidden danger may cause abnormal reaction when the data are processed, so that the safety when the data are processed is greatly reduced.
Therefore, how to provide a processing method capable of ensuring the security of processing data is a problem that needs to be solved by those skilled in the art.
Disclosure of Invention
The application provides a processing method of energy data based on the Internet of things, which specifically comprises the following steps: acquiring energy data; determining a processing node according to the acquired energy data; judging whether the number of the processing nodes needs to be changed or not; if the change is needed, carrying out change processing on the processing nodes, and carrying out energy data processing by using the changed processing nodes; if the change is not needed, the determined processing nodes are utilized to process the energy data.
As above, the acquiring the energy data includes acquiring the energy data stored in the internet of things.
As above, wherein determining the processing node from the acquired energy data comprises: creating a plurality of virtual nodes to form a virtual node set; judging the data size of the acquired energy data in response to the completion of the creation of the plurality of virtual node sets; and if the data quantity of the energy data is larger than the specified threshold value, selecting a virtual node meeting the first condition from the virtual node set as a processing node.
As above, wherein determining the processing node from the acquired energy data further comprises: and if the data quantity of the energy data is smaller than the specified threshold value, selecting a virtual node meeting the second condition from the virtual node set as a processing node.
As above, the performing the change processing on the processing node includes increasing or decreasing the processing node.
An energy data processing system based on the internet of things specifically comprises: the device comprises an acquisition unit, a processing node determination unit, a fluctuation judgment unit and a fluctuation processing unit; the acquisition unit is used for acquiring the energy data; the processing node determining unit is used for determining a processing node according to the acquired energy data; the change processing unit is used for judging whether the number of the processing nodes needs to be changed or not; if the change is needed, the change processing unit carries out change processing on the processing nodes, and the energy data processing is carried out by using the processing nodes after the change processing.
As described above, the acquiring the energy data includes acquiring the energy data stored in the internet of things.
As described above, wherein the processing node determining unit determines the processing node from the acquired energy data includes: creating a plurality of virtual nodes to form a virtual node set; judging the data size of the acquired energy data in response to the completion of the creation of the plurality of virtual node sets; and if the data quantity of the energy data is larger than the specified threshold value, selecting a virtual node meeting the first condition from the virtual node set as a processing node.
As described above, wherein the processing node determining unit determines the processing node according to the acquired energy data further includes: and if the data quantity of the energy data is smaller than the specified threshold value, selecting a virtual node meeting the second condition from the virtual node set as a processing node.
As described above, the change processing unit performs change processing on the processing node, including increasing or decreasing the processing node.
The application has the following beneficial effects:
after the data are acquired, the data are selected to be proper nodes to perform data processing to further measure the number of the nodes, so that the data processing is performed by the nodes with the most proper number as much as possible, the resource waste is avoided, and the data processing can be performed safely and stably.
Drawings
In order to more clearly illustrate the embodiments of the present application or the technical solutions in the prior art, the following description will briefly introduce the drawings that are required to be used in the embodiments or the description of the prior art, and it is obvious that the drawings in the following description are only some embodiments described in the present application, and other drawings may also be obtained according to these drawings for a person having ordinary skill in the art.
Fig. 1 is a flowchart of a method for processing energy data based on the internet of things according to an embodiment of the present application;
fig. 2 is an internal structure diagram of an energy data processing system based on the internet of things according to an embodiment of the present application.
Detailed Description
The following description of the embodiments of the present application, taken in conjunction with the accompanying drawings, clearly and completely describes the technical solutions of the embodiments of the present application, and it is apparent that the described embodiments are some embodiments of the present application, not all embodiments. All other embodiments, which can be made by those skilled in the art based on the embodiments herein without making any inventive effort, are intended to be within the scope of the present application.
According to the processing method and the processing system for the energy data based on the Internet of things, after the data are acquired, the data are selected to be suitable nodes to perform data processing to the greatest extent, the number of the nodes is further measured, the data processing is performed by the nodes with the most suitable number as far as possible, waste of resources is avoided, and meanwhile safe and stable data processing is guaranteed.
Example 1
As shown in fig. 1, the method for processing energy data based on the internet of things according to the embodiment of the present application specifically includes the following steps:
step S110: and obtaining energy data.
The energy data can comprise raw coal data, crude oil data, natural gas data, power consumption data and the like which are produced or used.
The energy data acquired in this embodiment may be the energy data acquired and stored in the internet of things, or may be the energy data input into the system in real time.
Step S120: and determining a processing node according to the acquired energy data.
The processing node is a virtual node, and the virtual node is a node capable of performing energy data processing, so that certain requirements are required on the virtual node, such as a speed of reading data from the node and a time of transmitting data from the node, and the requirements are combined with the energy data to select the processing node. Wherein step S120 specifically includes the following sub-steps:
step S1201: a plurality of virtual nodes are created to form a set of virtual nodes.
Wherein a plurality of virtual nodes are randomly created, the randomly created plurality of virtual nodes constituting a virtual node set. The manner in which virtual nodes are created may be referred to in the art and will not be described in detail herein.
Step S1202: in response to creating the plurality of virtual node sets, a size of a data amount of the acquired energy data is determined.
The data size of the energy data may be determined according to the existing method, if the data size of the energy data is greater than the specified threshold, step S1203 is executed, otherwise step S1204 is executed.
Step S1203: and selecting the virtual node meeting the first condition from the virtual node set as a processing node.
If the data size of the energy data is larger than the specified threshold, the corresponding requirement on the virtual nodes is higher, and the virtual nodes meeting the first condition are required to be selected from the virtual node set to serve as processing nodes.
The speed of reading data and the time of transmitting data by the node are taken as judging objects, and whether the speed and the time of transmitting data meet the first condition is judged.
Wherein determining whether the first condition is met is specifically expressed as:
wherein 
Representing the highest speed of the read data preset,/-, for>
Representing a preset minimum speed of read data that can be tolerated,/->
Representing the speed at which the data is read by the node in real time.
Representing the maximum time that can be tolerated by the preset transmission data,/->
Representing a preset minimum time for transmitting data, < >>
Time representing real-time transmission data of a node, +.>
Representing a specified speed threshold, +.>
Representing a specified time threshold, a speed threshold and a time thresholdThe specific values may be preset by a worker and are not limited herein.
If the first specified condition is satisfied, the processing node may execute step S130.
Step S1204: and selecting the virtual node meeting the second condition from the virtual node set as a processing node.
Wherein the second condition is met:
Wherein it is determined whether the node satisfaction in the virtual node set satisfies
Or (b)
When any equation is used, the processing node may execute step S130.
Step S130: it is determined whether the number of processing nodes needs to be changed.
If the number of the processing nodes is too large, a certain waste is caused, and if the number of the processing nodes is too small, the processing of the energy data is not timely, so that the number of the processing nodes needs to be further controlled. Step S130 specifically includes the following sub-steps:
step S1301: it is determined whether the number of processing nodes meeting the first condition needs to be changed.
The method comprises the steps of judging whether the processing nodes meeting the first condition need to be changed or not, specifically, judging whether the processing time of processing the energy data is larger than a second specified threshold and smaller than a first specified threshold by taking the processing nodes meeting the first condition as a whole, if so, indicating that the current processing nodes do not need to be changed, if so, the processing time is too long, the number of the current processing nodes is insufficient, and if so, the processing time is too fast, and the number of the current processing nodes is too large.
Wherein the processing time of the processing node is in accordance with the first condition
The concrete steps are as follows:
wherein ,
representing the time required for the ith processing node conforming to the first condition to receive the energy data, K representing the number of processing nodes conforming to the first condition, f representing the maximum node bandwidth among the processing nodes conforming to the first condition, j representing the minimum node bandwidth among the processing nodes conforming to the first condition,/->
And representing the number of connected edges obtained after connecting the processing nodes meeting the first condition.
The first designated time and the second designated time are both preset values, the value of the first designated time is larger than the value of the second designated time, and the specific value is not limited herein.
If it is
If the number of the current processing nodes is not enough, the step S140 is executed, if yes>
If the number of the current processing nodes is smaller than the second designated time, the processing time is too fast, which means that the number of the current processing nodes is too large, and step S140 is executed.
Step S1302: it is determined whether the number of processing nodes meeting the second condition needs to be changed.
The same idea as that of step S1301 is that determining whether the processing node meeting the second condition needs to be changed is specifically that the processing node meeting the second condition is taken as a whole, determining whether the processing time of processing the energy data is greater than a fourth specified threshold and smaller than a third specified threshold, if the processing time is greater than the fourth specified time and smaller than the third specified time, indicating that the current processing node does not need to be changed, if the processing time is greater than the third specified time, the processing time is too long, the number of the current processing nodes is insufficient, and if the processing time is less than the fourth specified time, the processing time is too fast, indicating that the number of the current processing nodes is too large.
Wherein the processing time of the processing node is in accordance with the first condition
The concrete steps are as follows:
wherein ,
represents the time required for the ith processing node meeting the first condition to receive the energy data, U represents the number of processing nodes meeting the first condition, +.>
Representing the maximum node bandwidth in the processing nodes meeting the first condition +.>
Representing the minimum node bandwidth in the processing nodes meeting the first condition,
And representing the number of connected edges obtained after connecting the processing nodes meeting the first condition.
The third designated time and the fourth designated time are both values set in advance, the value of the third designated time is larger than the value of the fourth designated time, and the specific value is not limited herein.
If it is
If the processing time is longer than the third specified time, the current processing node is insufficient, step S140 is executed, if yes>
If the processing time is less than the fourth designated time, the processing time is too fast, which means that the number of the current processing nodes is too large, and step S140 is executed.
Step S140: and carrying out change processing on the processing nodes, and carrying out energy data processing by using the changed processing nodes.
Specifically, if the processing time of the processing node meets the first condition
If the processing time is longer than the first specified time, the processing nodes meeting the first condition are subjected to node increasing change processing, and if the processing time of the processing nodes meeting the first condition is +.>
And if the node is smaller than the second designated time, performing node fluctuation reduction processing on the processing nodes meeting the first condition. />
If the processing time of the processing node meets the second condition
If the processing time is longer than the third designated time, the processing node meeting the second condition is subjected to node increasing change processing, and if the processing time of the processing node meeting the second condition is +.>
And if the time is smaller than the fourth designated time, performing node fluctuation reduction processing on the processing nodes meeting the second condition.
The change processing of the added nodes is specifically that any virtual node except the processing node is selected from the virtual node set, and the virtual node is directly used as the processing node.
By selecting the processing nodes from the virtual node set again, the nodes do not need to be created again, so that resources are saved and response time is shortened.
The node change reducing process is to randomly select nodes from the processing nodes conforming to the first condition or the processing nodes conforming to the second condition for deletion.
Wherein after increasing or decreasing the processing nodes meeting the first condition and/or the processing nodes meeting the second condition, the processing time is determined again
and
Until treatment time +.>
More than the second specified time less than the first specified time, or the processing time +.>
And the time greater than the fourth specified time is less than the third specified time.
After finishing the node change processing, the energy data processing is performed by using the node after the change processing. For example, energy data is stored in each processing node, or energy data is read out from each virtual node.
Example two
As shown in fig. 2, the system for processing energy data based on the internet of things according to the embodiment of the present application specifically includes: acquisition unit 210, processing node determination unit 220, fluctuation determination unit 230, and fluctuation processing unit 240.
Wherein the acquisition unit 210 is used for acquiring energy data.
The energy data can comprise raw coal data, crude oil data, natural gas data, power consumption data and the like which are produced or used.
The energy data acquired in this embodiment may be the acquired energy data stored in the internet of things, or may be the energy data of the real-time input system.
The processing node determining unit 220 is configured to determine a processing node according to the acquired energy data.
The processing node is a virtual node, and the virtual node is a node capable of performing energy data processing, so that certain requirements are required on the virtual node, such as a speed of reading data from the node and a time of transmitting data from the node, and the requirements are combined with the energy data to select the processing node. Wherein the following sub-steps are specifically performed:
a plurality of virtual nodes are created to form a set of virtual nodes.
Wherein a plurality of virtual nodes are randomly created, the randomly created plurality of virtual nodes constituting a virtual node set.
In response to creating the plurality of virtual node sets, a size of a data amount of the acquired energy data is determined.
And if the data quantity of the energy data is larger than the specified threshold value, selecting a virtual node meeting the first condition from the virtual node set as a processing node. Otherwise, selecting the virtual node meeting the second condition from the virtual node set as a processing node.
If the data size of the energy data is larger than the specified threshold, the corresponding requirement on the virtual nodes is higher, and the virtual nodes meeting the first condition are required to be selected from the virtual node set to serve as processing nodes.
The speed of reading data and the time of transmitting data by the node are taken as judging objects, and whether the speed and the time of transmitting data meet the first condition is judged.
Wherein determining whether the first condition is met is specifically expressed as:
wherein 
Representing the highest speed of the read data preset,/-, for>
Representing a preset minimum speed of read data that can be tolerated,/->
Representing the speed at which the data is read by the node in real time.
Representing the maximum time that can be tolerated by the preset transmission data,/->
Representing a preset minimum time for transmitting data, < >>
Time representing real-time transmission data of a node, +.>
The designated speed threshold is indicated, the designated time threshold is indicated, and the speed threshold and the time threshold can be preset by a worker, and specific values are not limited herein.
And judging whether the nodes in the virtual node set meet the first specified condition, and if so, using the nodes as processing nodes.
Wherein the second condition is met:
Wherein it is determined whether the node satisfaction in the virtual node set satisfies
Or (b)
Any term formula can be used as a processing node.
The change processing unit 230 is configured to determine whether the number of processing nodes needs to be changed.
If the number of the processing nodes is too large, a certain waste is caused, and if the number of the processing nodes is too small, the processing of the energy data is not timely, so that the number of the processing nodes needs to be further controlled. The method specifically comprises the following substeps:
it is determined whether the number of processing nodes meeting the first condition needs to be changed.
It is determined whether the number of processing nodes meeting the second condition needs to be changed.
The method comprises the steps of judging whether the processing nodes meeting the first condition need to be changed or not, specifically, judging whether the processing time of processing the energy data is larger than a second specified threshold and smaller than a first specified threshold by taking the processing nodes meeting the first condition as a whole, and if the processing time is larger than the second specified threshold and smaller than the first specified time, indicating that the current processing nodes do not need to be changed, and directly processing the energy data by using the determined processing nodes. If the processing time is longer than the first designated time, the number of the current processing nodes is insufficient, and if the processing time is shorter than the second designated time, the processing time is too fast, which indicates that the number of the current processing nodes is too large.
Wherein the processing time of the processing node is in accordance with the first condition
The concrete steps are as follows:
wherein ,
representing the time required for the ith processing node conforming to the first condition to receive the energy data, K representing the number of processing nodes conforming to the first condition, f representing the maximum node bandwidth among the processing nodes conforming to the first condition, j representing the minimum node bandwidth among the processing nodes conforming to the first condition,/->
And representing the number of connected edges obtained after connecting the processing nodes meeting the first condition.
The first designated time and the second designated time are both preset values, the value of the first designated time is larger than the value of the second designated time, and the specific value is not limited herein.
If it is
If the processing time is longer than the first specified time, the processing time is too long, and if the number of the current processing nodes is insufficient, the change processing unit 240 performs change processing on the processing nodes, and performs energy data processing by using the changed processing nodes. If->
And if the processing time is smaller than the second designated time, the processing time is too fast, and the current processing nodes are too large in number, the processing nodes are subjected to change processing, and the energy data processing is performed by the changed processing nodes. />
And judging whether the processing nodes meeting the second condition need to be changed or not, wherein the processing nodes meeting the second condition are taken as a whole, judging whether the processing time of the processed energy data is larger than a fourth specified threshold and smaller than a third specified threshold, if the processing time is larger than the fourth specified threshold and smaller than the third specified time, indicating that the current processing node does not need to be changed, and directly utilizing the determined processing nodes to process the data. If the processing time is longer than the third appointed time, the number of the current processing nodes is insufficient, and if the processing time is shorter than the fourth appointed time, the processing time is too fast, which indicates that the number of the current processing nodes is too large.
Wherein the processing time of the processing node is in accordance with the first condition
The concrete steps are as follows:
wherein ,
represents the time required for the ith processing node meeting the first condition to receive the energy data, U represents the number of processing nodes meeting the first condition, +.>
Representing the maximum node bandwidth in the processing nodes meeting the first condition +.>
Representing the minimum node bandwidth in the processing nodes meeting the first condition,
And representing the number of connected edges obtained after connecting the processing nodes meeting the first condition.
The third designated time and the fourth designated time are both values set in advance, the value of the third designated time is larger than the value of the fourth designated time, and the specific value is not limited herein.
If it is
If the processing time is longer than the third appointed time, the processing time is too long, and if the number of the current processing nodes is insufficient, the processing nodes are subjected to change processing, and the energy data processing is performed by the processing nodes after the change processing. If->
If the processing time is shorter than the fourth designated time, the processing time is too short, which means that the number of current processing nodes is too large, and the fluctuation processing unit 240 performs fluctuation processing on the processing nodes, and performs energy data processing by using the processing nodes after the fluctuation processing.
Specifically, the fluctuation processing unit 240 performs the fluctuation processing on the processing node, and performs the energy data processing by using the processing node after the fluctuation processing, including, if the processing time of the processing node meets the first condition
Greater thanThe first appointed time is to increase the node change of the processing node which accords with the first condition, if the processing time of the processing node which accords with the first condition is +.>
And if the node is smaller than the second designated time, performing node fluctuation reduction processing on the processing nodes meeting the first condition.
If the processing time of the processing node meets the second condition
If the processing time is longer than the third designated time, the processing node meeting the second condition is subjected to node increasing change processing, and if the processing time of the processing node meeting the second condition is +.>
And if the time is smaller than the fourth designated time, performing node fluctuation reduction processing on the processing nodes meeting the second condition.
The change processing of the added nodes is specifically that any virtual node except the processing node is selected from the virtual node set, and the virtual node is directly used as the processing node.
The node change reducing process is to randomly select nodes from the processing nodes conforming to the first condition or the processing nodes conforming to the second condition for deletion.
Wherein after increasing or decreasing the processing nodes meeting the first condition and/or the processing nodes meeting the second condition, the processing time is determined again
and
Until treatment time +.>
More than the second specified time less than the first specified time, or the processing time +.>
And the time greater than the fourth specified time is less than the third specified time.
After finishing the node change processing, the energy data processing is performed by using the node after the change processing. For example, energy data is stored in each processing node, or energy data is read out from each virtual node.
The application has the following beneficial effects:
after the data are acquired, the data are selected to be proper nodes to perform data processing to further measure the number of the nodes, so that the data processing is performed by the nodes with the most proper number as much as possible, the resource waste is avoided, and the data processing can be performed safely and stably.
Although the examples referred to in the present application are described for illustrative purposes only and not as limitations on the present application, variations, additions and/or deletions to the embodiments may be made without departing from the scope of the application.
The foregoing is merely specific embodiments of the present application, but the scope of the present application is not limited thereto, and any person skilled in the art can easily think about changes or substitutions within the technical scope of the present application, and the changes and substitutions are intended to be covered by the scope of the present application. Therefore, the protection scope of the present application shall be subject to the protection scope of the claims.
Claims (10)
1. The energy data processing method based on the Internet of things is characterized by comprising the following steps of:
acquiring energy data;
determining a processing node according to the acquired energy data;
judging whether the number of the processing nodes needs to be changed or not;
if the change is needed, carrying out change processing on the processing nodes, and carrying out energy data processing by using the changed processing nodes;
if the change is not needed, the determined processing nodes are utilized to process the energy data;
judging whether the number of the processing nodes needs to be changed or not includes judging whether the number of the processing nodes meeting the first condition needs to be changed or not;
processing time of processing node meeting first condition
The concrete steps are as follows:
wherein ,
representing the time required for the ith processing node conforming to the first condition to receive the energy data, K representing the number of processing nodes conforming to the first condition, f representing the maximum node bandwidth among the processing nodes conforming to the first condition, j representing the minimum node bandwidth among the processing nodes conforming to the first condition,/->
Representing the number of connected edges obtained after connecting the processing nodes meeting the first condition;
if it is
If the processing time is longer than the first appointed time, the processing time is too long, and if the number of the current processing nodes is insufficient, the processing nodes are subjected to change processing, and the energy data processing is performed by the processing nodes after the change processing.
2. The method for processing energy data based on the internet of things according to claim 1, wherein the acquiring energy data includes acquiring energy data stored in the internet of things.
3. The method for processing energy data based on the internet of things according to claim 1, wherein determining the processing node according to the acquired energy data comprises:
creating a plurality of virtual nodes to form a virtual node set;
judging the data size of the acquired energy data in response to the completion of the creation of the plurality of virtual node sets;
and if the data quantity of the energy data is larger than the specified threshold value, selecting a virtual node meeting the first condition from the virtual node set as a processing node.
4. The method for processing energy data based on the internet of things according to claim 1, wherein determining the processing node according to the acquired energy data further comprises:
and if the data quantity of the energy data is smaller than the specified threshold value, selecting a virtual node meeting the second condition from the virtual node set as a processing node.
5. The method for processing energy data based on the internet of things according to claim 1, wherein the varying processing of the processing nodes includes increasing or decreasing the processing nodes.
6. The utility model provides a processing system of energy data based on thing networking which characterized in that specifically includes: the device comprises an acquisition unit, a processing node determination unit, a fluctuation judgment unit and a fluctuation processing unit;
the acquisition unit is used for acquiring the energy data;
the processing node determining unit is used for determining a processing node according to the acquired energy data;
the change processing unit is used for judging whether the number of the processing nodes needs to be changed or not;
if the change is needed, the change processing unit carries out change processing on the processing nodes, and the energy data processing is carried out by using the processing nodes after the change processing;
the change processing unit judging whether the number of the processing nodes needs to be changed or not includes judging whether the number of the processing nodes meeting a first condition needs to be changed or not;
processing time of processing node meeting first condition
The concrete steps are as follows:
wherein ,
representing the time required for the ith processing node conforming to the first condition to receive the energy data, K representing the number of processing nodes conforming to the first condition, f representing the maximum node bandwidth among the processing nodes conforming to the first condition, j representing the minimum node bandwidth among the processing nodes conforming to the first condition,/->
Representing the number of connected edges obtained after connecting the processing nodes meeting the first condition;
if it is
If the processing time is longer than the first appointed time, the processing time is too long, and if the number of the current processing nodes is insufficient, the processing nodes are subjected to change processing, and the energy data processing is performed by the processing nodes after the change processing.
7. The system for processing energy data based on the internet of things according to claim 6, wherein the acquiring the energy data acquired by the acquiring unit includes acquiring the energy data stored in the internet of things.
8. The system according to claim 7, wherein the processing node determining unit determines the processing node based on the acquired energy data, comprising:
creating a plurality of virtual nodes to form a virtual node set;
judging the data size of the acquired energy data in response to the completion of the creation of the plurality of virtual node sets;
and if the data quantity of the energy data is larger than the specified threshold value, selecting a virtual node meeting the first condition from the virtual node set as a processing node.
9. The system for processing energy data based on the internet of things according to claim 8, wherein the processing node determining unit determines the processing node according to the acquired energy data further comprises:
and if the data quantity of the energy data is smaller than the specified threshold value, selecting a virtual node meeting the second condition from the virtual node set as a processing node.
10. The system for processing energy data based on the internet of things according to claim 6, wherein the change processing unit performs change processing on the processing nodes, including increasing or decreasing the processing nodes.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202310281499.7A CN115996228B (en) | 2023-03-22 | 2023-03-22 | Energy data processing method and system based on Internet of things |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202310281499.7A CN115996228B (en) | 2023-03-22 | 2023-03-22 | Energy data processing method and system based on Internet of things |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN115996228A CN115996228A (en) | 2023-04-21 |
| CN115996228B true CN115996228B (en) | 2023-05-30 |
Family
ID=85993733
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202310281499.7A Active CN115996228B (en) | 2023-03-22 | 2023-03-22 | Energy data processing method and system based on Internet of things |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN115996228B (en) |
Citations (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114969154A (en) * | 2022-05-23 | 2022-08-30 | 阳泉市郊区温河灌区管理站 | Water quality data processing method and system |
Family Cites Families (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN107729147B (en) * | 2014-03-06 | 2021-09-21 | 华为技术有限公司 | Data processing method in stream computing system, control node and stream computing system |
| CN107038059A (en) * | 2016-02-03 | 2017-08-11 | 阿里巴巴集团控股有限公司 | virtual machine deployment method and device |
| US10382284B1 (en) * | 2018-03-02 | 2019-08-13 | SILVAIR Sp. z o.o. | System and method for commissioning mesh network-capable devices within a building automation and control system |
| CN109086131A (en) * | 2018-06-25 | 2018-12-25 | 郑州云海信息技术有限公司 | A kind of virtual machine elastic telescopic control method and control device |
| WO2022028149A1 (en) * | 2020-08-03 | 2022-02-10 | 华为技术有限公司 | Method and system for binding multiple physical devices as virtual device, and related device |
| CN114666334B (en) * | 2022-04-28 | 2024-01-26 | 深圳嘉业共创供应链管理有限公司 | Node management method and system |
-
2023
- 2023-03-22 CN CN202310281499.7A patent/CN115996228B/en active Active
Patent Citations (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN114969154A (en) * | 2022-05-23 | 2022-08-30 | 阳泉市郊区温河灌区管理站 | Water quality data processing method and system |
Also Published As
| Publication number | Publication date |
|---|---|
| CN115996228A (en) | 2023-04-21 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN107039977A (en) | With the uncertain collection construction method of the power system Robust Scheduling of the minimum target of integrated cost | |
| CN103347009A (en) | Method and device filtering information | |
| CN103617226A (en) | Regular expression matching method and device | |
| CN104682447A (en) | Power system economic dispatching method containing multiple wind power plants | |
| CN115529315B (en) | Cloud edge cooperative system | |
| CN115996228B (en) | Energy data processing method and system based on Internet of things | |
| CN104731651B (en) | The power automation task scheduling and method of trigger mechanism, system and processor | |
| CN107193782A (en) | A kind of method of abnormal value removing and correction fitted based on multinomial | |
| CN113221422A (en) | Fluid simulation method based on nonlinear fluid data information processing technology | |
| CN104680017A (en) | Stability analysis system and method of time-varying power system | |
| CN116931438B (en) | Method, device, equipment and medium for determining parameters of speed regulator of water turbine | |
| CN112614002A (en) | Data acquisition system, method, device, electronic equipment and computer storage medium | |
| CN117786500A (en) | Method, device, equipment and storage medium for predicting earth surface subsidence in shield construction | |
| Li et al. | Fuzzy goal programming with multiple priorities via generalized varying-domain optimization method | |
| CN111736076A (en) | Battery system state judgment method and device, readable storage medium and electronic equipment | |
| CN108563894B (en) | Graphic file processing method, device, equipment and storage medium | |
| CN116028930A (en) | Defense detection method and system for energy data in Internet of things | |
| Salama et al. | Multi-objective approach with a distance metric in genetic programming for job shop scheduling | |
| Kajornrit | A comparative study of optimization methods for improving artificial neural network performance | |
| Groumpos et al. | An overview of fuzzy cognitive maps for energy efficiency in intelligent buildings | |
| CN114462625A (en) | Decision tree generation method and device, electronic equipment and program product | |
| Martins et al. | Hercules: A context-aware multiple application and multisensor data fusion algorithm | |
| Benguigui et al. | Scaling and urban growth | |
| CN104023337A (en) | Dynamically adjusted trust value calculation method based on Beta credit system | |
| Wu et al. | An estimation of distribution algorithm to optimize the utility of task scheduling under fog computing systems |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |