CN105682121A - Data acquisition method for sensor network, gateway and data acquisition system - Google Patents

Abstract

The present invention relates to a data collection method, a gateway and a data collection system for a sensor network, wherein the sensor network includes a plurality of sensor nodes, and the data collection method includes: receiving data sent by each sensor node within a preset time period The amount of change is compared with the corresponding preset value; determine whether there is data whose amount of change reaches the corresponding preset value; increase the acquisition frequency of the sensor node corresponding to the data whose amount of change reaches the corresponding preset value to the first acquisition frequency frequency. The present invention utilizes the same gateway to control the collection frequency of different sensor nodes, so that the unsynchronized situation of uploaded data does not occur, which is beneficial to the analysis and processing of the data by the background server.

Description

Data acquisition method, gateway and data acquisition system for sensor network

technical field

The invention relates to the field of wireless sensor network communication, in particular to a sensor network data acquisition method, gateway and data acquisition system.

Background technique

As an important part of the Internet of Things, the sensor network plays a role in obtaining information about the physical world and transmitting it to the background server. The basic process of information collection and transmission is: the sensor nodes in the sensor network collect information, and transmit the collected information to the aggregation node (or gateway) through the pre-built sensor network, and the gateway performs preliminary processing (such as data compression). After integration or protocol conversion), upload to the background server.

In some scenarios, multiple sensor nodes in the collection area are divided into different types to collect different types of data respectively. After comparing and analyzing multiple types of data in the background, a more reliable judgment can be made, and a decision can be made based on the situation in the monitoring area. Treat accordingly. When multiple sensor nodes are divided into different types, different gateways are generally used to receive information collected by various types of sensors, and the information received by different gateways is transmitted to the background for analysis, and the monitoring area is processed accordingly. In this method, because different data collected are processed by different gateways, different gateways cannot cooperate with each other, and the function of the gateway is single, only doing data protocol conversion and uploading work, there is no selectivity for data uploading, and different gateways Due to the asynchronous frequency of data processing and uploading, etc., it is possible to process and upload the data in the monitoring area at different times. It is difficult for the background to compare and analyze different types of data, and there will be time delay errors, which will affect the processing decision. .

Contents of the invention

The purpose of the present invention is to provide a sensor network data acquisition method, gateway and data acquisition system, so that the background server can analyze the data collected by different sensors and improve the accuracy of the analysis results.

In order to achieve the above object, the present invention provides a data collection method for a sensor network, the sensor network includes a plurality of sensor nodes, and the data collection method includes:

Comparing the change amount of the received data sent by each sensor node within the preset time period with the corresponding preset value;

Judging whether there is data whose variation reaches the corresponding preset value;

The collection frequency of the sensor nodes corresponding to the data whose change amount reaches the corresponding preset value is increased to the first collection frequency.

Preferably, the data collection method further includes synchronously performing the step of increasing the collection frequency of the sensor node corresponding to the data whose change amount reaches a corresponding preset value to the first collection frequency:

The collection frequency of the sensor nodes corresponding to the data whose change amount does not reach the corresponding preset value is reduced to a second collection frequency.

Preferably, after the step of increasing the collection frequency of the sensor nodes corresponding to the data whose variation reaches the corresponding preset value to the first collection frequency, it further includes:

In the same upload cycle, upload the received data sent by each sensor node to the server; where,

When the collection frequency of some sensor nodes is the first collection frequency and the collection frequency of another part of the sensor nodes is the second collection frequency, upload data at the first upload speed, and within the same upload cycle, upload data at the first The data collected at the collection frequency is uploaded prior to the data collected at the second collection frequency;

When the collection frequencies of all sensor nodes are the first collection frequency, upload data at a second upload speed, where the second upload speed is greater than the first upload speed.

Preferably, the collection method also includes:

When the collection frequency of all sensor nodes is the first collection frequency, an alarm signal is sent to the terminal device.

Correspondingly, the present invention also provides a gateway, and the gateway includes:

A receiving module, configured to receive data sent by a plurality of sensor nodes in the sensor network;

A comparison module, the comparison module is connected to the receiving module, and is used to compare the variation of the received data sent by each sensor node within a preset time period with the corresponding preset value;

A judgment module, the judgment module is connected to the comparison module, and is used to judge whether there is data whose variation reaches a corresponding preset value according to the comparison result of the comparison module, and if so, the judgment module sends a first judgment signal;

a control module, the control module is used to send control signals to all sensor nodes to control the acquisition frequency of the sensor nodes, the control module is connected to the judgment module to receive the first judgment signal, the control The signal includes a first control signal sent when the control module receives the first determination signal, and the first control signal is used to control the collection frequency of the sensor node corresponding to the data whose change amount reaches a corresponding preset value Increase to the first acquisition frequency.

Preferably, when the receiving module receives the data of each sensor node, there are data in which the amount of change within the preset time period does not reach the corresponding preset value, and data in which the amount of change in the preset time period reaches the corresponding preset value , the control module can send out a second control signal at the same time as sending out the first control signal, and the second control signal is used to control the The collection frequency is reduced to a second collection frequency.

Preferably, the gateway further includes an upload module, which is respectively connected to the receiving module and the control module, and is used to respectively upload the data sent by each sensor node received by the receiving module in the same upload cycle uploaded to the server, where,

When the control module sends the first control signal and the second control signal at the same time, the upload module can upload data at the first upload speed, and within the same upload cycle, the data collected at the first collection frequency uploading prior to the data collected at the second collection frequency;

When the control module controls the collection frequency of all sensor nodes to increase to the first collection frequency, the upload module can upload the data collected at the first collection frequency at a second upload speed, and the second upload speed greater than the first upload speed.

Preferably, the gateway also includes:

An alarm module, which is connected to the control module and used to send an alarm signal to the terminal device when the control module controls the collection frequencies of all sensor nodes to increase to the first collection frequency.

Preferably, the alarm module includes:

A signal generation submodule, which is connected to the control module and used to generate an alarm signal when the control module controls the acquisition frequencies of all sensor nodes to increase to the first acquisition frequency;

A signal communication submodule, which is connected to the signal generation submodule and used to send the alarm signal generated by the signal generation submodule to the terminal device.

Correspondingly, the present invention also provides a data acquisition system, including a sensor network, a gateway, and a server, the sensor network includes a plurality of sensor nodes, the gateway is the above-mentioned gateway provided by the present invention, and the control module can issue a control A control signal of the collection frequency of the sensor node, the control signal includes a first control signal, and when the sensor node receives the first control signal, the sensor node can perform data collection at the first collection frequency.

In the present invention, the collection frequency of the sensor nodes can be controlled according to whether the variation of the data collected by the sensor nodes within the preset time period reaches the preset value (that is, whether there is a large fluctuation in the data), thereby improving the background The accuracy of the server's judgment on the environment of the monitoring area, and the same gateway can be used to control the collection frequency of multiple sensor nodes at the same time, so there will be no asynchronous data processing and uploading data between different types of gateways. It is beneficial for the background server to analyze and process data, reduce delay errors, and help the background server to make accurate processing decisions.

Description of drawings

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

FIG. 1 is a schematic diagram of a method for collecting data collected by multi-type sensor nodes provided in an embodiment of the present invention;

Fig. 2 is the structural representation of data acquisition system in the application example of the present invention;

Fig. 3 is a schematic structural diagram of a gateway provided in an embodiment of the present invention.

Wherein, reference sign is:

1. Gateway; 11. Receiving module; 12. Comparison module; 13 Judgment module; 14. Control module; 15. Upload module; 16. Alarm module; 2. Server; 3. Sensor network; 31. Temperature sensor node; 32. Oxygen sensor node.

detailed description

Specific embodiments of the present invention will be described in detail below in conjunction with the accompanying drawings. It should be understood that the specific embodiments described here are only used to illustrate and explain the present invention, and are not intended to limit the present invention.

As an aspect of the present invention, a data collection method of a sensor network is provided, the sensor network includes a plurality of sensor nodes, as shown in Figure 1, the data collection method includes:

S1. Comparing the change amount of the received data sent by each sensor node within the preset time period with the corresponding preset value;

S2. Judging whether there is data whose variation reaches a corresponding preset value;

S3. Increase the collection frequency of the sensor nodes corresponding to the data whose change amount reaches a corresponding preset value to a first collection frequency.

The plurality of sensor nodes may be set in the area to be monitored to collect data at different positions in the area to be monitored, wherein the types of the plurality of sensor nodes may be the same or different. In order to monitor different parameters in the monitoring area, a plurality of sensors can be divided into different types, as shown in Figure 2, a plurality of temperature sensor nodes 31 and a plurality of oxygen content sensor nodes 32 can be included in the sensor network to treat them separately The temperature, oxygen content and humidity of the monitoring area are used for data collection, and the gateway 1 provides the collected data to the background server 2, so that the server 2 can judge the environment of the area to be monitored according to the collected data, for example, to determine whether the area to be monitored has Emergency events such as fire or chemical waste dumping, so as to make further processing decisions.

In step S1, each sensor node can be set to collect data at an initial collection frequency, and the initial collection frequency can be set according to specific collection requirements, for example, 3 times per second. When the amount of change in the data sent by a certain sensor node reaches a corresponding preset value within a preset time period, it indicates that the data fluctuates greatly. For example, for the temperature information collected by the temperature sensor node, when the temperature fluctuates greatly, it indicates that the temperature in the monitoring area is abnormal. At this time, the collection frequency of the temperature sensor node can be controlled to increase to continue collecting data, for example, Increase from 3 times per second to 4 times per second, so that the server can obtain more abnormal data, and then make accurate judgments and processing decisions. When each data does not reach the corresponding preset value within the preset time period, it indicates that there is no abnormality in each data, or that the abnormal data has returned to normal. At this time, each sensor node maintains the original initial acquisition frequency and continues Just collect it.

In the present invention, the collection frequency of the sensor nodes can be controlled according to whether the variation of the data collected by the sensor nodes within the preset time period reaches the preset value (that is, whether there is a large fluctuation in the data), thereby improving the background The accuracy of the server's judgment on the environment of the monitoring area, and the same gateway can be used to control the collection frequency of multiple sensor nodes at the same time, so there will be no asynchronous data processing and uploading data between different types of gateways. It is beneficial for the background server to analyze and process data, reduce delay errors, and help the background server to make accurate processing decisions.

The specific value of the preset time period can be determined according to actual needs, but at least two data collections should be included, for example, the preset time period is 1 second or the time interval between two adjacent data collections. When multiple sensor nodes are classified into different types, the preset values corresponding to different types of data may be different. For example, for the temperature collected by the temperature sensor node, when the temperature change reaches 15° within the preset time period, it indicates that the temperature fluctuates greatly; for the oxygen content sensor node, when the oxygen content is within the preset time period When the variation within reaches 20%, it indicates that the oxygen content fluctuates greatly.

In order to ensure the data processing efficiency of the gateway, preferably, the data collection method further includes synchronously performing with step S2:

The collection frequency of the sensor nodes corresponding to the data whose change amount does not reach the corresponding preset value is reduced to the second collection frequency. Of course, if the variation of data collected by all sensor nodes within a predetermined time period reaches a corresponding preset value, then it is sufficient to increase the collection frequency of all sensor nodes to the first collection frequency.

For example, the sensor network includes multiple temperature sensor nodes, and each temperature sensor node collects temperature at an initial collection frequency of 3 times per second. When the temperature collected by multiple temperature sensor nodes in a certain area reaches the trigger condition (large fluctuation ), the collection frequency of multiple temperature sensor nodes controlling this area is increased, for example, up to 4 times per second, and at the same time, the collection frequency of multiple temperature sensor nodes controlling other areas is reduced, such as up to 2 times per second. For another example, two types of sensor nodes are set in the sensor network to collect two types of data, and when one type of data reaches a trigger condition, the collection frequency of the sensor node of this type is controlled to increase to the first one collection frequency, and control the collection frequency of another type of sensor node to be reduced to the second collection frequency, so as to ensure the data processing efficiency. Both the first collection frequency and the second collection frequency can be set in advance.

Further, as shown in Figure 1, after the step S3, it also includes:

S4. In the same upload cycle, upload the received data sent by each sensor node to the server. Wherein, when the collection frequency of some sensor nodes is the first collection frequency and the collection frequency of another part of the sensor nodes is the second collection frequency, the data is uploaded at the first upload speed, and within the same upload period, the data is uploaded at the The data collected by the first collection frequency is uploaded before the data collected by the second collection frequency, so that the server preferentially processes the data meeting the trigger condition; when the collection frequencies of all sensor nodes are the first collection frequency, the second Uploading data at an uploading speed, the second uploading speed is greater than the first uploading speed, so that the gateway can still upload data to the server in time when receiving more data.

Usually, when the data received by the gateway is uploaded to the server, the data is first packaged, and then these data packages are uploaded to the server according to certain rules. For example, the sensor network includes multiple temperature sensor nodes and multiple oxygen sensor nodes, and the upload rule is: in each upload cycle, first upload two temperature data packets, and then upload two oxygen content data packets, or , first upload two oxygen content data packets, and then upload two temperature data packets; when the temperature data collected by the temperature sensor node fluctuates greatly within the preset time period, control the temperature sensor node to collect temperature data at the first collection frequency , and at the same time control the oxygen content sensor node to collect oxygen content data at the second collection frequency. At this time, the upload rule is: upload three temperature data packets first in each upload cycle, and then upload one oxygen content data packet; when two When the temperature data collected by two types of sensor nodes fluctuate greatly within the preset time period, both types of sensor nodes are controlled to collect data at the first collection frequency. At this time, the upload rule is: within each upload cycle Upload two temperature data packets, two oxygen content data packets, two temperature data packets, and two oxygen content data packets in sequence.

Further, the collection method also includes:

When the collection frequency of all sensor nodes is the first collection frequency, an alarm signal is sent to the terminal device.

Taking the two types of sensor nodes (temperature sensor node and oxygen content sensor node) mentioned above as an example, when the data collected by the two types of sensor nodes meet the corresponding trigger conditions, that is, the temperature data and the oxygen content sensor node When the volume data fluctuates greatly within the preset time period, it indicates that there is a large destructive behavior in the detection area. In this case, an alarm signal is sent to the terminal device to remind the background staff to pay attention to the change of data.

As another aspect of the present invention, a gateway is provided. As shown in FIG. 3, the gateway includes:

The receiving module 11 is used for the data sent by a plurality of sensor nodes in the sensor network;

A comparison module 12, the comparison module 12 is connected with the receiving module 11, and is used to compare the variation of the received data sent by each sensor node within the preset time period with the corresponding preset value;

Judging module 13, judging module 13 is connected with comparison module 12, is used for judging whether there is the data that reaches corresponding trigger condition according to the comparison result of comparing module 12, if so, judging module sends the first judgment signal;

Control module 14, control module 13 is used for sending the control signal that controls the acquisition frequency of described sensor node to all sensor nodes, and control module 14 is connected with judgment module 12, to receive described first judgment signal, and described control signal includes When the control module 14 receives the first determination signal, the first control signal is sent, and the first control signal is used to control the collection frequency of the sensor node corresponding to the data whose variation reaches the corresponding preset value to increase to the first 1. Collection frequency.

Further, when the data of each sensor node received by the receiving module 11 simultaneously has data whose amount of change within the preset time period reaches the corresponding preset value, and data whose amount of change in the preset data segment reaches the corresponding preset value , the control module 13 can send out the second control signal at the same time as sending out the first control signal, and the second control signal is used to control the collection of sensor nodes corresponding to the data whose change amount does not reach the corresponding preset value The frequency is reduced to the second collection frequency, so as to prevent the receiving module from receiving too much data and affecting the processing efficiency.

Further, the gateway also includes an upload module 15, the upload module 15 is connected to the receiving module 11 and the control module 14 respectively, and is used to upload the data sent by each sensor node received by the receiving module 11 to the server. Wherein, when the control module 14 sends the first control signal and the second control signal at the same time, the upload module 15 can upload data at the first upload speed, and within the same upload cycle, the data collected at the first collection frequency Prior to uploading the data collected at the second collection frequency; when the control module 14 controls the collection frequency of all sensor nodes to increase to the first collection frequency, the upload module 15 can upload at the second upload speed and collect at the first collection frequency data, the second upload speed is greater than the first upload speed.

Further, as shown in Figure 3, the gateway also includes:

Alarm module 16, the alarm module 16 is connected with the control module 14, and is used to send an alarm signal to the terminal equipment when the collection frequency of all sensor nodes controlled by the control module 14 is increased to the first collection frequency, so as to remind the background staff.

Specifically, the alarm module 16 may include: a signal generation submodule and a signal communication submodule, the signal generation submodule is connected with the control module 14, and is used to control the collection frequency of all sensor nodes in the control module 14 to increase to the first An alarm signal is generated when the frequency is collected; the signal communication sub-module is connected to the signal generation sub-module, and is used to send the alarm signal generated by the signal generation sub-module to the terminal equipment.

The signal generation sub-module may be a structure capable of generating alarm signals such as a data card, and the signal communication sub-module may be a structure such as a wireless communication card. The alarm signal can be an image signal that can be displayed on the terminal device or an audio signal that can be played on the terminal device.

As another aspect of the present invention, a kind of data acquisition system is provided, comprising above-mentioned gateway 1 provided by the present invention, sensor network 3 and server 2, sensor network 3 comprises a plurality of sensor nodes, and the control module 14 of gateway 1 can issue control A control signal of the collection frequency of the sensor node, where the control signal includes a first control signal, and when the sensor node receives the first control signal, the sensor node can perform data collection at the first collection frequency.

In an application embodiment, as shown in Figure 2, a plurality of temperature sensor nodes 31 and a plurality of oxygen content sensor nodes 32 are set in the sensor network 3, and the data collection method includes:

S101. The receiving module of the gateway 1 receives data collected by each sensor node at an initial collection frequency, for example, the initial collection frequency is 3 times per second;

S102. Comparing the amount of change in the data collected by each sensor node within a predetermined time period with a corresponding preset value;

S103. When the amount of change of the data collected by the first type of sensor node within the preset time period reaches the corresponding preset value, the amount of change of the data collected by the second type of sensor node within the preset time period does not reach the corresponding preset value. When the preset value, execute step S104a; when the variation of the data collected by the two types of sensor nodes within the preset time period reaches the corresponding preset value, execute step S104b; when the data collected by the two types of sensor nodes When the variation of the data within the preset time period does not reach the preset value, step S104c is executed;

S104a. Control the collection frequency of the sensor nodes of the first type to increase to the first collection frequency (for example, 4 times per second), and control the collection frequency of the sensor nodes of the second type to decrease to the second collection frequency (for example, every 2 times per second);

After the two types of sensor nodes collect data again at the first collection frequency and the second collection frequency, they upload the two types of data to the server 2 at the first upload speed, and upload the first collection data in each upload cycle. Frequency of collected data;

S104b. Control the collection frequencies of the two types of sensor nodes to increase to the first collection frequency;

After the two types of sensor nodes collect data again with the first collection frequency, the two types of data are uploaded to the server 2 at the second upload speed, and the second upload speed is greater than the first upload speed; Send an alarm signal;

S104c, controlling the collection frequencies of the two types of sensor nodes to maintain the initial collection frequency;

Two types of data are uploaded to the server 2 at the first upload speed.

It can be understood that, the above embodiments are only exemplary embodiments adopted for illustrating the principle of the present invention, but the present invention is not limited thereto. For those skilled in the art, various modifications and improvements can be made without departing from the spirit and essence of the present invention, and these modifications and improvements are also regarded as the protection scope of the present invention.

Claims (10)

1. a data collection method of sensor network, described sensor network comprises a plurality of sensor nodes, it is characterized in that, described data collection method comprises: Comparing the change amount of the received data sent by each sensor node within the preset time period with the corresponding preset value; Judging whether there is data whose variation reaches the corresponding preset value; The collection frequency of the sensor nodes corresponding to the data whose change amount reaches the corresponding preset value is increased to the first collection frequency. 2. The data acquisition method according to claim 1, characterized in that, the data acquisition method also includes increasing the acquisition frequency of the sensor node corresponding to the data whose amount of change reaches the corresponding preset value to the first A frequency acquisition step is performed synchronously: The collection frequency of the sensor nodes corresponding to the data whose change amount does not reach the corresponding preset value is reduced to a second collection frequency. 3. The data acquisition method according to claim 2, characterized in that, after the step of increasing the acquisition frequency of the sensor node corresponding to the data whose variation reaches the corresponding preset value to the first acquisition frequency, include: In the same upload cycle, upload the received data sent by each sensor node to the server; where, When the collection frequency of some sensor nodes is the first collection frequency and the collection frequency of another part of the sensor nodes is the second collection frequency, upload data at the first upload speed, and within the same upload cycle, upload data at the first The data collected at the collection frequency is uploaded prior to the data collected at the second collection frequency; When the collection frequencies of all sensor nodes are the first collection frequency, upload data at a second upload speed, where the second upload speed is greater than the first upload speed. 4. the data collection method according to claim 3, is characterized in that, described collection method also comprises: When the collection frequency of all sensor nodes is the first collection frequency, an alarm signal is sent to the terminal device. 5. A gateway, characterized in that the gateway comprises: A receiving module, configured to receive data sent by a plurality of sensor nodes in the sensor network; A comparison module, the comparison module is connected to the receiving module, and is used to compare the variation of the received data sent by each sensor node within a preset time period with the corresponding preset value; A judgment module, the judgment module is connected to the comparison module, and is used to judge whether there is data whose variation reaches a corresponding preset value according to the comparison result of the comparison module, and if so, the judgment module sends a first judgment signal; a control module, the control module is used to send control signals to all sensor nodes to control the acquisition frequency of the sensor nodes, the control module is connected to the judgment module to receive the first judgment signal, the control The signal includes a first control signal sent when the control module receives the first determination signal, and the first control signal is used to control the collection frequency of the sensor node corresponding to the data whose change amount reaches a corresponding preset value Increase to the first acquisition frequency. 6. The gateway according to claim 5, characterized in that, when the receiving module receives the data of each sensor node, there is also data in which the amount of change within the preset time period does not reach the corresponding preset value, the preset time When the amount of change in the segment reaches the data corresponding to the preset value, the control module can send out a second control signal while sending out the first control signal, and the second control signal is used to control that the amount of change does not reach The collection frequency of the sensor nodes corresponding to the data corresponding to the preset value is reduced to the second collection frequency. 7. The gateway according to claim 6, characterized in that, the gateway further comprises an upload module, which is respectively connected to the receiving module and the control module, and is used to upload the The data sent by each sensor node received by the receiving module is uploaded to the server, wherein, When the control module sends the first control signal and the second control signal at the same time, the upload module can upload data at the first upload speed, and within the same upload cycle, the data collected at the first collection frequency uploading prior to the data collected at the second collection frequency; When the control module controls the collection frequency of all sensor nodes to increase to the first collection frequency, the upload module can upload the data collected at the first collection frequency at a second upload speed, and the second upload speed greater than the first upload speed. 8. The gateway according to claim 7, wherein the gateway further comprises: An alarm module, which is connected to the control module and used to send an alarm signal to the terminal device when the control module controls the collection frequencies of all sensor nodes to increase to the first collection frequency. 9. The gateway according to claim 8, wherein the alarm module comprises: A signal generation submodule, which is connected to the control module and used to generate an alarm signal when the control module controls the acquisition frequencies of all sensor nodes to increase to the first acquisition frequency; A signal communication submodule, which is connected to the signal generation submodule and used to send the alarm signal generated by the signal generation submodule to the terminal equipment. 10. A data acquisition system comprising a sensor network, a gateway and a server, the sensor network comprising a plurality of sensor nodes, characterized in that the gateway is the gateway according to any one of claims 5 to 9, the The control module can send a control signal for controlling the collection frequency of the sensor node, the control signal includes a first control signal, and when the sensor node receives the first control signal, the sensor node can use the first collection frequency frequency of data collection.