CN111800503B - Internet of things communication data topology method and system for reducing data acquisition terminals - Google Patents

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

An Internet of Things communication data topology method and system for reducing data collection terminals

technical field

The invention relates to the technical field of the Internet of Things, in particular to an Internet of Things communication data topology method for reducing data collection terminals, and an Internet of Things communication data topology system.

Background technique

In the communication process of the Internet of Things, it is necessary to set up a large number of data acquisition terminals to collect data, and send the collected data to the cloud for data processing. Since the collection frequency of existing data collection terminals is a fixed frequency, in order to adapt to the increased collection frequency of users in certain periods of time, in the existing Internet of Things technology, it is necessary to set up some spare data collection terminals to adapt to the adjustment of collection frequency . Therefore, there is a disadvantage of wasting the number of data collection terminals in the prior art.

Contents of the invention

The main purpose of the present invention is to provide a communication data topology method of the Internet of Things that reduces the number of data collection terminals, aiming at solving the problem of waste of data collection terminals in the existing Internet of Things technology.

In order to achieve the above-mentioned purpose, the Internet of Things communication data topology method for reducing data acquisition terminals proposed by the present invention is applied to the Internet of Things communication data topology system, and the Internet of Things communication data topology system includes a cloud server and a communication connection with the cloud server. Data acquisition terminal; the Internet of Things communication data topology method for reducing the data acquisition terminal, comprising the steps of:

Obtain the real-time data collected by the data collection terminal;

determining the current rate of change of the real-time data collected by the data collection terminal;

According to the current rate of change, determine the collection frequency of the data collection terminal corresponding to the current rate of change;

At the next data collection node, determine a new round of change rate of the real-time data collected by the data collection terminal;

When the new round of change rate exceeds a preset interval, the data collection frequency of the data collection terminal is increased according to the new round of change rate;

When the new round of change rate is lower than the preset interval, the data collection frequency of the data collection terminal is lowered according to the new round of change rate.

Preferably, the step of determining the collection frequency of the data collection terminal corresponding to the current rate of change according to the current rate of change includes:

Acquiring a plurality of change rate intervals preset for the data collection terminal;

Obtain the collection frequency interval corresponding to each change rate interval;

determining the current rate-of-change interval corresponding to the current rate-of-change;

According to the current collection frequency interval corresponding to the current change rate interval, the collection frequency of the data collection terminal is determined as the minimum collection frequency of the current collection frequency interval.

Preferably, when the new round of change rate exceeds a preset interval, the step of increasing the data collection frequency of the data collection terminal according to the new round of change rate includes:

When the new round of change rate exceeds a preset interval, acquire a new round of change rate interval corresponding to the new round of change rate;

judging whether the new round of rate-of-change interval is the current rate-of-change interval;

If not, according to the new round of collection frequency interval corresponding to the new round of change rate interval, the collection frequency of the data collection terminal is determined as the minimum collection frequency of the new round of collection frequency interval;

If so, increase the minimum collection frequency of the current collection frequency interval by a preset increment to obtain a corrected collection frequency, and determine the collection frequency of the data collection terminal as the corrected collection frequency.

Preferably, when the new round of change rate is lower than a preset interval, the step of lowering the data collection frequency of the data collection terminal according to the new round of change rate includes:

When the new round of change rate is lower than the preset interval, acquiring a new round of change rate interval corresponding to the new round of change rate;

judging whether the new round of rate-of-change interval is the current rate-of-change interval;

If not, according to the new round of collection frequency interval corresponding to the new round of change rate interval, the collection frequency of the data collection terminal is determined as the minimum collection frequency of the new round of collection frequency interval;

If so, reduce the minimum collection frequency in the current collection frequency interval by a preset damping rate to obtain a corrected collection frequency, and determine the collection frequency of the data collection terminal as the corrected collection frequency.

Preferably, there are at least two data collection terminals, and the IoT communication data topology method for reducing data collection terminals further includes:

Obtain the preset collection frequency of each of the data collection terminals;

performing hierarchical marking on each of the data collection terminals according to the preset collection frequency of each of the data collection terminals;

Acquiring the physical location of each of the data collection terminals;

According to the physical location of each of the data collection terminals, mark each of the data collection terminals as partitions;

Obtain each real-time data collected by the data collection terminal in the current data processing period, and determine the processing order of each of the real-time data according to the layered mark and the partition mark of the data collection terminal corresponding to each of the real-time data;

Marking the real-time data by using the processing sequence, and performing data processing on each of the real-time data on the cloud server according to the processing sequence.

Preferably, the step of hierarchically marking each of the data collection terminals according to the preset collection frequency of each of the data collection terminals includes:

Obtaining a plurality of preset collection frequency intervals, wherein the interval ranges of each of the collection frequency intervals do not overlap;

Corresponding the preset collection frequencies of each of the data collection terminals to a unique collection frequency interval;

According to the corresponding results of the collection frequency intervals, the level of each data collection terminal is determined.

Preferably, the step of marking each of the data collection terminals according to the physical location of each of the data collection terminals includes:

Obtain each preset physical area;

Corresponding the physical positions of each of the data collection terminals to a unique physical area;

According to the corresponding result of the physical area, the area of each data collection terminal is determined.

Preferably, in the acquisition of each real-time data collected by the data collection terminal within the current data processing period, according to the hierarchical mark and partition mark of the data collection terminal corresponding to each of the real-time data, determine the number of each real-time data Steps in the processing sequence, including:

Obtain each real-time data collected by the data collection terminal within the current data processing period;

Determining a first processing sequence coefficient corresponding to each of the real-time data according to the hierarchical mark of the data collection terminal corresponding to each of the real-time data;

Determining a second processing order coefficient corresponding to each of the real-time data according to the partition mark of the data collection terminal corresponding to each of the real-time data;

determining a processing sequence value of each of the real-time data according to the first processing sequence coefficient and the second processing sequence coefficient;

The processing sequence of each real-time data is determined according to the processing sequence value of each real-time data.

Preferably, the step of marking the real-time data using the processing sequence, and performing data processing on each of the real-time data on the cloud server according to the processing sequence includes:

Obtain the processing sequence value of each of the real-time data within the current data processing period;

Acquiring the processing sequence value of each of the real-time data in the next data processing period;

Sorting the processing sequence values of each of the real-time data in the current data processing period and the next data processing period in descending order;

Perform data processing on each of the real-time data according to the sorting results.

In order to achieve the above object, the present invention also provides a communication data topology system of the Internet of Things, which uses the communication data topology method of the Internet of Things that reduces data collection terminals as described in any one of the above, and the communication data topology system of the Internet of Things includes a cloud server and a data collection terminal communicatively connected to the cloud server.

In the technical solution of the present invention, after the real-time data of the data collection terminal is obtained, the current rate of change of the real-time data collected by the data collection terminal is further determined, and the current rate of change corresponding to the current rate of change is determined according to the current rate of change. The collection frequency of the data collection terminal. Specifically, if the current rate of change exceeds the preset interval, it indicates that the current real-time data is in a transient state (significantly abnormal state), and if the rate of change continues to maintain a high level, it is likely to cause equipment failure or cause danger. Increase the collection frequency to closely observe the changes of real-time data; if the current change rate is less than the preset interval, it indicates that the current real-time data is in a relatively stable state and the equipment is in a stable state. In this case, the collection frequency can be reduced to reduce the data Collect the energy consumption of the terminal; if the current rate of change is within the preset range, it indicates that the current real-time data is in a certain state of fluctuation, but has not reached a significant abnormal state, and it is necessary to continue to pay attention to the changes in the collected real-time data in the current state. Maintain the current acquisition frequency. Since the technical solution of the present invention dynamically adjusts the data collection frequency according to the rate of change of real-time data, the technical solution of the present invention is conducive to using the existing number of data collection terminals to obtain more data without changing the number of data collection terminals. More collected data, or less collected data, so as to solve the problem of waste of data collection terminals in the existing Internet of Things technology.

Description of drawings

In order to more clearly illustrate the technical solutions in the embodiments of the present invention or the prior art, the following will briefly introduce the drawings that need to be used in the description of the embodiments or the prior art. Obviously, the accompanying drawings in the following description are only These are some embodiments of the present invention. For those skilled in the art, other drawings can also be obtained according to the structures shown in these drawings without creative effort.

Fig. 1 is the flowchart of the first embodiment of the Internet of Things communication data topology method for reducing data acquisition terminals in the present invention;

FIG. 2 is a flow chart of a second embodiment of the method for reducing the Internet of Things communication data topology of data collection terminals according to the present invention.

The realization of the purpose of the present invention, functional characteristics and advantages will be further described in conjunction with the embodiments and with reference to the accompanying drawings.

Detailed ways

The following will clearly and completely describe the technical solutions in the embodiments of the present invention with reference to the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments are only part of the embodiments of the present invention, not all of them. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without creative efforts fall within the protection scope of the present invention.

It should be noted that all directional indications (such as up, down, left, right, front, back...) in the embodiments of the present invention are only used to explain the relationship between the components in a certain posture (as shown in the accompanying drawings). Relative positional relationship, movement conditions, etc., if the specific posture changes, the directional indication will also change accordingly.

In addition, in the present invention, descriptions such as "first", "second" and so on are used for description purposes only, and should not be understood as indicating or implying their relative importance or implicitly indicating the quantity of indicated technical features. Thus, the features defined as "first" and "second" may explicitly or implicitly include at least one of these features. In the description of the present invention, "plurality" means at least two, such as two, three, etc., unless otherwise specifically defined.

In the present invention, unless otherwise specified and limited, the terms "connection" and "fixation" should be understood in a broad sense, for example, "fixation" can be a fixed connection, a detachable connection, or an integral body; It can be a mechanical connection or an electrical connection; it can be a direct connection or an indirect connection through an intermediary, and it can be an internal communication between two elements or an interaction relationship between two elements, unless otherwise clearly defined. Those of ordinary skill in the art can understand the specific meanings of the above terms in the present invention according to specific situations.

In addition, the technical solutions of the various embodiments of the present invention can be combined with each other, but it must be based on the realization of those skilled in the art. When the combination of technical solutions is contradictory or cannot be realized, it should be considered as a combination of technical solutions. Does not exist, nor is it within the scope of protection required by the present invention.

Please refer to Fig. 1, in order to achieve the above-mentioned purpose, the Internet of Things communication data topology method for reducing data collection terminals proposed by the present invention is applied to the Internet of Things communication data topology system, and the Internet of Things communication data topology system includes a cloud server and the communication with the said The data acquisition terminal of cloud server communication connection; The described method for reducing the Internet of Things communication data topology of data acquisition terminal comprises the following steps:

Step S10, obtaining the real-time data collected by the data collection terminal;

Step S20, determining the current rate of change of the real-time data collected by the data collection terminal;

Step S30, according to the current rate of change, determine the collection frequency of the data collection terminal corresponding to the current rate of change;

Step S40, at the next data collection node, determine a new round of change rate of the real-time data collected by the data collection terminal;

Step S50, when the new round of change rate exceeds a preset interval, increase the data collection frequency of the data collection terminal according to the new round of change rate;

Step S60, when the new round of change rate is lower than the preset interval, lower the data collection frequency of the data collection terminal according to the new round of change rate.

In the technical solution of the present invention, after the real-time data of the data collection terminal is obtained, the current rate of change of the real-time data collected by the data collection terminal is further determined, and the current rate of change corresponding to the current rate of change is determined according to the current rate of change. The collection frequency of the data collection terminal. Specifically, if the current rate of change exceeds the preset interval, it indicates that the current real-time data is in a transient state (significantly abnormal state), and if the rate of change continues to maintain a high level, it is likely to cause equipment failure or cause danger. Increase the collection frequency to closely observe the changes of real-time data; if the current change rate is less than the preset interval, it indicates that the current real-time data is in a relatively stable state and the equipment is in a stable state. In this case, the collection frequency can be reduced to reduce the data Collect the energy consumption of the terminal; if the current rate of change is within the preset range, it indicates that the current real-time data is in a certain state of fluctuation, but has not reached a significant abnormal state, and it is necessary to continue to pay attention to the changes in the collected real-time data in the current state. Maintain the current acquisition frequency. Since the technical solution of the present invention dynamically adjusts the data collection frequency according to the rate of change of real-time data, the technical solution of the present invention is conducive to using the existing number of data collection terminals to obtain more data without changing the number of data collection terminals. More collected data, or less collected data, so as to solve the problem of waste of data collection terminals in the existing Internet of Things technology.

Wherein, the "next data collection node" in step S40 is determined according to the collection frequency determined in step S30. The initial collection frequency of the data collection terminal is the preset frequency. In step S60, the data collection frequency of the data collection terminal is lowered according to the new round of change rate, and after the collection frequency is lowered to the set minimum collection frequency, it cannot be further lowered.

Please refer to FIG. 2, based on the first embodiment of the present invention to reduce the Internet of Things communication data topology method of data collection terminals, in the second embodiment of the present invention, the step S30 includes:

Step S31, obtaining a plurality of change rate intervals preset for the data collection terminal;

Step S32, acquiring the collection frequency interval corresponding to each change rate interval;

Step S33, determining the current rate of change interval corresponding to the current rate of change;

Step S34, according to the current collection frequency interval corresponding to the current change rate interval, determine the collection frequency of the data collection terminal as the minimum collection frequency of the current collection frequency interval.

In a specific embodiment, there may be three rate-of-change intervals, namely: an insignificant rate-of-change interval, a fluctuating rate-of-change interval, and a significant rate-of-change interval, and the boundary value of each rate-of-change interval can be set according to user input.

Each rate-of-change interval corresponds to a unique acquisition frequency interval, for example, the insignificant rate-of-change interval corresponds to the low-acquisition-frequency interval, the fluctuating rate-of-change interval corresponds to the normal acquisition frequency interval, and the significant-rate-of-change interval corresponds to the high-acquisition frequency interval. The boundary value of each collection frequency interval can be set according to user input.

When the data collection terminal is collecting real-time data, the data collected under normal conditions tends to be stable, and there may be occasional abnormal data with large single fluctuations, and the data collected next time may quickly return to normal. In this embodiment, according to the current collection frequency interval corresponding to the current change rate interval, the collection frequency of the data collection terminal is determined as the minimum collection frequency of the current collection frequency interval, instead of directly adjusting to the current collection frequency interval The maximum collection frequency is beneficial to reduce the energy consumption of the data collection terminal while increasing the data collection frequency.

Based on the second embodiment of the present invention to reduce the Internet of Things communication data topology method of data collection terminals, 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, obtain a new round of change rate interval corresponding to the new round of change rate;

Step S52, judging whether the new round of rate-of-change interval is the current rate-of-change interval;

If not, perform step S53: according to the new round of collection frequency interval corresponding to the new round of change rate interval, determine the collection frequency of the data collection terminal as the minimum collection frequency of the new round of collection frequency interval;

If yes, execute step S54: increase the minimum collection frequency in the current collection frequency interval by a preset increment to obtain a revised collection frequency, and determine the collection frequency of the data collection terminal as the revised collection frequency.

Specifically, when the new round of rate of change is within a preset interval, the current collection frequency is maintained. The preset interval is used to evaluate whether the new round of change rate is significant. When the new round of change rate exceeds the preset interval but is still within the previous change rate interval, it indicates that the change rate is relatively significant, but it is controllable. At this time, you can The current acquisition frequency is corrected according to the preset increment to obtain a higher acquisition frequency to provide more favorable data monitoring. When the new round of change rate exceeds the preset range and exceeds the previous change rate range, the acquisition frequency can be directly adjusted across levels to achieve rapid adjustment.

Based on the second embodiment or the third embodiment of the Internet of Things communication data topology method for reducing data collection terminals in the present invention, in the fourth embodiment of the present invention, the step S60 includes:

Step S61, when the new round of change rate is lower than the preset interval, obtain a new round of change rate interval corresponding to the new round of change rate;

Step S62, judging whether the new round of rate-of-change interval is the current rate-of-change interval;

If not, perform step S63: according to the new round of collection frequency interval corresponding to the new round of change rate interval, determine the collection frequency of the data collection terminal as the minimum collection frequency of the new round of collection frequency interval;

If yes, execute step S64: reduce the minimum collection frequency in the current collection frequency interval by a preset damping rate to obtain a revised collection frequency, and determine the collection frequency of the data collection terminal as the revised collection frequency.

When the new round of change rate is lower than the preset interval, it indicates that the change rate is reduced. At this time, the current collection frequency can be corrected according to the preset reduction rate to obtain a lower collection frequency to reduce data collection energy consumption.

Further, when the data collection frequency increases for the first time consecutively, start the fault diagnosis monitoring equipment, and perform fault diagnosis according to the real-time data of the data collection terminal and the data collected by the fault diagnosis monitoring equipment.

Based on the first embodiment to the fourth embodiment of the Internet of Things communication data topology method for reducing data collection terminals of the present invention, in the fifth embodiment of the present invention, there are at least two data collection terminals, and the reduction of data collection terminals The Internet of Things communication data topology method also includes:

Step S70, acquiring the preset collection frequency of each of the data collection terminals;

Step S80, according to the collection frequency preset by each of the data collection terminals, mark each of the data collection terminals hierarchically;

Step S90, acquiring the physical location of each of the data collection terminals;

Step S100, according to the physical location of each of the data collection terminals, mark each of the data collection terminals as partitions;

Step S110: Obtain each real-time data collected by the data collection terminal within the current data processing period, and determine the processing order of each real-time data according to the hierarchical mark and partition mark of the data collection terminal corresponding to each of the real-time data ;

Step S120, marking the real-time data with the processing sequence, and performing data processing on each of the real-time data on the cloud server according to the processing sequence.

In the technical solution of the present invention, the data collection frequency preset by each data collection terminal is used to carry out hierarchical marking on each data collection terminal, so as to use the collection frequency of the data as an index for evaluating the importance of the data, Specifically, the collection frequency and the importance of the data are positively correlated; further, the physical location of each data collection terminal is used to mark each data collection terminal as a partition, so as to use the physical location as another indicator for evaluating the importance of the data. An indicator; at the same time, for each real-time data collected in the same data processing period, use hierarchical marking and partition marking to determine the processing sequence of each real-time data in this period, so that the cloud server no longer processes each real-time data indiscriminately. Instead, each real-time data is processed successively according to the order of importance of the data, so that the cloud server will first feed back the processing results of important data, and then feed back the data with relatively low importance, so as to improve the convenience of data analysis. Therefore, the technical solution of the present invention is beneficial to solve the problem that in the existing Internet of Things technology, data analysis lacks scientific management and important data cannot be prioritized due to indiscriminate processing of various real-time data by the cloud.

Specifically, each mark may be used as an influence coefficient, and the summation result is determined by summing the hierarchical marks and partition marks of each real-time data, and the processing sequence is determined according to the summation result. In addition to partition marks and layered marks as influence coefficients, the rate of change of real-time data collected continuously for preset times can also be introduced, and data change rate marks can be used as another influence coefficient; degree mark as a further influence factor. In a specific embodiment, an evaluation model for determining the data processing order of the cloud server can be established, and various influence coefficients are brought into the model to determine the processing order of each real-time data.

Based on the fifth embodiment of the Internet of Things communication data topology method for reducing data collection terminals in the present invention, 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 each of the acquisition frequency intervals do not overlap;

Step S82, corresponding the preset collection frequencies of each of the data collection terminals to a unique collection frequency interval;

Step S83: Determine the level of each data collection terminal according to the corresponding result of the collection frequency interval.

Specifically, the ranges of the collection frequency intervals do not overlap, and the collection frequency intervals have different sizes. For example:

The first acquisition frequency interval is (0s, 3s], the corresponding layer is marked as the first level, and the first processing sequence coefficient is 4;

The second acquisition frequency interval is (3s, 6s], the corresponding layer is marked as the second level, and the first processing sequence coefficient is 3;

The third acquisition frequency interval is (6s, 8s], the corresponding layer is marked as the third level, and the first processing sequence coefficient is 2;

The fourth acquisition frequency interval is (8s, 10s], the corresponding layer is marked as the fourth level, and the first processing sequence coefficient is 1.

The larger the coefficient of the first processing order, the higher the collection frequency and the higher the priority processing degree.

In this embodiment, the Internet of Things communication data topology system includes two data collection terminals of a voltmeter and an ammeter, wherein the collection frequency of the voltmeter is 5s, and the collection frequency of the ammeter is 2s; the voltmeter corresponds to the second frequency collection The interval is marked as the second level, and the corresponding first processing order coefficient is 3; the galvanometer corresponds to the first frequency acquisition interval, marked as the first level, and the corresponding first processing order coefficient is 4.

Based on the fifth embodiment of the present invention to reduce the Internet of Things communication data topology method of data collection terminals, in the seventh embodiment of the present invention, the step S100 includes:

Step S101, acquiring each preset physical area;

Step S102, corresponding the physical locations of each of the data collection terminals to a unique physical area;

Step S103, according to the corresponding result of the physical area, determine the area of each of the data collection terminals.

Specifically, each of the physical areas does not overlap, and has a security level order. For example, in this method, each data collection terminal is provided with a positioning module, and the physical location of the data collection terminal is determined according to the positioning module, for example: each preset physical area is divided on the map to form non-overlapping areas separated from each other, and each physical area Corresponding to different area names.

For example, the first physical area is in the first zone on the map, and the corresponding security level is the first level (indicating that the security level is very important), and the second processing sequence coefficient is 4;

The second physical area is in the second district on the map, and the corresponding security level is the second level (indicates that the degree of security is important), and the second processing sequence coefficient is 3;

The third physical area is in the third area on the map, and the corresponding security level is the third level (indicating that the security level is average), and the second processing sequence coefficient is 2;

The fourth physical area is in the fourth area on the map, the corresponding security level is the fourth level (indicating that the security level is not important), and the second processing sequence coefficient is 1.

Each physical partition can be divided according to the degree of impact on the operation of the equipment, or according to the type of collected data as hot data or non-hot data.

The larger the second processing sequence coefficient, the higher the security level and the higher the priority processing degree.

In this embodiment, the physical location of the voltmeter is located in area A, and the physical location of the ammeter is located in area B. Assuming that area A of the voltmeter is located in the first physical area, it corresponds to the first area; the second processing order coefficient is 4; assuming that area B is located in the third physical area, it corresponds to the third area, then the second processing order coefficient is 2.

Based on the fifth embodiment of the Internet of Things communication data topology method for reducing data collection terminals in the present invention, in the eighth embodiment of the present invention, step S110 includes:

Step S111, acquiring various real-time data collected through the data collection terminal within the current data processing period;

Step S112, determining the first processing sequence coefficient x corresponding to each of the real-time data according to the hierarchical mark of the data collection terminal corresponding to each of the real-time data;

Step S113, according to the partition mark of the data collection terminal corresponding to each of the real-time data, determine the second processing sequence coefficient y corresponding to each of the real-time data;

Step S114, according to the first processing order coefficient and the second processing order coefficient, determine the processing order value of each of the real-time data;

Step S115, according to the processing order value of each said real-time data, determine the processing order of each said real-time data.

Wherein, in step S112, the first processing sequence coefficients corresponding to the data collection terminals at different levels are determined by referring to the following method:

The first level, the first processing sequence coefficient is 4;

At the second level, the first processing sequence coefficient is 3;

The third level, the first processing sequence coefficient is 2;

For the fourth level, the first processing sequence coefficient is 1.

In the above-mentioned second embodiment, the voltmeter is marked as the second level, and the corresponding first processing order coefficient is 3; the ammeter is marked as the first level, and the corresponding first processing order coefficient is 4.

Further, in step S113, the second processing order coefficients corresponding to the data collection terminals in different partitions are determined by referring to the following method:

In the first zone, the second processing sequence coefficient is 4, and the corresponding security level is the first level (indicating that the degree of security is very important);

In the second area, the second processing sequence coefficient is 3, and the corresponding security level is the second level (indicating that the degree of security is important);

In the third zone, the second processing sequence coefficient is 2, and the corresponding security level is the third level (indicating that the security level is general);

In the fourth zone, the second processing sequence coefficient is 1, and the corresponding security level is the fourth level (indicating that the security level is not important).

In the above third embodiment, the voltmeter corresponds to the first zone, and the second processing sequence coefficient is 4; the ammeter corresponds to the third zone, and the second processing sequence coefficient is 2.

Furthermore, the data change rate mark is determined in the following manner: the change rate is determined by using the same real-time data collected twice in a row (the current data processing period and the previous data processing period), specifically:

When the rate of change is in (b, a], corresponding to the first rate of change, the third processing sequence coefficient z is 4;

When the rate of change is in (c, b], corresponding to the second rate of change, the third processing sequence coefficient z is 3;

When the rate of change is in (d, c], corresponding to the third rate of change, the third processing sequence coefficient z is 2;

When the rate of change is in [0,d], corresponding to the fourth rate of change, the coefficient z of the third processing sequence is 1;

Wherein, a>b>c>d≥0, a, b, c, and d can take values within a value interval according to user settings. The larger the coefficient of the third processing order, the faster the rate of change and the higher the degree of priority processing.

Furthermore, the importance is marked as r, and each processing sequence coefficient of each item of real-time data may correspond to an importance mark, and the importance is marked as a coefficient greater than zero.

Step S114 is specifically: establishing an evaluation model of the data processing sequence, and bringing 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 sequence is S(i)=r _{1i .xi} +r _2i .y _i +r _3i .z _i ;

Among them, in the model S(i), i represents the i-th real-time data, x _i represents the first processing sequence coefficient of the i-th real-time data, y _i represents the second processing sequence coefficient of the i-th real-time data, z _i represents The third processing sequence coefficient of the i-th real-time data; r _1i represents the importance coefficient of x _i , r _2i represents the importance coefficient of y _i , and r _3i represents the importance coefficient of z _i . The value range of each parameter in this section is greater than or equal to 0. Wherein, when the values of i are different, each r _1i can be equal, each r _2i can be equal, and each r _3i can be equal.

Based on the fifth embodiment of the Internet of Things communication data topology method for reducing data collection terminals in the present invention, in the ninth embodiment of the present invention, the step S120 includes:

Step S121, acquiring the processing sequence value of each of the real-time data within the current data processing period;

Step S122, acquiring the processing sequence value of each of the real-time data in the next data processing period;

Step S123, sorting the processing sequence values of each of the real-time data in the current data processing period and the next data processing period in descending order;

Step S124, performing data processing on each of the real-time data according to the sorting result.

Specifically, in this embodiment, for each processing period, time period mark values of different data processing periods are introduced. When the real-time data of the current data processing period and the next data processing period are not processed at the same time, the period mark value is added to the processing sequence value of each real-time data in the current data processing period, so as to pass the period mark value to the current data. The processing sequence value of each real-time data within the processing period is corrected to obtain the corrected processing sequence value. Sorting the corrected processing sequence values of each real-time data in the current data processing period and the processing sequence values of each real-time data in the next data processing period in descending order, and according to the sorting results, Data processing is performed on each of the real-time data.

The value range of the period mark value is greater than or equal to 0, and the specific value can be adjusted according to the user's input. The introduction of time period mark value can strengthen the priority order of data processing in different data processing periods. The impact of the data processing period on the data processing sequence. As another example, when the value of the period flag exceeds the second set value (for example, the value of the period flag is 10), it means that the influence of different data processing periods on the data processing sequence needs to be strengthened, and the previous processing period must be prioritized real-time data. Wherein, the first set value and the second set value are respectively greater than 0, and the first set value is smaller than the second set value.

The introduction of time-period tag values can enable users to prioritize the real-time data that users think is more important according to their own data analysis needs.

Based on the fifth embodiment of the Internet of Things communication data topology method for reducing data collection terminals in the present invention, in the tenth embodiment of the present invention, the Internet of Things communication data topology system further includes a data processor, and one end of the data processor is set Receive the data collection interface of each data collection terminal data, and set the communication interface connected with the cloud server at the other end; the step S110 includes:

Step S116, using the data processor to obtain each real-time data collected by the data collection terminal in the current data processing period;

Step S117, in the data processor, determine the processing order of each of the real-time data according to the hierarchical mark and the partition mark of the data collection terminal corresponding to each of the real-time data;

The step S120 includes:

Step S125, marking the real-time data with the processing order by the data processor, and sending each real-time data marked with the processing order to the cloud server for data processing.

The data processor is used to receive the real-time data collected by each data collection terminal, complete the processing order marking of each real-time data by means of layered marking and partition marking, and then send each real-time data marked with the completed processing order to The cloud server performs data processing.

Therefore, in this embodiment, while using the communication topology method to determine the data processing order, it can also transfer the additional calculation amount to the data processor to complete, so as to avoid the reduction of the data processing speed of the cloud server caused by the additional calculation amount of the cloud server.

At the same time, if the cloud server fails, the processing sequence mark of this part of real-time data will not cause data loss due to the cloud server failure.

Furthermore, the data processor alone is used to complete the processing sequence marking, which is conducive to quickly realizing the processing sequence marking work of real-time data.

Further, based on the tenth embodiment of the present invention reducing the IoT communication data topology method for data collection terminals, in the eleventh embodiment of the present invention, the IoT communication data topology system further includes a data storage, and the data storage is respectively connected to Each data collection terminal is connected and connected with the data processor; the method for reducing the Internet of Things communication data topology method of the data collection terminal also includes 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 storage, so as to avoid loss of collected data.

Based on the ninth embodiment of the present invention to reduce the Internet of Things communication data topology method for data collection terminals, in the twelfth embodiment of the present invention, the method for reducing the Internet of Things communication data topology for data collection terminals further includes the following steps:

Step S140, mark the processed data in the cloud server as completed;

Step S150, returning the processing completion flag to the data processor;

Step S160, in the data processor, delete the processed data according to the processing completion mark.

In this embodiment, the processed data in the cloud server is deleted in the data processor in time to ensure that the data processor has sufficient storage space and does not need to be manually deleted, reducing the workload of manual maintenance.

Further, the processing completion mark may be returned to the data storage, and in the data storage, the processed data is deleted according to the processing completion mark.

Based on the sixth embodiment to the twelfth embodiment of the Internet of Things communication data topology method for reducing data collection terminals in the present invention, in the thirteenth embodiment of the present invention, the method for reducing the Internet of Things communication data topology for data collection terminals, Also include the following steps:

Step S170, comparing the data to be processed in the data processor with the cloud server;

Step S180, according to the comparison result, resend the real-time data not received in the cloud server to the cloud server from the data processor.

In actual use, due to reasons such as the strength or interruption of the communication signal, the data in the data processor may not be successfully sent to the cloud server. In this embodiment, when the counting time reaches the comparison period, the data processor and the data to be processed in the cloud server are compared, so that the data to be processed that cannot be successfully sent to the cloud server can be sent again to the cloud server.

Furthermore, in actual use, due to reasons such as strength or interruption of communication signals, the data processor may fail to receive the real-time data sent by the data memory. In this embodiment, when the counting time reaches the comparison period, the data to be processed in the data processor and the data memory are compared, so that the data to be processed that cannot be successfully sent to the data memory is sent again to the data store.

In order to achieve the above object, the present invention also provides a communication data topology system of the Internet of Things, which uses the communication data topology method of the Internet of Things that reduces data collection terminals as described in any one of the above, and the communication data topology system of the Internet of Things includes a cloud server and a plurality of data collection terminals respectively connected to the cloud server by communication.

The above are only preferred embodiments of the present invention, and are not intended to limit the patent scope of the present invention. Under the conception of the present invention, the equivalent structural transformation made by using the description of the present invention and the contents of the accompanying drawings, or directly/indirectly used in other related All technical fields are included in the patent protection 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.

Images