Data aggregation in the internet of things
Data aggregation in an internet of things (IoT) system refers generally to collecting data such that the data can be processed in a useful manner. Existing approaches to data aggregation in IoT systems, such as a system including a network of sensors for example, often focus on network logical topology and data transmission scheduling and routing schemes. An IoT system can aggregate data at an application-protocol layer. For example, an IoT node in an IoT system can send a data aggregation request message that is capable of retrieving data from a plurality of different applications. In response, the IoT node may receive data that is representative of a set of nodes that are located downstream in the IoT system from the IoT node.
1. In a system comprising a plurality of devices that include an intermediary node comprising a sensor that communicates with at least some of the plurality of devices via a network, a method comprising, at the intermediary node:
sending a data aggregation request message to retrieve data from a plurality of different applications, the data aggregation request message comprising an aggregation rule;
in response to the data aggregation request message, receiving a data aggregation response message that comprises an aggregation group identity and data representative of a set of the plurality of devices, the received data in compliance with the aggregation rule, wherein the set is located downstream in the system from the intermediary node, and the data aggregation request message is an application-protocol layer message;
based on the aggregation rule, calculating one of a maximum, minimum, or average value associated with one of the devices in the set of the plurality of devices, the data representative of the set of the plurality of devices including the one of the maximum, minimum, or average value;
generating sensory data;
aggregating the sensory data with the data representative of the set of the plurality of devices to create an aggregation result;
creating a new data aggregation response message that includes the aggregation result; and
sending the new data aggregation response message to at least one device of the plurality of devices, the at least one device located upstream in the system from the intermediary node.
2. The method as recited in claim 1 , wherein the data aggregation request message further comprises, and the received data representative of the set of the plurality of devices is based on, the aggregation group identity.
3. The method as recited in claim 1 , the method further comprising:
determining whether there is a data aggregation request header that includes the aggregation group identity; and
if there is no data aggregation request header that includes the aggregation group identity, forwarding the data aggregation request message to at least one device of the plurality of devices, the at least one device located upstream in the system from the intermediary node.
4. The method as recited in claim 3 , wherein the data aggregation response message indicates at least one of one or more critical nodes, a number of aggregated data, a list of aggregators, or a length of data items.
5. The method as recited in claim 1 , the method further comprising:
based on the aggregation result, forwarding the data aggregation request message to at least one device of the plurality of devices, the at least one device located upstream in the system from the intermediary node, whereby the data representative of the set of the plurality of devices is unchanged by the aggregation result.
6. The method as recited in claim 1 , the method further comprising:
based on the aggregation rule and in response to the sensory data, replacing the one of the maximum, minimum, or average value with a new maximum, minimum, or average value; and
sending a new maximum, minimum, or average value to at least one device located upstream in the system from the intermediary node.
7. A network node in a network of connected nodes, the network node comprising:
a sensor;
a first processor adapted to execute computer-readable instructions; and
a first memory communicatively coupled to said first processor, said first memory having stored therein computer-readable instructions that, when executed by the first processor, cause the processor to perform operations comprising:
sending a data aggregation request message to retrieve data from a plurality of different applications, the data aggregation request message comprising an aggregation rule;
in response to the data aggregation request message, receiving a data aggregation response message that comprises an aggregation group identity and data representative of a set of the connected nodes, the received data in compliance with the aggregation rule, wherein the set is located downstream in the system from the network node, and the data aggregation request message is an application-protocol layer message;
based on the aggregation rule, calculating one of a maximum, minimum, or average value associated with one of the nodes in the set of the connected nodes, the data representative of the set of the connected nodes including the one of the maximum, minimum, or average value;
generating sensory data;
aggregating the sensory data with the data representative of the set of the connected nodes to create an aggregation result;
creating a new data aggregation response message that includes the aggregation result; and
sending the new data aggregation response message to at least one node in the network of connected nodes, the at least one node located upstream in the system from the intermediary node.
8. The network node as recited in claim 7 , wherein the data aggregation request message further comprises the aggregation group identity, and the data representative of the set of the connected nodes is based on the aggregation group identity.
9. The network node as recited in claim 7 , the operations further comprising:
determining whether there is a data aggregation request header that includes the aggregation group identity; and
if there is no data aggregation request header that includes the aggregation group identity, forwarding the data aggregation request message to at least one node in the network of connected nodes, the at least one node located upstream in the network from the network node.
10. The network node as recited in claim 9 , wherein the data aggregation response message indicates at least one of one or more critical nodes, a number of aggregated data, a list of aggregators, or a length of data items.
11. The network node as recited in claim 7 , the operations further comprising:
based on the aggregation result, forwarding the data aggregation request message to at least one in the network of connected nodes, the at least one node located upstream in the network from the network node, whereby the data representative of the set of the connected nodes is unchanged by the aggregation result.
12. The network node as recited claim 7 , the method further comprising:
based on the aggregation rule and in response to the sensory data, replacing the one of the maximum, minimum, or average value with a new maximum, minimum, or average value; and
sending a new maximum, minimum, or average value to at least one node located upstream in the network from the network node.