Platform for capturing, processing, storing, and presentation of generic sensor data from remote arbitrary locations

• US 10,382,294 B2
• Filed: 09/23/2015
• Issued: 08/13/2019
• Est. Priority Date: 09/25/2014
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Bali, Gurbinder Singh, Leahy-Dios, Filipe, Rodgers, Michael Patrick, Javed Lal Mohammed Ameerjan, Shoaib
• Primary Examiner(s): Mirza, Adnan M
• Application Number:
  US14/863,282
• Publication Number:
  US 20160094421A1
• Time in Patent Office: 1,420 Days
• Field of Search: 709223
• CPC Class Codes: H04L 41/022 Multivendor or multi-standard integration
• CPC Class Codes: H04L 41/14 Network analysis or design
• CPC Class Codes: H04L 43/04 Processing captured monitoring data, e.g. for logfile generation
• CPC Class Codes: H04L 67/12 specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
• CPC Class Codes: H04L 67/125 involving control of end-device applications over a network
• CPC Class Codes: H04L 67/56 Provisioning of proxy services store-and-forward switching systems in data switching networks H04L12/54
• CPC Class Codes: H04L 67/568 Storing data temporarily at an intermediate stage, e.g. caching
• CPC Class Codes: H04W 4/38 for collecting sensor information

Abstract

Disclosed is a method and mechanism to implement a unified infrastructure for handling IoT components and devices. A platform is provided to integrate, access, and control any type of local device, and to use any type of back-end application to processed collected data from the local devices.

Claims

1. A method for managing networked components, comprising:

managing data collection and analysis from a plurality of local networked components using a gateway device and a server device, the gateway device being coupled between the plurality of local networked components and the server device in a network, the gateway device comprising at least a processor and a memory;

receiving, at the gateway device, collected data from a local networked component of the plurality of local networked components, wherein the collected data is received from a front-end data collection module comprising custom code that is specific to handle data received from different types of local networked components, the custom code collecting data in a generic format from the different types of local networked components, wherein the collected data having the generic format collected from the different types of local networked components are pre-processed at the gateway device;

pre-processing, at the gateway device, the collected data by;

accessing gateway device rules to locally analyze the collected data from the local networked component;

identifying a localized action to take on the gateway device or on the local networked component, the localized action being taken in response to identification of a gateway device rules condition corresponding to the localized action;

generating first filtered data by applying one or more of the gateway device rules to the collected data, the first filtered data being smaller than the collected data; and

throttling transmission of the first filtered data to the server device to not overwhelm capacities of the network;

receiving, at the server device, the first filtered data;

processing, at the server device, the first filtered data received at least by;

generating second filtered data by applying server device rules to the first filtered data in a data pre-processing step, the second filtered data being smaller than the first filtered data; and

initiating downstream processing of the second filtered data in a post-processing step, the downstream processing of the second filtered data being taken in response to identification of a server device rules condition corresponding to the downstream processing.

2. The method of claim 1, wherein the collected data from a local networked component of the plurality of local networked components is received using a plurality of hardware-specific components of the gateway device, and respective hardware-specific components of the plurality of hardware-specific components supports one or more device types.

3. The method of claim 1, wherein the server device implements data storage rules to control location, storage frequency, or data transformation of the second filtered data when storing the second filtered data into a datastore.

4. The method of claim 1, wherein the gateway device selects from among multiple routing choices to send the first filtered data to the server device, wherein a cost analysis is performed to select a routing choice from among the multiple routing choices.

5. The method of claim 1, wherein the local networked component comprises an internet of things (IoT) device.

6. The method of claim 1, further comprising performing adaptor management to manage updates to the gateway device rules and adaptor code on the gateway device.

7. The method of claim 1, wherein control signals are provided to the gateway device to initiate action on the local networked component.

8. The method of claim 1, wherein the gateway device further comprises a data cache, a sensor management component, an adaptor management component, a data processor component, a data transfer component, and a first datastore, the data cache storing the collected data, the sensor management component controlling refresh intervals for acquiring data from the local network components, the adaptor management component managing updates to gateway device rules adaptor code on the gateway device, the data processor component identifies the localized action and generated the first filtered data, the data transfer component transmits the first filtered data to the server device, and the first datastore storing the first filtered data;

and

the server device further comprising a data capture component, a data cache, a data pre-processor, a second datastore, a data post-processor, and an action processor component, the data capture component receives the first filtered data, the data cache stores the first filtered data, the data pre-processor generates the second filtered data, the second datastore storing the second filtered data, the data post-processor performing the downstream processing, the action processor component triggering one or more actions at the gateway device and an enterprise application

wherein;

the second filtered data is transmitted to an enterprise application and stored in an enterprise application database;

the collected data from a local networked component of the plurality of local networked components is received using a plurality of hardware-specific components of the gateway device, and respective hardware-specific components of the plurality of hardware-specific components support one or more device types, and the respective hardware-specific components comprise application programming interfaces that extract data from corresponding local networked components;

the server device implements data storage rules to control location, storage frequency, or data transformation of the second filtered data when storing the second filtered data into a datastore;

the server device is coupled to a plurality of gateway devices;

the gateway device selects from among multiple routing choices to send the first filtered data to the server device, wherein a cost analysis is performed to select a routing choice from among the multiple routing choices;

control signals are provided to the gateway device to initiate action on the local networked component; and

the local networked component comprises an internet of things (IoT) device.

9. A non-transitory computer-readable medium storing instructions for managing networked components which, when executed by one or more processors, cause the one or more processors to perform operations comprising:

managing data collection and analysis from a plurality of local networked components using a gateway device and a server device, the gateway device being coupled between the plurality of local networked components and the server device in a network, the gateway device comprising at least a processor and a memory;

receiving, at the gateway device, collected data from a local networked component of the plurality of local networked components, wherein the collected data is received from a front-end data collection module comprising custom code that is specific to handle data received from different types of local networked components, the custom code collecting data in a generic format from the different types of local networked components, wherein the collected data having the generic format collected from the different types of local networked components are pre-processed at the gateway device;

pre-processing, at the gateway device, the collected data by;

accessing gateway device rules to locally analyze the collected data from the local networked component;

identifying a localized action to take on the gateway device or on the local networked component, the localized action being taken in response to identification of a gateway device rules condition corresponding to the localized action;

generating first filtered data by applying one or more of the gateway device rules to the collected data, the first filtered data being smaller than the collected data; and

throttling transmission of the first filtered data to the server device to not overwhelm capacities of the network;

receiving, at the server device, the first filtered data;

processing, at the server device, the first filtered data received at least by;

generating second filtered data by applying server device rules to the first filtered data in a data pre-processing step, the second filtered data being smaller than the first filtered data; and

initiating downstream processing of the second filtered data in a post-processing step, the downstream processing of the second filtered data being taken in response to identification of a server device rules condition corresponding to the downstream processing.

10. The non-transitory computer-readable medium of claim 9, wherein the collected data from a local networked component of the plurality of local networked components is received using a plurality of hardware-specific components of the gateway device, and respective hardware-specific components of the plurality of hardware-specific components supports one or more device types.

11. The non-transitory computer-readable medium of claim 9, wherein the server device implements data storage rules to control location, storage frequency, or data transformation of the second filtered data when storing the second filtered data into a datastore.

12. The non-transitory computer-readable medium of claim 9, wherein the gateway device selects from among multiple routing choices to send the first filtered data to the server device, wherein a cost analysis is performed to select a routing choice from among the multiple routing choices.

13. The non-transitory computer-readable medium of claim 9, wherein the local networked component comprises an internet of things (IoT) device.

14. The non-transitory computer-readable medium of claim 9, the operations further comprising performing adaptor management to manage updates to the gateway device rules and adaptor code on the gateway device.

15. The non-transitory computer-readable medium of claim 9, wherein control signals are provided to the gateway device to initiate action on the local networked component.

16. The non-transitory computer-readable medium of claim 9, wherein the gateway device further comprises a data cache, a sensor management component, an adaptor management component, a data processor component, a data transfer component, and a first datastore, the data cache storing the collected data, the sensor management component controlling refresh intervals for acquiring data from the local network components, the adaptor management component managing updates to gateway device rules adaptor code on the gateway device, the data processor component identifies the localized action and generated the first filtered data, the data transfer component transmits the first filtered data to the server device, and the first datastore storing the first filtered data;

and

the server device further comprising a data capture component, a data cache, a data pre-processor, a second datastore, a data post-processor, and an action processor component, the data capture component receives the first filtered data, the data cache stores the first filtered data, the data pre-processor generates the second filtered data, the second datastore storing the second filtered data, the data post-processor performing the downstream processing, the action processor component triggering one or more actions at the gateway device and an enterprise application

wherein;

the second filtered data is transmitted to an enterprise application and stored in an enterprise application database;

the collected data from a local networked component of the plurality of local networked components is received using a plurality of hardware-specific components of the gateway device, and respective hardware-specific components of the plurality of hardware-specific components support one or more device types, and the respective hardware-specific components comprise application programming interfaces that extract data from corresponding local networked components;

the server device implements data storage rules to control location, storage frequency, or data transformation of the second filtered data when storing the second filtered data into a datastore;

the server device is coupled to a plurality of gateway devices;

the gateway device selects from among multiple routing choices to send the first filtered data to the server device, wherein a cost analysis is performed to select a routing choice from among the multiple routing choices;

control signals are provided to the gateway device to initiate action on the local networked component; and

the local networked component comprises an internet of things (IoT) device.

17. A system for managing networked components, comprising:

a gateway device and a server device managing data collection and analysis from a plurality of local networked components, the gateway device being coupled between the plurality of local networked components and the server device in a network;

the gateway device comprising at least a first processor and a first memory to hold instructions, the instructions when executed by the first processor performs acts comprising;

receiving, at the gateway device, collected data from a local networked component of the plurality of local networked components, wherein the collected data is received from a front-end data collection module comprising custom code that is specific to handle data received from different types of local networked components, the custom code collecting data in a generic format from the different types of local networked components, wherein the collected data having the generic format collected from the different types of local networked components are pre-processed at the gateway device;

pre-processing, at the gateway device, the collected data by;

accessing gateway device rules to locally analyze the collected data from the local networked component;

identifying a localized action to take on the gateway device or on the local networked component, the localized action being taken in response to identification of a gateway device rules condition corresponding to the localized action;

generating first filtered data by applying one or more of the gateway device rules to the collected data, the first filtered data being smaller than the collected data; and

throttling transmission of the first filtered data to the server device to not overwhelm capacities of the network;

the server device comprising at least a second processor and a second memory to hold instructions, the instructions when executed by the second processor performs acts comprising;

receiving the first filtered data;

processing the first filtered data received at least by;

generating second filtered data by applying server device rules to the first filtered data in a data pre-processing step, the second filtered data being smaller than the first filtered data; and

initiating downstream processing of the second filtered data in a post-processing step, the downstream processing of the second filtered data being taken in response to identification of a server device rules condition corresponding to the downstream processing.

18. The system of claim 17, wherein the collected data from a local networked component of the plurality of local networked components is received using a plurality of hardware-specific components of the gateway device, and respective hardware-specific components of the plurality of hardware-specific components supports one or more device types.

19. The system of claim 17, wherein the instructions when executed by the server device implements data storage rules to control location, storage frequency, or data transformation of the second filtered data when storing the second filtered data into a datastore.

20. The system of claim 17, wherein the gateway device comprises a data transfer component that selects from among multiple routing choices to send the first filtered data to the server device, wherein a cost analysis is performed to select a routing choice from among the multiple routing choices.

21. The system of claim 17, wherein the local networked component comprises an internet of things (IoT) device.

22. The system of claim 17, wherein the gateway device further comprises an adaptor manager to manage updates to the gateway device rules and adaptor code on the gateway device.

23. The system of claim 17, wherein the gateway device further comprises a data cache, a sensor management component, an adaptor management component, a data processor component, a data transfer component, and a first datastore, the data cache storing the collected data, the sensor management component controlling refresh intervals for acquiring data from the local network components, the adaptor management component managing updates to gateway device rules adaptor code on the gateway device, the data processor component identifies the localized action and generated the first filtered data, the data transfer component transmits the first filtered data to the server device, and the first datastore storing the first filtered data;

and

the server device further comprising a data capture component, a data cache, a data pre-processor, a second datastore, a data post-processor, and an action processor component, the data capture component receives the first filtered data, the data cache stores the first filtered data, the data pre-processor generates the second filtered data, the second datastore storing the second filtered data, the data post-processor performing the downstream processing, the action processor component triggering one or more actions at the gateway device and an enterprise application

wherein;

the second filtered data is transmitted to an enterprise application and stored in an enterprise application database;

the collected data from a local networked component of the plurality of local networked components is received using a plurality of hardware-specific components of the gateway device, and respective hardware-specific components of the plurality of hardware-specific components support one or more device types, and the respective hardware-specific components comprise application programming interfaces that extract data from corresponding local networked components;

the server device implements data storage rules to control location, storage frequency, or data transformation of the second filtered data when storing the second filtered data into a datastore;

the server device is coupled to a plurality of gateway devices;

the gateway device selects from among multiple routing choices to send the first filtered data to the server device, wherein a cost analysis is performed to select a routing choice from among the multiple routing choices;

control signals are provided to the gateway device to initiate action on the local networked component; and

the local networked component comprises an internet of things (IoT) device.