Server System for Providing Current Data and Past Data to Clients

• US 20150019687A1
• Filed: 07/05/2013
• Published: 01/15/2015
• Est. Priority Date: 07/05/2013
• Status: Active Grant

• Current Assignee: The Boeing Co.
• Original Assignee: The Boeing Co.
• Inventors: Aaron, Noah Eric, Bennett, Dave, Cummins, Will R., Wecker, Noah H.
• Granted Patent: US 10,362,145 B2
• Time in Patent Office: Days
• US Class Current: 709/219
• CPC Class Codes: H04L 67/01 Protocols
• 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

A method and apparatus for handling a server request received at a data server. The data server comprises a policy request handler. The policy request handler is activated within the data server in response to the server request being received at the data server. The policy request handler is configured to receive a plurality of asynchronous data streams. The policy request handler is further configured to merge data points in the plurality of asynchronous data streams together to form time-ordered data points. The policy request handler is further configured to form policy-based data according to a server policy identified in the server request using the time-ordered data points.

Claims

1. A data server comprising:

a policy request handler that is activated within the data server in response to a server request being received at the data server,

wherein the policy request handler is configured to receive a plurality of asynchronous data streams;

merge data points in the plurality of asynchronous data streams together to form time-ordered data points; and

form policy-based data according to a server policy identified in the server request using the time-ordered data points.

2. The data server of claim 1, wherein the policy request handler comprises:

a data merger that merges the data points in the plurality of asynchronous data streams together to form the time-ordered data points.

3. The data server of claim 2, wherein the data merger receives the plurality of asynchronous data streams from a receiver in the data server when the server request is a live request in which the receiver receives data from at least one of a set of data providers.

4. The data server of claim 3, wherein the data merger receives the plurality of asynchronous data streams from a storage system in the data server when the server request is a historical request in which the storage system stores the data received by the receiver.

5. The data server of claim 2, wherein the policy request handler further comprises:

a policy-based data manager that forms the policy-based data using the time-ordered data points in which the policy-based data is formed based on the server policy.

6. The data server of claim 5, wherein the policy-based data manager is configured to use every data point in the time-ordered data points to form the policy-based data when the server policy indicates that the server request is an every sample request.

7. The data server of claim 5, wherein the policy-based data manager is configured to form the policy-based data as a set of policy-based data frames in which each policy-based data frame in the set of policy-based data frames is formed in response to an event occurring using the time-ordered data points.

8. The data server of claim 7, wherein the event is a lapse of a time interval and wherein a policy-based data frame in the set of policy-based data frames comprises a number of data values and a time value indicating a time at which the lapse of the time interval occurred.

9. The data server of claim 8, wherein the number of data values are identified using the time-ordered data points and interpolation.

10. The data server of claim 1, wherein the policy request handler further comprises:

an output packetizer that forms output data for transmission from the policy request handler to a client using the policy-based data.

11. The data server of claim 1 further comprising:

a receiver that receives data from at least one of a set of data providers; and

a storage system that receives the data from the receiver and stores the data, wherein the policy request handler is configured to receive the plurality of asynchronous data streams from one of the receiver and the storage system.

12. The data server of claim 1, wherein each of the data points in the plurality of asynchronous data streams includes a data value and a time value indicating a time at which the data value was acquired.

13. The data server of claim 1, wherein the policy request handler serves the policy-based data to a client that generated a policy request from which the server request was formed.

14. A server system comprising:

a server controller configured to receive a policy request from a client and generate a number of server requests based on the policy request; and

a set of data servers, wherein a data server in the set of data servers comprises;

a server manager that activates a number of policy request handlers in response to receiving a server request in the number of server requests; and

a policy request handler in the number of policy request handlers that is configured to;

receive a plurality of asynchronous data streams;

merge data points in the plurality of asynchronous data streams together to form time-ordered data points;

form policy-based data according to a server policy identified in the server request using the time-ordered data points; and

send the policy-based data to the client as output data.

15. A method for handling a server request received at a data server, the method comprising:

activating a policy request handler within the data server in response to receiving the server request;

receiving a plurality of asynchronous data streams at the policy request handler;

merging, by the policy request handler, data points in the plurality of asynchronous data streams together to form time-ordered data points; and

forming, by the policy request handler, policy-based data according to a server policy identified in the server request using the time-ordered data points.

16. The method of claim 15 further comprising:

sending the policy-based data as output data to a client that originated a policy request from which the server request was formed.

17. The method of claim 15, wherein receiving the plurality of asynchronous data streams at the policy request handler comprises:

receiving the plurality of asynchronous data streams at the policy request handler from a receiver in the data server when the server request is a live request in which the receiver receives data from at least one of a set of data providers.

18. The method of claim 17, wherein receiving the plurality of asynchronous data streams at the policy request handler further comprises:

receiving the plurality of asynchronous data streams at the policy request handler from a storage system in the data server when the server request is a historical request in which the storage system stores the data received by the receiver.

19. The method of claim 15, wherein forming, by the policy request handler, the policy-based data comprises:

forming, by the policy request handler, the policy-based data using every data point in the time-ordered data points to form the policy-based data when the server policy indicates that the server request is an every sample request.

20. The method of claim 15, wherein forming, by the policy request handler, the policy-based data comprises:

forming, by the policy request handler, the policy-based data as a set of policy-based data frames in which each policy-based data frame in the set of policy-based data frames is formed in response to an event occurring using the time-ordered data points.