Coordinated device grouping in fog computing
An augmented connection graph can be created based on a task to be performed by a fog computing node by augmenting a connection graph representing plurality of IoT devices and connections among them. The augmenting can include adding to the connection graph data type nodes representing types of data processed by the fog computing node and adding connections between the data type nodes and IoT devices that generate the type of data represented by the respective data type nodes. A connection can be added between each pair of the IoT devices that are not currently connected and for which a level of correlation between the pair of IoT devices at least equals a threshold value. Based on the augmented connection graph, at least one of the IoT devices to assign to the fog computing node can be determined and assigned to the fog computing node.
1. A method, comprising:
automatically creating an augmented connection graph based on a task to be performed by a particular fog computing node by augmenting a connection graph representing plurality of Internet of Things (IoT) devices and connections among the plurality of IoT devices, augmenting the connection graph comprising:
adding to the connection graph a plurality of data type nodes, each of the plurality of data type nodes representing a respective type of data processed by the particular fog computing node; and
for each of the plurality of data type nodes, adding to the connection graph a connection between the data type node and each of the plurality of IoT devices that generate the type of data represented by that data type node;
automatically adding to the augmented connection graph a connection between each pair of the IoT devices that are not currently connected and for which a level of correlation between the pair of IoT devices at least equals a threshold value;
based on the augmented connection graph, automatically determining at least one of the plurality of IoT devices to assign to the particular fog computing node; and
automatically assigning, using a processor, the at least one of the plurality of IoT devices to the particular fog computing node.
2. The method of claim 1 , further comprising:
automatically initiating creation communication links between each pair of the IoT devices that are not currently connected and for which a level of correlation between the pair of IoT devices at least equals a threshold value.
3. The method of claim 1 , further comprising:
determining at least one pair of IoT devices that currently are connected and for which the level of correlation between that pair of IoT devices is below the threshold value; and
indicating in the augmented connection graph that a communication link between the at least one pair of IoT devices should be removed.
4. The method of claim 3 , further comprising:
automatically initiating removal of a communication link between the at least one pair of IoT devices that currently are connected and for which the level of correlation between that pair of IoT devices is below the threshold value.
5. The method of claim 1 , wherein the level of correlation between the pair of IoT devices is determined, based at least in part, on a proximity of the pair of IoT devices to one another.
6. The method of claim 1 , wherein the level of correlation between the pair of IoT devices is determined, based at least in part, on a signal strength between the pair of IoT devices.
7. The method of claim 1 , wherein the level of correlation between the pair of IoT devices is determined, based at least in part, on types of data generated or communicated by each of the pair of IoT devices.
8. A system, comprising:
a processor programmed to initiate executable operations comprising:
automatically creating an augmented connection graph based on a task to be performed by a particular fog computing node by augmenting a connection graph representing plurality of Internet of Things (IoT) devices and connections among the plurality of IoT devices, augmenting the connection graph comprising:
adding to the connection graph a plurality of data type nodes, each of the plurality of data type nodes representing a respective type of data processed by the particular fog computing node; and
for each of the plurality of data type nodes, adding to the connection graph a connection between the data type node and each of the plurality of IoT devices that generate the type of data represented by that data type node;
automatically adding to the augmented connection graph a connection between each pair of the IoT devices that are not currently connected and for which a level of correlation between the pair of IoT devices at least equals a threshold value;
based on the augmented connection graph, automatically determining at least one of the plurality of IoT devices to assign to the particular fog computing node; and
automatically assigning the at least one of the plurality of IoT devices to the particular fog computing node.
9. The system of claim 8 , the executable operations further comprising:
automatically initiating creation communication links between each pair of the IoT devices that are not currently connected and for which a level of correlation between the pair of IoT devices at least equals a threshold value.
10. The system of claim 8 , the executable operations further comprising:
determining at least one pair of IoT devices that currently are connected and for which the level of correlation between that pair of IoT devices is below the threshold value; and
indicating in the augmented connection graph that a communication link between the at least one pair of IoT devices should be removed.
11. The system of claim 10 , the executable operations further comprising:
automatically initiating removal of a communication link between the at least one pair of IoT devices that currently are connected and for which the level of correlation between that pair of IoT devices is below the threshold value.
12. The system of claim 8 , wherein the level of correlation between the pair of IoT devices is determined, based at least in part, on a proximity of the pair of IoT devices to one another.
13. The system of claim 8 , wherein the level of correlation between the pair of IoT devices is determined, based at least in part, on a signal strength between the pair of IoT devices.
14. The system of claim 8 , wherein the level of correlation between the pair of IoT devices is determined, based at least in part, on types of data generated or communicated by each of the pair of IoT devices.
15. A computer program product, comprising:
one or more computer readable storage mediums having program code stored thereon, the program code stored on the one or more computer readable storage mediums collectively executable by a data processing system to initiate operations including:
automatically creating an augmented connection graph based on a task to be performed by a particular fog computing node by augmenting a connection graph representing plurality of Internet of Things (IoT) devices and connections among the plurality of IoT devices, augmenting the connection graph comprising:
adding to the connection graph a plurality of data type nodes, each of the plurality of data type nodes representing a respective type of data processed by the particular fog computing node; and
for each of the plurality of data type nodes, adding to the connection graph a connection between the data type node and each of the plurality of IoT devices that generate the type of data represented by that data type node;
automatically adding to the augmented connection graph a connection between each pair of the IoT devices that are not currently connected and for which a level of correlation between the pair of IoT devices at least equals a threshold value;
based on the augmented connection graph, automatically determining at least one of the plurality of IoT devices to assign to the particular fog computing node; and
automatically assigning the at least one of the plurality of IoT devices to the particular fog computing node.
16. The computer program product of claim 15 , wherein the program code is executable by the data processing system to initiate operations further comprising:
automatically initiating creation communication links between each pair of the IoT devices that are not currently connected and for which a level of correlation between the pair of IoT devices at least equals a threshold value.
17. The computer program product of claim 15 , wherein the program code is executable by the data processing system to initiate operations further comprising:
determining at least one pair of IoT devices that currently are connected and for which the level of correlation between that pair of IoT devices is below the threshold value; and
indicating in the augmented connection graph that a communication link between the at least one pair of IoT devices should be removed.
18. The computer program product of claim 17 , wherein the program code is executable by the data processing system to initiate operations further comprising:
automatically initiating removal of a communication link between the at least one pair of IoT devices that currently are connected and for which the level of correlation between that pair of IoT devices is below the threshold value.
19. The computer program product of claim 15 , wherein the level of correlation between the pair of IoT devices is determined, based at least in part, on a proximity of the pair of IoT devices to one another.
20. The computer program product of claim 15 , wherein the level of correlation between the pair of IoT devices is determined, based at least in part, on a signal strength between the pair of IoT devices.