Distributed load processing using forecasted location-based internet of things device clusters

Patent metadata

Field	Value
Publication number	US-10244054-B2
Application number	US-201815896670-A
Country	US
Kind code	B2
Filing date	Feb 14, 2018
Priority date	Feb 11, 2016
Publication date	Mar 26, 2019
Grant date	Mar 26, 2019

Abstract

For distributed processing using forecasted location-based IoT device clusters, at a central IoT device, a data source that is to be used and a duration for processing a workload is determined. A set of IoT devices operating within a threshold distance from the data source at a first time is selected. A subset of the set is selected to form a sub-cluster of IoT devices where a forecasted travel path of a member IoT device in the subset keeps the member within the threshold distance from the data source for the duration. A lightweight application is configured at a first IoT device in the subset which enables the first IoT device to participate in the sub-cluster and process the workload.

First claim

What is claimed is:

1. A method for distributed processing using forecasted location-based Internet of Things (IoT) device clusters, the method comprising:
determining, using a processor and a memory at a central IoT device, a data source that is to be used for processing a workload;
computing a duration needed to process the workload;
selecting a set of IoT devices that are operating within a threshold distance from the data source at a first time;
selecting, at the central IoT device, to form a sub-cluster of IoT devices, a subset of the set of IoT devices, wherein a forecasted travel path of a member IoT device in the subset keeps the member IoT device within the threshold distance from the data source for the duration; and
instructing the processor at the central IoT device to configure a lightweight application at a first IoT device in the subset of IoT devices, the lightweight application enabling the first IoT device to participate in the sub-cluster and process the workload.

2. The method of claim 1 , further comprising:
configuring the first IoT device in a high-availability configuration with a second IoT device in the sub-cluster, the subset of IoT devices including the second IoT device.

3. The method of claim 1 , further comprising:
dropping, responsive to determining at a second time that the first IoT device has moved to a distance greater than the threshold distance from the data source, the first IoT device from the sub-cluster;
joining a second IoT device to the sub-cluster, wherein the second IoT device has moved within the threshold distance from the data source at the second time, wherein the second IoT device satisfies a clustering condition, and wherein a forecasted travel path of the second IoT device keeps the second IoT device within the threshold distance from the data source for a remainder of the duration after the second time; and
transferring the processing of the workload from the first IoT device to the second IoT device.

4. The method of claim 1 , further comprising:
determining that the first IoT device satisfies a clustering condition, wherein the clustering condition comprises determining whether the first IoT device has a particular amount of a particular computing resource available and unused over the duration during which the workload has to be processed.

5. The method of claim 1 , further comprising:
determining that the first IoT device satisfies a clustering condition, wherein the clustering condition comprises determining whether the first IoT device has a permission to make a particular computing resource available over the duration during which the workload has to be processed.

6. The method of claim 1 , further comprising:
determining that the first IoT device satisfies a clustering condition, wherein the clustering condition comprises determining whether the first IoT device produces a response to a benchmark workload where a recall value of the response exceeds a threshold.

7. The method of claim 1 , further comprising:
selecting historical performance data corresponding to the first IoT device, wherein the historical performance data relates to a previous workload processed using the first IoT device, and wherein the previous workload includes a characteristic similar to the workload; and
determining that the first IoT device satisfies a clustering condition, wherein the clustering condition comprises determining whether a recall value in the historical performance data exceeds a threshold.

8. The method of claim 1 , further comprising:
determining that the first IoT device satisfies a clustering condition, wherein the clustering condition comprises determining whether the first IoT device produces a response to a benchmark workload where a precision value of the response exceeds a threshold.

9. The method of claim 1 , further comprising:
selecting historical performance data corresponding to the first IoT device, wherein the historical performance data relates to a previous workload processed using the first IoT device, and wherein the previous workload includes a characteristic similar to the workload; and
determining that the first IoT device satisfies a clustering condition, wherein the clustering condition comprises determining whether a precision value in the historical performance data exceeds a threshold.

10. The method of claim 1 , further comprising:
determining that the first IoT device satisfies a clustering condition, wherein the clustering condition comprises determining whether the first IoT device produces a response to a benchmark workload within a threshold amount of time.

11. The method of claim 1 , further comprising:
selecting historical performance data corresponding to the first IoT device, wherein the historical performance data relates to a previous workload processed using the first IoT device, and wherein the previous workload includes a characteristic similar to the workload; and
determining that the first IoT device satisfies a clustering condition, wherein the clustering condition comprises determining whether a response time in the historical performance data exceeds a threshold amount of time.

12. The method of claim 1 , further comprising:
decomposing the workload into a set of workload components, wherein a first workload component is at the threshold distance from the data source and a second workload component is at a second threshold distance from a second data source, and wherein assigning the workload to the sub-cluster comprises assigning the first workload component to the sub-cluster.

13. The method of claim 1 , wherein the threshold distance comprises a geographical distance on a geographical map, and wherein the threshold distance defines a shaped area on the geographical map.

14. The method of claim 1 , wherein the threshold distance comprises a number of hops in a data network.

15. The method of claim 1 , further comprising:
determining, using publications from the set of IoT devices on a social media platform, the locations of the IoT devices in the set of IoT devices; and
determining that each of the locations is within the threshold distance from the data source at the first time.

16. The method of claim 1 , wherein the method is embodied in a computer program product comprising one or more computer-readable storage devices and computer-readable program instructions which are stored on the one or more computer-readable tangible storage devices and executed by one or more processors.

17. The method of claim 1 , wherein the method is embodied in a computer system comprising one or more processors, one or more computer-readable memories, one or more computer-readable storage devices and program instructions which are stored on the one or more computer-readable storage devices for execution by the one or more processors via the one or more memories and executed by the one or more processors.

18. A computer program product for distributed processing using forecasted location-based Internet of Things (IoT) device clusters, the computer program product comprising one or more computer-readable storage devices, and program instructions stored on at least one of the one or more storage devices, the stored program instructions comprising:
program instructions to determine, using a processor and a memory at a central IoT device, a data source that is to be used for processing a workload;
program instructions to compute a duration needed to process the workload;
program instructions to select a set of IoT devices that are operating withi

Assignees

• IBM

Inventors

• Baughman Aaron K
• Harrison Thomas Benjamin
• O'Connell Brian M
• Pearthree Herbert D

Classifications

• H04L67/12 Primary

  specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks · CPC title

• H04W4/70

  Services for machine-to-machine communication [M2M] or machine type communication [MTC] · CPC title

• G06Q10/101

  Collaborative creation, e.g. joint development of products or services · CPC title

• G06F9/505

  considering the load · CPC title

• H04W4/08

  User group management · CPC title