DATA HUB ARCHITECTURE TO PROVIDE ACTIONABLE DATA FROM REMOTE SENSOR FEEDS

• US 20160253394A1
• Filed: 02/26/2015
• Published: 09/01/2016
• Est. Priority Date: 02/26/2015
• Status: Active Grant

• Current Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Original Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Inventors: Elis, Filip, Nguyen, Filip
• Granted Patent: US 10,078,671 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• 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

Abstract

Systems and methods are provided for data hub architecture to provide actionable data from remote sensor feeds. An exemplary method includes receiving, by a master hub of a plurality of data hubs, a request to access at least one first sensor in a first location and at least one second sensor in a second location from a data client, wherein the master hub is closest to the data client of the plurality of data hubs on a network, determining a first data hub that is closest to the at least one first sensor on the network, and determining a second data hub that is closest to the at least one second sensor on the network. The method further includes querying the first data hub and the second data hub for data and communicating the data to the data client.

Claims

1. A method comprising:

receiving, by a master hub of a plurality of data hubs, a request to access at least one first sensor in a first location and at least one second sensor in a second location from a data client, wherein a network includes the plurality of data hubs, and wherein the master hub is closest to the data client of the plurality of data hubs on the network;

determining, by the master hub, a first data hub of the plurality of data hubs that is closest to the at least one first sensor on the network;

determining, by the master hub, a second data hub of the plurality of data hubs that is closest to the at least one second sensor on the network;

querying, by the master hub, the first data hub for first data from the at least one first sensor;

querying, by the master hub, the second data hub for second data from the at least one first sensor; and

communicating, by the master hub, the first data and the second data to the data client.

2. The method of claim 1, wherein prior to the querying, by the master hub, the first data hub and the second data hub, the method further comprises:

determining, by the master hub, a first time delay between the master hub and the first data hub; and

determining, by the master hub, a second time delay between the master hub and the second data hub.

3. The method of claim 2, wherein the first time delay comprises a first amount of time to receive, by the master hub, a first data signal from the first data hub, and wherein the second time delay comprises a second amount of time to receive, by the master hub, a second data signal from the second data hub.

4. The method of claim 3, wherein the determining, by the master hub, the first time delay comprises pinging the first data hub by the master hub to determine the first amount of time, and wherein the determining, by the master hub, the second time delay comprises pinging the second data hub by the master hub to determine the second amount of time.

5. The method of claim 4, wherein prior to the querying, by the master hub, the first data hub and the second data hub, the method further comprises:

determining, by the master hub, a time difference between receiving the first data signal from the first data hub and receiving the second data signal from the second data hub using the first time delay and the second time delay.

6. The method of claim 5, wherein the first data hub comprises a first federated database system using data federation to retrieve the first data from the at least one first sensor, and wherein the second data hub comprises a second federated database system using data federation to retrieve the second data from the at least one second sensor.

7. The method of claim 6, wherein the first data hub fills a first materialized view with the first data from the at least one first sensor, wherein the first materialized comprises at least a first data column comprising the first data and a first timestamp column comprising at least one first timestamp for each datum in the first data, wherein the at least one first timestamp comprises at least one first time that the each datum in the first data is collected by the at least one first sensor, and

wherein the second data hub fills a second materialized view with the second data from the at least one second sensor, wherein the second materialized comprises at least a second data column comprising the second data and a second timestamp column comprising at least one second timestamp for each datum in the second data, wherein the at least one second timestamp comprises at least one second time that the each datum in the second data is collected by the at least one second sensor.

8. The method of claim 7, wherein the master hub uses the time difference to synchronize the querying, by the master hub, the first data hub for the first data and the querying, by the master hub, the second data hub for the second data so that the at least one first timestamp and the at least one second timestamp match.

9. The method of claim 8, wherein the master hub comprises a master federated database system using data federation to retrieve the first data from the first data hub and the second data from the second data hub, wherein prior to the communicating, by the master hub, the first data and the second data to the data client, the method further comprises:

receiving, by the master hub, the first data from the first data hub;

receiving, by the master hub, the second data from the second data hub; and

sorting, by the master hub, the first data and the second data according to the at least one first timestamp and the at least one second timestamp,

and wherein the communicating, by the master hub, the first data and the second data to the data client comprises streaming the first data and the second data to the data client using the sorting, by the master hub, the first data and the second data.

10. The method of claim 9, wherein the master hub uses a select union query for the querying, by the master hub, the first data hub for the first data, the querying, by the master hub, the second data hub for the second data, and the sorting, by the master hub, the first data and the second data.

11. A system comprising:

a master hub of a plurality of data hubs that receives a request to access at least one first sensor in a first location and at least one second sensor in a second location from a data client, wherein a network includes the plurality of data hubs, and wherein the master hub is closest to the data client of the plurality of data hubs on the network;

a first data hub of the plurality of data hubs that is closest to the at least one first sensor on the network and retrieves first data from the at least one first second;

a second data hub of the plurality of data hubs that is closest to the at least one second sensor on the network and retrieves second data from the at least one second sensor,

wherein the master hub queries the first data hub for the first data, queries the second data hub for the second data and communicates the first data and the second data to the data client.

12. The system of claim 11, wherein prior to the master hub querying the first data hub and the second data hub, the master hub further determines a first time delay between the master hub and the first data hub and determines a second time delay between the master hub and the second data hub.

13. The method of claim 12, wherein the first time delay comprises a first amount of time for the master hub to receive a first data signal from the first data hub, and wherein the second time delay comprises a second amount of time for the master hub to receive a second data signal from the second data hub.

14. The method of claim 13, wherein the mater hub determines the first time delay by pinging the first data hub by the master hub to determine the first amount of time, and wherein the master hub determines the second time delay by pinging the second data hub by the master hub to determine the second amount of time.

15. The method of claim 14, wherein prior to the master hub querying the first data hub and the second data hub, the master hub further determines a time difference between receiving the first data signal from the first data hub and receiving the second data signal from the second data hub using the first time delay and the second time delay.

16. The method of claim 15, wherein the first data hub comprises a first federated database system using data federation to retrieve the first data from the at least one first sensor, and wherein the second data hub comprises a second federated database system using data federation to retrieve the second data from the at least one second sensor.

17. The method of claim 16, wherein the first data hub fills a first materialized view with the first data from the at least one first sensor, wherein the first materialized comprises at least a first data column comprising the first data and a first timestamp column comprising at least one first timestamp for each datum in the first data, wherein the at least one first timestamp comprises at least one first time that the each datum in the first data is collected by the at least one first sensor, and

wherein the second data hub fills a second materialized view with the second data from the at least one second sensor, wherein the second materialized comprises at least a second data column comprising the second data and a second timestamp column comprising at least one second timestamp for each datum in the second data, wherein the at least one second timestamp comprises at least one second time that the each datum in the second data is collected by the at least one second sensor.

18. The method of claim 17, wherein the master hub uses the time difference to synchronize the querying, by the master hub, the first data hub for the first data and the querying, by the master hub, the second data hub for the second data so that the at least one first timestamp and the at least one second timestamp match.

19. The method of claim 18, wherein the master hub comprises a master federated database system using data federation to retrieve the first data from the first data hub and the second data from the second data hub, wherein prior to the master hub communicating the first data and the second data to the data client, the master hub further receives the first data from the first data hub, receives the second data from the second data hub, sorts the first data and the second data according to the at least one first timestamp and the at least one second timestamp, wherein the communicating, by the master hub, the first data and the second data to the data client comprises streaming the first data and the second data to the data client using the sorting, by the master hub, the first data and the second data.

20. A non-transitory computer readable medium comprising a plurality of machine-readable instructions which when executed by one or more processors of an application server are adapted to cause the application server to perform a method comprising:

receiving, by a master hub of a plurality of data hubs, a request to access at least one first sensor in a first location and at least one second sensor in a second location from a data client, wherein a network includes the plurality of data hubs, and wherein the master hub is closest to the data client of the plurality of data hubs on the network;

determining, by the master hub, a first data hub of the plurality of data hubs that is closest to the at least one first sensor on the network;

determining, by the master hub, a second data hub of the plurality of data hubs that is closest to the at least one second sensor on the network;

querying, by the master hub, the first data hub for first data from the at least one first sensor;

querying, by the master hub, the second data hub for second data from the at least one first sensor; and

communicating, by the master hub, the first data and the second data to the data client.