System and Method for Querying Disparate Data Sources in Real Time

• US 20150112985A1
• Filed: 10/16/2014
• Published: 04/23/2015
• Est. Priority Date: 10/17/2013
• Status: Active Grant

• Current Assignee: Blue Syntax Consulting LLC
• Original Assignee: Blue Syntax Consulting LLC
• Inventors: Roggero, Herve, Mullis, James Joseph
• Granted Patent: US 9,706,007 B2
• Time in Patent Office: Days
• US Class Current: 707/736
• CPC Class Codes: H04L 63/08 for authentication of entities cryptographic mechanisms or cryptographic arrangements for entity authentication H04L9/32
• CPC Class Codes: H04L 67/565 Conversion or adaptation of application format or content adding application control or application functional data H04L67/561

Abstract

A system and method for querying disparate data sources in real time utilizes a plurality of listeners and at least one data adapter operated on a request proxy. A interface specific data query is received from a client account by the request proxy through a specific listener. The interface specific data query is formatted into an agnostic request object that is then forwarded to a specific adapter, wherein a specific method is determined from a plurality of methods for the specific adapter. The request proxy retrieves requested data from at least one data source through the specific adapter. The requested data is then formatted into an agnostic response object that can be cached on the request proxy. The agnostic response object is then formatted into a interface specific response stream by the request proxy and the interface specific response stream is sent to the client account through the specific listener.

Claims

1. A method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method comprises the steps of:

providing an at least one data adapter, wherein each of the at least one data adapter is an object library and can implement a plurality of methods;

receiving a interface specific data query for requested data from a client account;

inspecting the interface specific data query in order to determine a specific adapter from the at least one data adapter and a specific method from the plurality of methods;

formatting the interface specific data query into an agnostic request object;

forwarding the agnostic request object to the specific adapter;

calling the specific method for the specific adapter;

retrieving the requested data from at least one data source through the specific adapter;

generating an agnostic response object for the requested data through the specific adapter;

formatting the agnostic response object into a interface specific response stream; and

sending the interface specific response stream to the client account.

2. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 1 further comprises the steps of:

providing a plurality of listeners, wherein each of the plurality of listeners is associated with a data interface; and

receiving the interface specific data query through a specific listener from the plurality of listeners.

3. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 2 further comprises the steps of:

formatting the interface specific data query into the agnostic request object through the specific listener.

4. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 2 further comprises the steps of:

formatting the agnostic response object into the interface specific response stream according to the data interface of the specific listener, wherein the data interface of the specific listener is associated with the client account.

5. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 1, wherein the agnostic request object contains identification credentials provided within the interface specific data query.

6. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 1, wherein the agnostic request object contains identification credentials provided through a payload sent with the interface specific data query.

7. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 1, wherein the agnostic response object represents a plurality of rows and a plurality of columns.

8. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 7, wherein the plurality of rows and the plurality of columns are arranged into a plurality of result sets.

9. The method of querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 1 further comprises the steps of:

caching the agnostic response object;

receiving a second interface specific data query for the requested data from a second client account;

inspecting the second interface specific data query;

retrieving the agnostic response object;

formatting the agnostic response object into a second interface specific response stream; and

sending the second interface specific response stream to the second client account.

10. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 9 further comprises the steps of:

providing a plurality of listeners, wherein each of the plurality of listeners is associated with a data interface; and

formatting the agnostic response object into the second interface specific response stream according to the data interface of a specific listener from the plurality of listeners, wherein the data interface of the specific listener is associated with the second client account.

11. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 1 further comprises the steps of:

retrieving identification credentials from the agnostic request object; and

authenticating the identification credentials in order to determine a level of access to the specific adapter.

12. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 11 further comprises the steps of:

retrieving custom communication credentials from the agnostic request object; and

applying the custom communication credentials to the specific adapter for access to the at least one data source.

13. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 1 further comprises the steps of:

providing the at least one data adapter, wherein each of the at least one data adapter includes communication credentials; and

authenticating the communication credentials of the specific adapter with the at least one data source.

14. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 1, wherein the specific adapter calls on a subsequent adapter from the at least one data adapter in order to retrieve the requested data from the at least one data source.

15. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 1, wherein the specific adapter defines a callback for the at least one data source.

16. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 1 further comprises the steps of:

providing an adapter name for each of the at least one data adapter;

retrieving the adapter name for the specific adapter from the interface specific data query; and

forwarding the agnostic request object to the specific adapter using the adapter name of the specific adapter.

17. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 1, wherein session variables are implemented for communication between the specific adapter and the at least one data source.

18. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 1, wherein the requested data is filtered by the specific adapter.

19. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 1, wherein the requested data is retrieved according to scheduling data defined by the agnostic request object.

20. The method for querying disparate data sources in real time by executing computer-executable instructions stored on a non-transitory computer-readable medium, the method as claimed in claim 1, wherein the requested data is retrieved according to an event trigger defined by the agnostic request object.