CN111800503B - Internet of things communication data topology method and system for reducing data acquisition terminals - Google Patents
Internet of things communication data topology method and system for reducing data acquisition terminals Download PDFInfo
- Publication number
- CN111800503B CN111800503B CN202010635240.4A CN202010635240A CN111800503B CN 111800503 B CN111800503 B CN 111800503B CN 202010635240 A CN202010635240 A CN 202010635240A CN 111800503 B CN111800503 B CN 111800503B
- Authority
- CN
- China
- Prior art keywords
- data
- change rate
- data acquisition
- real
- interval
- 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
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/12—Protocols specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/12—Discovery or management of network topologies
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Health & Medical Sciences (AREA)
- Computing Systems (AREA)
- General Health & Medical Sciences (AREA)
- Medical Informatics (AREA)
- Telephonic Communication Services (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The invention discloses a method and a system for reducing communication data topology of an internet of things of a data acquisition terminal, wherein the method comprises the following steps: acquiring real-time data acquired by the data acquisition terminal; determining the current change rate of the real-time data acquired by the data acquisition terminal; determining the acquisition frequency of the data acquisition terminal corresponding to the current change rate according to the current change rate; determining a new round of change rate of the real-time data acquired by the data acquisition terminal at a next data acquisition node; when the new round of change rate exceeds a preset interval, increasing the data acquisition frequency of the data acquisition terminal according to the new round of change rate; and when the new round of change rate is lower than a preset interval, the data acquisition frequency of the data acquisition terminal is adjusted to be low according to the new round of change rate. The invention aims to solve the problem that the quantity of data acquisition terminals in the existing Internet of things technology is wasted.
Description
Technical Field
The invention relates to the technical field of Internet of things, in particular to an Internet of things communication data topology method for reducing data acquisition terminals and an Internet of things communication data topology system.
Background
In the communication process of the internet of things, a large number of data acquisition terminals are required to be arranged to acquire data, and the acquired data are sent to the cloud for data processing. Because the acquisition frequency of the existing data acquisition terminal is fixed frequency, in order to adapt to the increase of the acquisition frequency of a user in certain time periods, some standby data acquisition terminals need to be additionally arranged in the existing internet of things technology so as to adapt to the adjustment of the acquisition frequency. Therefore, the prior art has the defect that the number of data acquisition terminals is wasted.
Disclosure of Invention
The invention mainly aims to provide an Internet of things communication data topology method for reducing data acquisition terminals, and aims to solve the problem that the quantity of the data acquisition terminals in the existing Internet of things technology is wasted.
In order to achieve the purpose, the internet of things communication data topology method for reducing the number of data acquisition terminals is applied to an internet of things communication data topology system, wherein the internet of things communication data topology system comprises a cloud server and the data acquisition terminals in communication connection with the cloud server; the method for reducing the communication data topology of the Internet of things of the data acquisition terminal comprises the following steps:
acquiring real-time data acquired by the data acquisition terminal;
determining the current change rate of the real-time data acquired by the data acquisition terminal;
determining the acquisition frequency of the data acquisition terminal corresponding to the current change rate according to the current change rate;
determining a new round of change rate of real-time data acquired by the data acquisition terminal at a next data acquisition node;
when the new round of change rate exceeds a preset interval, increasing the data acquisition frequency of the data acquisition terminal according to the new round of change rate;
and when the new round of change rate is lower than a preset interval, the data acquisition frequency of the data acquisition terminal is adjusted to be low according to the new round of change rate.
Preferably, the step of determining the acquisition frequency of the data acquisition terminal corresponding to the current change rate according to the current change rate includes:
acquiring a plurality of change rate intervals preset for the data acquisition terminal;
acquiring an acquisition frequency interval corresponding to each change rate interval;
determining a current change rate interval corresponding to the current change rate;
and determining the acquisition frequency of the data acquisition terminal as the minimum acquisition frequency of the current acquisition frequency interval according to the current acquisition frequency interval corresponding to the current change rate interval.
Preferably, when the new round of change rate exceeds a preset interval, the step of increasing the data acquisition frequency of the data acquisition terminal according to the new round of change rate includes:
when the new round of change rate exceeds a preset interval, acquiring a new round of change rate interval corresponding to the new round of change rate;
judging whether the new round of change rate interval is the current change rate interval or not;
if not, determining the acquisition frequency of the data acquisition terminal as the minimum acquisition frequency of the new acquisition frequency interval according to the new acquisition frequency interval corresponding to the new change rate interval;
if so, increasing the minimum acquisition frequency of the current acquisition frequency interval by a preset amplification to obtain a corrected acquisition frequency, and determining the acquisition frequency of the data acquisition terminal as the corrected acquisition frequency.
Preferably, when the new round of change rate is lower than a preset interval, the step of reducing the data acquisition frequency of the data acquisition terminal according to the new round of change rate includes:
when the new round of change rate is lower than a preset interval, acquiring a new round of change rate interval corresponding to the new round of change rate;
judging whether the new round of change rate interval is the current change rate interval or not;
if not, determining the acquisition frequency of the data acquisition terminal as the minimum acquisition frequency of the new acquisition frequency interval according to the new acquisition frequency interval corresponding to the new change rate interval;
if so, reducing the minimum acquisition frequency of the current acquisition frequency interval by a preset reduction amplitude to obtain a corrected acquisition frequency, and determining the acquisition frequency of the data acquisition terminal as the corrected acquisition frequency.
Preferably, the number of the data acquisition terminals is at least two, and the method for reducing the communication data topology of the internet of things of the data acquisition terminals further comprises the following steps:
acquiring preset acquisition frequency of each data acquisition terminal;
according to the preset acquisition frequency of each data acquisition terminal, each data acquisition terminal is marked hierarchically;
acquiring the physical position of each data acquisition terminal;
according to the physical position of each data acquisition terminal, carrying out partition marking on each data acquisition terminal;
acquiring each real-time data acquired by the data acquisition terminal in the current data processing period, and determining the processing sequence of each real-time data according to the layering mark and the partition mark of the data acquisition terminal corresponding to each real-time data;
and marking the real-time data by adopting the processing sequence, and performing data processing on each real-time data at the cloud server according to the processing sequence.
Preferably, the step of hierarchically marking each data acquisition terminal according to an acquisition frequency preset by each data acquisition terminal includes:
acquiring a plurality of preset acquisition frequency intervals, wherein the interval ranges of the acquisition frequency intervals are not overlapped;
respectively corresponding the preset acquisition frequency of each data acquisition terminal to a unique acquisition frequency interval;
and determining the hierarchy of each data acquisition terminal according to the corresponding result of the acquisition frequency interval.
Preferably, the step of marking each data acquisition terminal in a partitioned manner according to the physical location of each data acquisition terminal includes:
acquiring each preset physical area;
respectively corresponding the physical positions of the data acquisition terminals to a unique physical area;
and determining the area of each data acquisition terminal according to the corresponding result of the physical area.
Preferably, the step of acquiring each piece of real-time data acquired by the data acquisition terminal within the current data processing period, and determining a processing sequence of each piece of real-time data according to the hierarchical flag and the partition flag of the data acquisition terminal corresponding to each piece of real-time data includes:
acquiring each real-time data acquired by the data acquisition terminal within the current data processing period;
determining a first processing sequence coefficient corresponding to each real-time data according to the hierarchical mark of the data acquisition terminal corresponding to each real-time data;
determining a second processing sequence coefficient corresponding to each real-time data according to the partition mark of the data acquisition terminal corresponding to each real-time data;
determining a processing sequence value of each real-time data according to the first processing sequence coefficient and the second processing sequence coefficient;
and determining the processing sequence of each real-time data according to the processing sequence value of each real-time data.
Preferably, the step of marking the real-time data by using the processing sequence and performing data processing on each real-time data at the cloud server according to the processing sequence includes:
acquiring a processing sequence value of each piece of real-time data in a current data processing period;
acquiring a processing sequence value of each piece of real-time data in a next data processing time period;
sequencing the processing sequence values of the real-time data in the current data processing time interval and the next data processing time interval from big to small;
and according to the sequencing result, performing data processing on each piece of real-time data.
In order to achieve the above object, the present invention further provides an internet of things communication data topology system, which applies the internet of things communication data topology method for reducing data acquisition terminals as set forth in any one of the above aspects, and the internet of things communication data topology system includes a cloud server and data acquisition terminals in communication connection with the cloud server.
According to the technical scheme, after the real-time data of the data acquisition terminal are acquired, the current change rate of the real-time data acquired by the data acquisition terminal is further determined, and the acquisition frequency of the data acquisition terminal corresponding to the current change rate is determined according to the current change rate. Specifically, if the current change rate exceeds a preset interval, it indicates that the current real-time data is in a transient state (a significant abnormal state), and if the change rate is continuously maintained at a high level, an equipment failure or a danger is likely to be caused, and in such a case, the acquisition frequency needs to be increased to closely observe the change condition of the real-time data; if the current change rate is smaller than the preset interval, the current real-time data is in a relatively stable state, and the equipment is in a stable state, so that the acquisition frequency can be reduced under the condition, and the energy consumption of the data acquisition terminal is reduced; if the current change rate is in a preset interval, it indicates that the current real-time data is in a certain fluctuation state, but does not reach a significant abnormal state, and the change condition of the acquired real-time data needs to be continuously concerned in the current state, the current acquisition frequency needs to be maintained in the condition. According to the technical scheme, the data acquisition frequency is dynamically adjusted according to the change rate of the real-time data, so that the technical scheme provided by the invention is beneficial to acquiring more acquired data or acquiring less acquired data by using the existing data acquisition terminals under the condition of not changing the number of the data acquisition terminals, and the problem of waste of the number of the data acquisition terminals in the existing internet of things technology is solved.
Drawings
In order to more clearly illustrate the embodiments of the present invention or the technical solutions in the prior art, the drawings used in the description of the embodiments or the prior art will be briefly described below, it is obvious that the drawings in the following description are only some embodiments of the present invention, and for those skilled in the art, other drawings can be obtained according to the structures shown in the drawings without creative efforts.
FIG. 1 is a flowchart of a first embodiment of a method for reducing the topology of Internet of things communication data of a data acquisition terminal according to the present invention;
fig. 2 is a flowchart of a second embodiment of the topology method for reducing communication data of the internet of things of the data acquisition terminal according to the present invention.
The implementation, functional features and advantages of the present invention will be further described with reference to the accompanying drawings.
Detailed Description
The technical solutions in the embodiments of the present invention will be clearly and completely described below with reference to the drawings in the embodiments of the present invention, and it is obvious that the described embodiments are only a part of the embodiments of the present invention, and not all of the embodiments. All other embodiments, which can be obtained by a person skilled in the art without inventive step based on the embodiments of the present invention, are within the scope of protection of the present invention.
It should be noted that all directional indicators (such as up, down, left, right, front, back ...) in the embodiments of the present invention are only used to explain the relative positional relationship between the components, the motion situation, etc. in a specific posture (as shown in the attached drawings), and if the specific posture is changed, the directional indicator is changed accordingly.
In addition, the descriptions related to "first", "second", etc. in the present invention are only for descriptive purposes and are not to be construed as indicating or implying relative importance or implicitly indicating the number of technical features indicated. Thus, a feature defined as "first" or "second" may explicitly or implicitly include at least one such feature. In the description of the present invention, "a plurality" means at least two, e.g., two, three, etc., unless specifically limited otherwise.
In the present invention, unless otherwise expressly stated or limited, the terms "connected," "secured," and the like are to be construed broadly, and for example, "secured" may be a fixed connection, a removable connection, or an integral part; can be mechanically or electrically connected; they may be directly connected or indirectly connected through intervening media, or they may be connected internally or in any other suitable relationship, unless expressly stated otherwise. The specific meanings of the above terms in the present invention can be understood by those skilled in the art according to specific situations.
In addition, the technical solutions in the embodiments of the present invention may be combined with each other, but it must be based on the realization of the technical solutions by those skilled in the art, and when the technical solutions are contradictory to each other or cannot be realized, such a combination of the technical solutions should not be considered to exist, and is not within the protection scope of the present invention.
Referring to fig. 1, in order to achieve the above object, the internet of things communication data topology method for reducing data acquisition terminals provided by the invention is applied to an internet of things communication data topology system, wherein the internet of things communication data topology system comprises a cloud server and data acquisition terminals in communication connection with the cloud server; the method for reducing the communication data topology of the Internet of things of the data acquisition terminal comprises the following steps:
step S10, acquiring real-time data acquired by the data acquisition terminal;
step S20, determining the current change rate of the real-time data acquired by the data acquisition terminal;
step S30, determining the acquisition frequency of the data acquisition terminal corresponding to the current change rate according to the current change rate;
step S40, determining a new change rate of the real-time data acquired by the data acquisition terminal at the next data acquisition node;
s50, when the new round of change rate exceeds a preset interval, increasing the data acquisition frequency of the data acquisition terminal according to the new round of change rate;
and S60, when the new round of change rate is lower than a preset interval, reducing the data acquisition frequency of the data acquisition terminal according to the new round of change rate.
According to the technical scheme, after the real-time data of the data acquisition terminal are acquired, the current change rate of the real-time data acquired by the data acquisition terminal is further determined, and the acquisition frequency of the data acquisition terminal corresponding to the current change rate is determined according to the current change rate. Specifically, if the current change rate exceeds a preset interval, it indicates that the current real-time data is in a transient state (a significant abnormal state), and if the change rate is continuously maintained at a high level, an equipment failure or a danger is likely to be caused, and in such a case, the acquisition frequency needs to be increased to closely observe the change condition of the real-time data; if the current change rate is smaller than the preset interval, the current real-time data is in a relatively stable state, and the equipment is in a stable state, so that the acquisition frequency can be reduced, and the energy consumption of the data acquisition terminal can be reduced; if the current change rate is in a preset interval, it indicates that the current real-time data is in a certain fluctuation state, but does not reach a significant abnormal state, and the change condition of the acquired real-time data needs to be continuously concerned in the current state, the current acquisition frequency needs to be maintained in such a condition. According to the technical scheme, the data acquisition frequency is dynamically adjusted according to the change rate of the real-time data, so that the technical scheme provided by the invention is beneficial to acquiring more acquired data or acquiring less acquired data by using the existing data acquisition terminals under the condition of not changing the number of the data acquisition terminals, and the problem of waste of the number of the data acquisition terminals in the existing internet of things technology is solved.
The "next data collection node" in step S40 is determined according to the collection frequency determined in step S30. The initial acquisition frequency of the data acquisition terminal is a preset frequency. In step S60, the data acquisition frequency of the data acquisition terminal is reduced according to the new round of change rate, and the data acquisition frequency cannot be reduced again after the data acquisition frequency is reduced to the set minimum acquisition frequency.
Referring to fig. 2, based on the first embodiment of the method for reducing the communication data topology of the internet of things of the data acquisition terminal, in the second embodiment of the present invention, the step S30 includes:
step S31, acquiring a plurality of change rate intervals preset for the data acquisition terminal;
step S32, acquiring an acquisition frequency interval corresponding to each change rate interval;
step S33, determining a current change rate interval corresponding to the current change rate;
and step S34, determining the acquisition frequency of the data acquisition terminal as the minimum acquisition frequency of the current acquisition frequency interval according to the current acquisition frequency interval corresponding to the current change rate interval.
In one embodiment, the change rate intervals may be three, which are: the change rate is not significant, the change rate fluctuates, and the change rate is significant, and the boundary value of each change rate interval can be set according to the user input.
Each rate of change interval corresponds to a unique acquisition frequency interval, for example: the interval with the inconspicuous change rate corresponds to a low acquisition frequency interval, the interval with the fluctuation change rate corresponds to a normal acquisition frequency interval, and the interval with the remarkable change rate corresponds to a high acquisition frequency interval. The boundary value of each acquisition frequency interval may be set according to user input.
When the data acquisition terminal acquires real-time data, the data acquired under normal conditions tend to be stable, abnormal data with large single fluctuation may occasionally appear, and the data acquired next time may be quickly recovered to be normal. In this embodiment, according to the current acquisition frequency interval corresponding to the current change rate interval, the acquisition frequency of the data acquisition terminal is determined as the minimum acquisition frequency of the current acquisition frequency interval, instead of being directly adjusted to the maximum acquisition frequency of the current acquisition frequency interval, which is beneficial to reducing the energy consumption of the data acquisition terminal while increasing the data acquisition frequency.
Based on the second embodiment of the method for reducing the communication data topology of the internet of things of the data acquisition terminal, in the third embodiment of the present invention, the step S50 includes:
step S51, when the new round of change rate exceeds a preset interval, acquiring a new round of change rate interval corresponding to the new round of change rate;
step S52, judging whether the new round of change rate interval is the current change rate interval;
if not, go to step S53: determining the acquisition frequency of the data acquisition terminal as the minimum acquisition frequency of the new acquisition frequency interval according to the new acquisition frequency interval corresponding to the new change rate interval;
if yes, go to step S54: and increasing the minimum acquisition frequency of the current acquisition frequency interval by a preset amplification to obtain a corrected acquisition frequency, and determining the acquisition frequency of the data acquisition terminal as the corrected acquisition frequency.
Specifically, when the new round of change rate is in a preset interval, the current acquisition frequency is maintained. The preset interval is used for evaluating whether the change rate of a new round is obvious or not, when the change rate of the new round exceeds the preset interval and is still in the previous change rate interval, the change rate is obvious but controllable, and at the moment, the current acquisition frequency can be corrected according to the preset amplification to obtain a higher acquisition frequency so as to provide more favorable data monitoring. When the change rate of a new round exceeds a preset interval and exceeds a previous change rate interval, the acquisition frequency can be directly adjusted in a cross-level mode, so that rapid adjustment is achieved.
Based on the second embodiment or the third embodiment of the method for reducing the communication data topology of the internet of things of the data acquisition terminal, in the fourth embodiment of the present invention, the step S60 includes:
s61, when the new round of change rate is lower than a preset interval, acquiring a new round of change rate interval corresponding to the new round of change rate;
step S62, judging whether the new round of change rate interval is the current change rate interval;
if not, executing step S63: determining the acquisition frequency of the data acquisition terminal as the minimum acquisition frequency of the new acquisition frequency interval according to the new acquisition frequency interval corresponding to the new change rate interval;
if yes, go to step S64: and reducing the minimum acquisition frequency of the current acquisition frequency interval by a preset reduction amplitude to obtain a corrected acquisition frequency, and determining the acquisition frequency of the data acquisition terminal as the corrected acquisition frequency.
When the change rate of the new round is lower than the preset interval, the change rate is reduced, and at the moment, the current acquisition frequency can be corrected according to the preset amplitude, so that the lower acquisition frequency is obtained, and the energy consumption of data acquisition is reduced.
Further, when the data acquisition frequency is continuously increased for the first time, the fault diagnosis monitoring equipment is started, and fault diagnosis is carried out according to the real-time data of the data acquisition terminal and the data acquired by the fault diagnosis monitoring equipment.
Based on the first to fourth embodiments of the method for reducing communication data topology of the internet of things of the data acquisition terminal, in a fifth embodiment of the invention, at least two data acquisition terminals are provided, and the method for reducing communication data topology of the internet of things of the data acquisition terminal further includes:
step S70, acquiring preset acquisition frequency of each data acquisition terminal;
step S80, according to the preset acquisition frequency of each data acquisition terminal, carrying out hierarchical marking on each data acquisition terminal;
s90, acquiring the physical position of each data acquisition terminal;
step S100, marking each data acquisition terminal in a partition mode according to the physical position of each data acquisition terminal;
step S110, acquiring each real-time data acquired by the data acquisition terminal in the current data processing period, and determining the processing sequence of each real-time data according to the hierarchical mark and the partition mark of the data acquisition terminal corresponding to each real-time data;
and step S120, marking the real-time data by adopting the processing sequence, and performing data processing on each real-time data at the cloud server according to the processing sequence.
According to the technical scheme, the data acquisition frequency preset by each data acquisition terminal is adopted to hierarchically mark each data acquisition terminal, the acquisition frequency of the data is used as an index for evaluating the importance degree of the data, and specifically, the acquisition frequency is positively correlated with the importance degree of the data; further, the physical position of each data acquisition terminal is adopted to mark each data acquisition terminal in a partition mode, so that the physical position is used as another index for evaluating the importance degree of the data; meanwhile, the processing sequence of each real-time data in the same data processing time period is determined by using the hierarchical marks and the partition marks for each real-time data collected in the same data processing time period, so that the cloud server does not process each real-time data indiscriminately, but processes each real-time data in sequence according to the important sequence of the data, so that the cloud server firstly feeds back the processing result of the important data and then feeds back the data with relatively low importance degree, and the convenience of data analysis is improved. Therefore, the technical scheme of the invention is beneficial to solving the problems that in the existing Internet of things technology, the cloud end carries out undifferentiated processing on each real-time data, so that the data analysis lacks scientific management and important data cannot be processed preferentially.
Specifically, each of the marks may be used as an influence coefficient, a summation result is determined by summing the hierarchical mark and the partition mark of each piece of real-time data, and a processing sequence is determined according to the summation result. Besides the partition mark and the layering mark as influence coefficients, the change rate of real-time data acquired for continuous preset times can be introduced, and the data change rate mark is adopted as another influence coefficient; further, the user-entered importance label may also be employed as a further influence coefficient. In one embodiment, an evaluation model for determining the data processing sequence of the cloud server may be established, and each influence coefficient is substituted into the model to determine the processing sequence of each real-time data.
Based on the fifth embodiment of the method for reducing communication data topology of the internet of things of the data acquisition terminal, in the sixth embodiment of the present invention, the step S80 includes:
step S81, acquiring a plurality of preset acquisition frequency intervals, wherein the interval ranges of the acquisition frequency intervals are not overlapped;
step S82, respectively corresponding the preset acquisition frequency of each data acquisition terminal to a unique acquisition frequency interval;
and S83, determining the hierarchy of each data acquisition terminal according to the corresponding result of the acquisition frequency interval.
Specifically, the interval ranges of the acquisition frequency intervals are not overlapped, and the acquisition frequency intervals have different sizes. For example:
the first acquisition frequency interval is (0s, 3s), the corresponding hierarchical mark is a first level, and the first processing sequence coefficient is 4;
the second acquisition frequency interval is (3s, 6s), the corresponding hierarchical mark is a second level, and the first processing sequence coefficient is 3;
the third acquisition frequency interval is (6s, 8s), the corresponding layered marker is a third level, and the first processing sequence coefficient is 2;
the fourth acquisition frequency interval is (8s, 10s), the corresponding hierarchical mark is a fourth level, and the first processing sequence coefficient is 1.
The larger the first processing order coefficient is, the higher the acquisition frequency is, and the higher the priority processing degree is.
In this embodiment, the internet of things communication data topology system comprises two data acquisition terminals, namely a voltmeter and an ammeter, wherein the acquisition frequency of the voltmeter is 5s, and the acquisition frequency of the ammeter is 2s; the voltmeter corresponds to a second frequency acquisition interval, the interval is marked as a second level, and the corresponding first processing sequence coefficient is 3; the ammeter corresponds to a first frequency acquisition interval, is marked as a first level, and corresponds to a first processing sequence coefficient of 4.
Based on the fifth embodiment of the method for reducing the communication data topology of the internet of things of the data acquisition terminal, in the seventh embodiment of the present invention, the step S100 includes:
step S101, acquiring each preset physical area;
step S102, respectively corresponding the physical position of each data acquisition terminal to a unique physical area;
and step S103, determining the area of each data acquisition terminal according to the corresponding result of the physical area.
Specifically, the physical areas do not overlap and have a security level order. For example, in the method, each data acquisition terminal is provided with a positioning module, and the physical position of the data acquisition terminal is determined according to the positioning module, for example: each preset physical area is divided on the map to form separate non-coincident areas, and each physical area corresponds to different area names.
For example, a first area of the first physical area on the map corresponds to a first level of security (indicating that the degree of security is important), and the second processing order coefficient is 4;
a second area of the second physical area on the map, corresponding to a second level of security (indicating that the degree of security is important), has a second processing order coefficient of 3;
a third area of the third physical area on the map, corresponding to a third level of security (indicating a general degree of security), has a second processing order coefficient of 2;
the fourth physical area is a fourth area on the map corresponding to a fourth level of security (indicating that the degree of security is not important) and the second process order coefficient is 1.
Each physical partition can be divided according to the influence degree on the operation of the equipment, and can also be divided according to the type of the collected data, namely hotspot data or non-hotspot data.
The larger the second processing order coefficient is, the higher the security level is, and the higher the priority processing degree is.
In this embodiment, the physical position of the voltmeter is located in the area a, and the physical position of the ammeter is located in the area B. Assuming that the area A of the voltmeter is positioned in the first physical area, the area A corresponds to the first area; the second process order coefficient is 4; assuming that the region B is located in the third physical region, corresponding to the third region, the second processing order coefficient is 2.
Based on the fifth embodiment of the method for reducing the communication data topology of the internet of things of the data acquisition terminal, in the eighth embodiment of the present invention, step S110 includes:
step S111, acquiring each real-time data acquired by the data acquisition terminal in the current data processing period;
step S112, determining a first processing sequence coefficient x corresponding to each real-time data according to the hierarchical mark of the data acquisition terminal corresponding to each real-time data;
step S113, determining a second processing sequence coefficient y corresponding to each real-time data according to the partition mark of the data acquisition terminal corresponding to each real-time data;
step S114, determining the processing sequence value of each real-time data according to the first processing sequence coefficient and the second processing sequence coefficient;
step S115, determining a processing order of each piece of real-time data according to the processing order value of each piece of real-time data.
In step S112, the first processing order coefficients corresponding to the data acquisition terminals at different levels are determined by referring to the following manner:
a first level, a first process order coefficient of 4;
a second level, the first processing order coefficient being 3;
in the third level, the first processing order coefficient is 2;
in the fourth level, the first processing order coefficient is 1.
In the second embodiment, the voltmeter is labeled as a second level, and the corresponding first processing order coefficient is 3; the current meter is labeled as the first level and the corresponding first process order coefficient is 4.
Further, the second processing sequence coefficients corresponding to the data acquisition terminals of different partitions in step S113 are determined by referring to the following manner:
a first zone, where the second process order factor is 4, corresponding to a security level of a first level (indicating that the security level is important);
a second region having a second processing order coefficient of 3 corresponding to a second level of security (indicating that the degree of security is important);
a third area, where the second processing order coefficient is 2, and the corresponding security level is a third level (indicating that the security degree is general);
and in the fourth area, the second processing order coefficient is 1, and the corresponding safety level is a fourth level (which indicates that the safety degree is not important).
In the third embodiment, the voltmeter corresponds to the first zone, and the second processing order coefficient is 4; the ammeter corresponds to the third region, and the second process order coefficient is 2.
Further, the data rate of change flag is determined as follows: determining the change rate by using the same real-time data acquired twice (the current data processing period and the last data processing period), specifically:
when the change rate is (b, a), the third process order coefficient z is 4 corresponding to the first change rate;
when the change rate is (c, b), the third process order coefficient z is 3 corresponding to the second change rate;
when the change rate is (d, c), the third process order coefficient z is 2 corresponding to the third change rate;
when the change rate is [0, d ], the third process order coefficient z is 1 corresponding to the fourth change rate;
wherein a is more than b and c is more than or equal to 0, a, b, c and d can be valued in a value interval according to the setting of a user. The larger the third process order coefficient is, the faster the change rate is indicated, and the higher the degree of priority process is.
Further, the importance mark is r, and each processing order coefficient of each item of real-time data may correspond to an importance mark, where an importance mark is a coefficient greater than zero.
Step S114 specifically includes: and establishing an evaluation model of the data processing sequence, and substituting each influence coefficient into the model to determine the processing sequence of each real-time data.
In the present invention, the evaluation model of the established data processing order is S (i) = r 1i .x i +r 2i .y i +r 3i .z i ；
Wherein, in the model S (i), i represents the ith item of real-time data, x i First processing order coefficient, y, representing the ith item of real-time data i Second processing order coefficient, z, representing the ith item of real-time data i A third processing order coefficient representing the ith real-time data; r is 1i Denotes x i Coefficient of importance of r 2i Denotes y i Coefficient of importance of r 3i Denotes z i The importance coefficient of (2). The value range of each parameter in this section is greater than or equal to 0. Wherein, when i is different in value, each r 1i May be equal, each r 2i May be equal, each r 3i May be equal.
Based on the fifth embodiment of the method for reducing the communication data topology of the internet of things of the data acquisition terminal, in the ninth embodiment of the present invention, the step S120 includes:
step S121, acquiring a processing sequence value of each real-time data in the current data processing time period;
step S122, acquiring a processing sequence value of each real-time data in the next data processing time period;
step S123, sorting the processing sequence values of the real-time data in the current data processing period and the next data processing period in descending order;
and step S124, processing the data of each real-time data according to the sequencing result.
Specifically, in the present embodiment, a period flag value of a different data processing period is introduced for each processing period. When the real-time data of the current data processing time interval and the real-time data of the next data processing time interval are not processed, adding a time interval marking value to the processing sequence value of each real-time data in the current data processing time interval, and correcting the processing sequence value of each real-time data in the current data processing time interval through the time interval marking value to obtain a corrected processing sequence value. And sorting the corrected processing sequence value of each real-time data in the current data processing time interval and the processing sequence value of each real-time data in the next data processing time interval from large to small, and performing data processing on each real-time data according to a sorting result.
The value range of the time interval mark value is greater than or equal to 0, and the specific value can be adjusted according to the input of a user. The introduction of the time interval flag value can strengthen the data processing priority of different data processing time intervals, for example, when the value of the time interval flag value is lower than a first set value (for example, the value of the time interval flag value is 0.001), it indicates that the influence of different data processing time intervals on the data processing priority can be eliminated. For another example, when the value of the time interval flag exceeds the second set value (for example, the value of the time interval flag is 10), it indicates that the influence of different data processing time intervals on the data processing sequence needs to be strengthened, and the real-time data in the previous processing time interval needs to be processed preferentially. The first set value and the second set value are respectively larger than 0, and the first set value is smaller than the second set value.
The introduction of the time interval marking value can enable a user to preferentially process real-time data which is more important for the user according to the data analysis requirement of the user.
Based on the fifth embodiment of the method for reducing the communication data topology of the internet of things of the data acquisition terminal, in the tenth embodiment of the invention, the communication data topology system of the internet of things further comprises a data processor, wherein one end of the data processor is provided with a data acquisition interface for receiving data of each data acquisition terminal, and the other end of the data processor is provided with a communication interface in communication connection with the cloud server; the step S110 includes:
step S116, acquiring each real-time data acquired by the data acquisition terminal in the current data processing period through the data processor;
step S117, in the data processor, determining a processing order of each piece of real-time data according to the hierarchical flag and the partition flag of the data acquisition terminal corresponding to each piece of real-time data;
the step S120 includes:
and step S125, marking the real-time data by adopting the processing sequence through the data processor, and sending each piece of real-time data marked by the processing sequence to the cloud server for data processing.
And the data processor is used for receiving the real-time data acquired by each data acquisition terminal, finishing the processing sequence marking of each real-time data in a layering marking and partitioning marking mode, and then sending each real-time data finished with the processing sequence marking to the cloud server for data processing.
Therefore, in this embodiment, while the data processing sequence is determined by using the communication topology method, the additionally generated calculated amount can be transferred to the data processor to be completed, so that the data processing speed of the cloud server is prevented from being reduced due to the fact that the cloud server increases the additionally calculated amount.
Meanwhile, if the cloud server fails, the processing sequence of the part of real-time data is marked, and data loss caused by the failure of the cloud server is avoided.
Furthermore, the data processor is independently adopted to finish the marking of the processing sequence, which is beneficial to quickly realizing the marking work of the processing sequence of the real-time data.
Further, based on the tenth embodiment of the method for reducing communication data topology of internet of things of the data acquisition terminal, in the eleventh embodiment of the invention, the communication data topology system of internet of things further includes a data memory, and the data memory is respectively connected with each data acquisition terminal and connected with the data processor; the method for reducing the communication data topology of the Internet of things of the data acquisition terminal further comprises the following steps:
step S130: when the data in the data processor is lost, the data processor acquires each stored real-time data from the data memory to avoid the loss of the acquired data.
Based on the ninth embodiment of the method for reducing the communication data topology of the internet of things of the data acquisition terminal, in the twelfth embodiment of the invention, the method for reducing the communication data topology of the internet of things of the data acquisition terminal further comprises the following steps:
step S140, processing completion marking is carried out on the processed data in the cloud server;
step S150, returning the processing completion flag to the data processor;
step S160, in the data processor, deleting the processed data according to the processing completion flag.
In this embodiment, the data processed in the cloud server is deleted in the data processor in time, so as to ensure that the data processor has sufficient storage space, and manual deletion is not required, thereby reducing the workload of manual maintenance.
Further, a processing completion flag may be returned to the data storage, and in the data storage, the processed data may be deleted according to the processing completion flag.
Based on the sixth embodiment to the twelfth embodiment of the method for reducing communication data topology of the internet of things of the data acquisition terminal, in the thirteenth embodiment of the invention, the method for reducing communication data topology of the internet of things of the data acquisition terminal further includes the following steps:
step S170, comparing the data processor with the data to be processed in the cloud server;
and step S180, according to the comparison result, sending the real-time data which are not received in the cloud server to the cloud server again from the data processor.
In actual use, due to the strength or interruption of the communication signal, data in the data processor may not be successfully sent to the cloud server. In this embodiment, when the timing time reaches the comparison period, the data processor is compared with the to-be-processed data in the cloud server, so that the to-be-processed data which is not successfully sent to the cloud server is sent to the cloud server again.
Further, in actual use, due to the strong and weak or interruption of the communication signal, the data processor may fail to receive the real-time data sent by the data memory. In this embodiment, when the timing time reaches the comparison period, the data processor is compared with the data to be processed in the data memory, so that the data to be processed, which is not successfully sent to the data memory, is sent to the data memory again.
In order to achieve the above object, the present invention further provides an internet of things communication data topology system, which applies any one of the above internet of things communication data topology methods for reducing data acquisition terminals, and the internet of things communication data topology system includes a cloud server and a plurality of data acquisition terminals respectively connected to the cloud server in a communication manner.
The above description is only a preferred embodiment of the present invention, and not intended to limit the scope of the present invention, and all modifications and equivalents of the present invention, which are made by the contents of the present specification and the accompanying drawings, or directly/indirectly applied to other related technical fields, are included in the scope of the present invention.
Claims (4)
1. The method for reducing the communication data topology of the Internet of things of the data acquisition terminal is characterized by being applied to a communication data topology system of the Internet of things, wherein the communication data topology system of the Internet of things comprises a cloud server and the data acquisition terminal which is in communication connection with the cloud server; the method for reducing the communication data topology of the Internet of things of the data acquisition terminals comprises the following steps:
acquiring real-time data acquired by the data acquisition terminal;
determining the current change rate of the real-time data acquired by the data acquisition terminal;
determining the acquisition frequency of the data acquisition terminal corresponding to the current change rate according to the current change rate;
determining a new round of change rate of the real-time data acquired by the data acquisition terminal at a next data acquisition node;
when the new round of change rate exceeds a preset interval, increasing the data acquisition frequency of the data acquisition terminal according to the new round of change rate;
when the new round of change rate is lower than a preset interval, the data acquisition frequency of the data acquisition terminal is adjusted to be low according to the new round of change rate; the preset interval is used for evaluating whether the change rate of a new round is obvious or not, when the change rate of the new round exceeds the preset interval and is still in the previous change rate interval, the change rate is obvious but controllable, and at the moment, the current acquisition frequency is corrected according to the preset amplification to obtain higher acquisition frequency so as to provide more favorable data monitoring; when the change rate of the new round exceeds a preset interval and exceeds the previous change rate interval, directly performing cross-level adjustment on the acquisition frequency to realize quick adjustment; when the change rate of the new round is lower than the preset interval, the change rate is reduced, and at the moment, the current acquisition frequency is corrected according to the preset attenuation to obtain a lower acquisition frequency so as to reduce the energy consumption of data acquisition; when the data acquisition frequency is continuously increased for the first time, starting the fault diagnosis monitoring equipment, and carrying out fault diagnosis according to the real-time data of the data acquisition terminal and the data acquired by the fault diagnosis monitoring equipment;
the method for reducing the communication data topology of the Internet of things of the data acquisition terminal further comprises the following steps:
acquiring preset acquisition frequency of each data acquisition terminal;
according to the preset acquisition frequency of each data acquisition terminal, hierarchically marking each data acquisition terminal, and taking the acquisition frequency of the data as an index for evaluating the importance degree of the data;
acquiring the physical position of each data acquisition terminal; each data acquisition terminal is provided with a positioning module, and the physical position of the data acquisition terminal is determined according to the positioning module;
according to the physical position of each data acquisition terminal, carrying out partition marking on each data acquisition terminal so as to use the physical position as another index for evaluating the importance degree of the data;
acquiring each real-time data acquired by the data acquisition terminal within a current data processing period, and determining the processing sequence of each real-time data according to the hierarchical mark and the partition mark of the data acquisition terminal corresponding to each real-time data, so that the cloud server does not process each real-time data indiscriminately, but processes each real-time data in sequence according to the important sequence of the data, so that the cloud server firstly feeds back the processing result of the important data and then feeds back the data with relatively low importance;
marking the real-time data by adopting the processing sequence, and performing data processing on each real-time data at the cloud server according to the processing sequence;
the step of marking each data acquisition terminal in a layered manner according to the preset acquisition frequency of each data acquisition terminal comprises the following steps: acquiring a plurality of preset acquisition frequency intervals, wherein the interval ranges of the acquisition frequency intervals are not overlapped; respectively corresponding the preset acquisition frequency of each data acquisition terminal to a unique acquisition frequency interval; determining the hierarchy of each data acquisition terminal according to the corresponding result of the acquisition frequency interval;
the step of marking each data acquisition terminal in a partition manner according to the physical position of each data acquisition terminal comprises the following steps: acquiring each preset physical area; respectively corresponding the physical positions of the data acquisition terminals to a unique physical area; determining the area of each data acquisition terminal according to the corresponding result of the physical area;
introducing each mark as one of the influence coefficients, determining a summation result by adopting a summation mode for the layering mark and the partitioning mark of each real-time data, and determining a processing sequence according to the summation result; introducing the change rate of real-time data acquired for continuous preset times, and adopting a data change rate mark as another influence coefficient; adopting the importance mark input by the user as a further influence coefficient; establishing an evaluation model for determining a data processing sequence of the cloud server, and substituting each influence coefficient into the model to determine the processing sequence of each real-time data;
the step of determining the acquisition frequency of the data acquisition terminal corresponding to the current change rate according to the current change rate comprises the following steps: acquiring a plurality of change rate intervals preset for the data acquisition terminal; acquiring acquisition frequency intervals corresponding to all the change rate intervals; determining a current change rate interval corresponding to the current change rate; determining the acquisition frequency of the data acquisition terminal as the minimum acquisition frequency of the current acquisition frequency interval according to the current acquisition frequency interval corresponding to the current change rate interval;
when the new round of change rate exceeds a preset interval, the step of increasing the data acquisition frequency of the data acquisition terminal according to the new round of change rate comprises the following steps: when the new round of change rate exceeds a preset interval, acquiring a new round of change rate interval corresponding to the new round of change rate; judging whether the new round of change rate interval is the current change rate interval or not; if not, determining the acquisition frequency of the data acquisition terminal as the minimum acquisition frequency of the new acquisition frequency interval according to the new acquisition frequency interval corresponding to the new change rate interval; if so, increasing the minimum acquisition frequency of the current acquisition frequency interval by a preset amplification to obtain a corrected acquisition frequency, and determining the acquisition frequency of the data acquisition terminal as the corrected acquisition frequency;
the step of acquiring each piece of real-time data acquired by the data acquisition terminal within the current data processing period, and determining the processing sequence of each piece of real-time data according to the hierarchical mark and the partition mark of the data acquisition terminal corresponding to each piece of real-time data includes: acquiring each real-time data acquired by the data acquisition terminal within the current data processing period; determining a first processing sequence coefficient corresponding to each real-time data according to the hierarchical mark of the data acquisition terminal corresponding to each real-time data; determining a second processing sequence coefficient corresponding to each real-time data according to the partition mark of the data acquisition terminal corresponding to each real-time data; determining a processing sequence value of each real-time data according to the first processing sequence coefficient and the second processing sequence coefficient; and determining the processing sequence of each real-time data according to the processing sequence value of each real-time data.
2. The method for reducing the communication data topology of the internet of things of the data acquisition terminal according to claim 1, wherein the step of reducing the data acquisition frequency of the data acquisition terminal according to the new change rate when the new change rate is lower than a preset interval comprises:
when the new round of change rate is lower than a preset interval, acquiring a new round of change rate interval corresponding to the new round of change rate;
judging whether the new round of change rate interval is the current change rate interval or not;
if not, determining the acquisition frequency of the data acquisition terminal as the minimum acquisition frequency of the new round of acquisition frequency interval according to the new round of acquisition frequency interval corresponding to the new round of change rate interval;
if so, reducing the minimum acquisition frequency of the current acquisition frequency interval by a preset reduction amplitude to obtain a corrected acquisition frequency, and determining the acquisition frequency of the data acquisition terminal as the corrected acquisition frequency.
3. The method for reducing the communication data topology of the internet of things of the data acquisition terminal according to claim 1, wherein the step of marking the real-time data by the processing sequence and performing data processing on each real-time data at the cloud server according to the processing sequence comprises:
acquiring a processing sequence value of each real-time data in a current data processing time period;
acquiring a processing sequence value of each piece of real-time data in a next data processing time period;
sequencing the processing sequence values of the real-time data in the current data processing time interval and the next data processing time interval from big to small;
and according to the sequencing result, performing data processing on each piece of real-time data.
4. The communication data topology system of the internet of things is characterized in that the communication data topology method of the internet of things for reducing the number of data acquisition terminals according to any one of claims 1 to 3 is applied, and the communication data topology system of the internet of things comprises a cloud server and the data acquisition terminals which are in communication connection with the cloud server.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010635240.4A CN111800503B (en) | 2020-07-03 | 2020-07-03 | Internet of things communication data topology method and system for reducing data acquisition terminals |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202010635240.4A CN111800503B (en) | 2020-07-03 | 2020-07-03 | Internet of things communication data topology method and system for reducing data acquisition terminals |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN111800503A CN111800503A (en) | 2020-10-20 |
| CN111800503B true CN111800503B (en) | 2023-04-18 |
Family
ID=72811061
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202010635240.4A Active CN111800503B (en) | 2020-07-03 | 2020-07-03 | Internet of things communication data topology method and system for reducing data acquisition terminals |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN111800503B (en) |
Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN105682121A (en) * | 2016-01-29 | 2016-06-15 | 中国联合网络通信集团有限公司 | Data acquisition method for sensor network, gateway and data acquisition system |
| WO2017067487A1 (en) * | 2015-10-22 | 2017-04-27 | 华为技术有限公司 | Electronic equipment and data processing method therefor |
| CN106873676A (en) * | 2017-02-09 | 2017-06-20 | 浙江百倍云信息科技有限公司 | A kind of wisdom agricultural data acquisition method and system based on Internet of Things |
| CN109525408A (en) * | 2017-09-18 | 2019-03-26 | 杭州海康威视系统技术有限公司 | A kind of unit exception processing method, device and cloud storage system |
| CN109672579A (en) * | 2017-10-16 | 2019-04-23 | 蔚来汽车有限公司 | Terminal device monitoring data acquisition strategies optimization method and device |
| CN111104303A (en) * | 2019-12-13 | 2020-05-05 | 苏州浪潮智能科技有限公司 | Server index data acquisition method, device and medium |
-
2020
- 2020-07-03 CN CN202010635240.4A patent/CN111800503B/en active Active
Patent Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| WO2017067487A1 (en) * | 2015-10-22 | 2017-04-27 | 华为技术有限公司 | Electronic equipment and data processing method therefor |
| CN105682121A (en) * | 2016-01-29 | 2016-06-15 | 中国联合网络通信集团有限公司 | Data acquisition method for sensor network, gateway and data acquisition system |
| CN106873676A (en) * | 2017-02-09 | 2017-06-20 | 浙江百倍云信息科技有限公司 | A kind of wisdom agricultural data acquisition method and system based on Internet of Things |
| CN109525408A (en) * | 2017-09-18 | 2019-03-26 | 杭州海康威视系统技术有限公司 | A kind of unit exception processing method, device and cloud storage system |
| CN109672579A (en) * | 2017-10-16 | 2019-04-23 | 蔚来汽车有限公司 | Terminal device monitoring data acquisition strategies optimization method and device |
| CN111104303A (en) * | 2019-12-13 | 2020-05-05 | 苏州浪潮智能科技有限公司 | Server index data acquisition method, device and medium |
Also Published As
| Publication number | Publication date |
|---|---|
| CN111800503A (en) | 2020-10-20 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111586195B (en) | Communication topology method and system of Internet of things | |
| US20160233957A1 (en) | Optical power data processing method, device and computer storage medium | |
| CN112597263B (en) | Pipe network detection data abnormity judgment method and system | |
| KR20220058606A (en) | Method and system for task distribution based on resource management platform | |
| CN107966193A (en) | Electronic scale capable of measuring in divided mode | |
| CN111800503B (en) | Internet of things communication data topology method and system for reducing data acquisition terminals | |
| CN110298570A (en) | Distribution network system topology status discrimination method, device, storage medium and equipment | |
| CN108874430A (en) | Electronic control unit ECU upgrade method, device and battery management system | |
| CN107340479B (en) | Method and system for improving SOC (state of charge) calculation precision of power battery of electric automobile | |
| CN115878418A (en) | Power consumption monitoring method, device, equipment and storage medium | |
| CN106209404B (en) | Analyzing abnormal network flow method and system | |
| CN102412426A (en) | Battery management system calibration method, battery management system and calibration system | |
| CN100397281C (en) | System and method for coordinated control of a switched power capacitor with an integrated resonance protection system | |
| CN111371593B (en) | Service deployment method, device, electronic equipment and storage medium | |
| CN104502932A (en) | Method and device for positioning terminal equipment | |
| CN110825753A (en) | Method for increasing positioning point capacity on webpage map | |
| CN106304176B (en) | Mobile terminal slave pattern frequency point measurement method and device | |
| CN110568370A (en) | Voltage acquisition period adjusting method and device | |
| CN106879027A (en) | A kind of load-balancing method and system based on wireless routing device response speed | |
| CN105099826A (en) | Network service operation status monitoring method and device | |
| CN106341829A (en) | Frequency point configuration method and device | |
| CN113543223A (en) | Parameter adjusting method, server and storage medium | |
| CN105990616B (en) | A kind of data processing method, device and electronic equipment | |
| CN115243383A (en) | Beam transmitting power adjusting method, device, equipment and storage medium | |
| CN106686082A (en) | Storage resource adjusting method and management node |
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 |