Constructed data stream for enhanced event processing

• US 9,870,410 B2
• Filed: 09/15/2014
• Issued: 01/16/2018
• Est. Priority Date: 09/15/2014
• Status: Active Grant

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Inventors: Novik, Lev, Nano, Olivier, Dos Santos, Ivo Jose Garcia, Bussard, Laurent, Raizman, Alex, Banik, Dipanjan
• Primary Examiner(s): VO, TRUONG V
• Application Number:
  US14/486,638
• Publication Number:
  US 20160078103A1
• Time in Patent Office: 1,219 Days
• CPC Class Codes: G06F 16/2477 Temporal data queries
• CPC Class Codes: G06F 16/248 Presentation of query results

Abstract

Embodiments described herein are directed to methods and systems for enhanced event processing. An enhanced event processing request is received, the enhanced processing request comprising an indication of input data from a database data source. The input data indicated in the enhanced event processing request is accessed using a constructed data stream. The constructed data stream provides access to a collection of snapshots over time of database data of the database data source. The data from constructed data stream source may be accessed as a function of a selected value and a selected time. The constructed data stream data includes the temporal element, which is unavailable with the database data, the temporal element facilitates performing enhanced event processing for the database data using the constructed data stream data. An output for the enhanced event processing request is generated based on the input data accessed using the constructed data stream data.

Claims

1. A computer-implemented method for enhanced event processing, the method comprising:

receiving an enhanced event processing request, wherein the enhanced event processing request comprises an indication of input data from a database data source;

accessing the input data in the indication of input data using a constructed data stream source, wherein the constructed data stream source provides access to a collection of snapshots, of database data of the database data source, over time, wherein the input data is accessed using the constructed data stream that operates as a data stream simulation proxy for the database data source, the constructed data stream is constructed from the collection of snapshots such that the constructed data stream comprises a temporal element that indicates a time corresponding to an event of the constructed data stream; and

generating an output for the enhanced event processing request based on the input data accessed using the constructed data stream.

2. The method of claim 1, wherein the input data from the database data source is not associated with a temporal element for the input data in that the database data source maintains database data in relational database tables.

3. The method of claim 1, wherein the input data in the enhanced event processing request corresponds to a selected value and a selected time in a selected snapshot in the collection of snapshots that is accessed via the constructed data stream.

4. The method of claim 1, wherein the temporal element of the constructed data stream is determined from the time an event of the constructed data stream occurred and stored as part of a snapshot of the event in the database data.

5. The method of claim 1, wherein the constructed data stream provides for repeatable computations using the database data that changes over time, and wherein the constructed data stream is accessed as a function of a selected value and a selected time.

6. The method of claim 1, wherein the enhanced event processing request further includes a second indication of input data from a data stream.

7. The method of claim 6, further comprising:

correlating a first temporal element of the constructed data stream with a second temporal element of the data stream; and

generating an output for the enhanced event processing request based on the input data of the constructed data stream and the input data of the data stream.

8. The method of claim 1, wherein the output is associated with a validity temporal element that indicates the time where the output based on the constructed data stream accurately reflects data in the database data.

9. One or more computer storage media having computer-executable instructions embodied thereon that, when executed, by one or more processors, causes the one or more processors to perform a method for enhanced event processing, the method comprising:

identifying a database data source;

sampling at least a portion of a database data of the database data source to generate one or more snapshots of the database data;

generating a constructed data stream based on the one or more snapshots of the database data, wherein the constructed data stream is associated with a temporal element; and

providing access to the constructed data stream based on an enhanced event processing request;

wherein the enhanced processing event request is associated with an indication of input data in a database of the database data source accessible using the constructed data stream.

10. The media of claim 9, wherein sampling the database data is based on a periodical sampling mechanism that generates one or more snapshots based on a predetermined time interval.

11. The media of claim 9, wherein the sampling the database data is based on a differential sampling mechanism that generates one or more snapshots that include only the changes to the database data.

12. The media of claim 9, wherein sampling the database is based on a notification mechanism that indicates when a change to the database data has occurred such that a snapshot is generated upon an indication of a change to the database data.

13. The media of claim 12, wherein the notification mechanism further comprises a batching feature, wherein the batching feature determines a predetermined number of changes or determines a predetermined period of time before triggering a notification to perform sampling.

14. The media of claim 12, wherein the notification mechanism is based on an administrative temporal element that is associated with operation-based functionality of the database data, wherein the administrative temporal element is not recorded in the database.

15. The media of claim 14, wherein the administrative temporal element indicates a time that is associated with snapshots that are used to generate the constructed data stream with the temporal element.

16. A computer system for performing enhanced event processing, the computer system comprising:

a database data source component configured for;

providing access to a database data;

a constructed data stream source component configured for;

identifying a database data source;

sampling at least a portion of a database data of the database data source to generate one or more snapshots of the database data;

generating a constructed data stream based on the one or more snapshots of the database data, wherein the constructed data stream is associated with a temporal element; and

providing access to the constructed data stream based on an enhanced event processing request, wherein the enhanced processing event request is associated with at least an indication of input data in the database of the database data source accessible using the constructed data stream;

a data stream source configured for;

providing access to a data stream; and

an enhanced event processing server configured for;

receiving the enhanced event processing request, wherein the enhanced event processing request comprises an indication of input data from the database data source and a second indication of input data from the data stream source;

accessing the input data in the indication of input data using the constructed data stream source, wherein the constructed data stream source provides access to a collection of snapshots, of database data of the database data source, over time, wherein the input data is accessed using the constructed data stream that comprises a first temporal element;

accessing input data in the second indication of input data using the data stream source;

correlating the first temporal element of the constructed data stream with a second temporal element of the data stream; and

generating an output for the enhanced event processing request based on the input data of the constructed data stream and the input data of the data stream.

17. The system of claim 16, wherein the enhanced event processing server comprises a logic module, wherein the logic module is configured for:

identifying a logic for generating output based on the enhanced event processing request, wherein the logic is selected from at least one of a;

most up-to-date snapshot logic; and

interpolation logic; and

providing the logic such that the output is generated based on the logic, wherein the logic is backwards compatible with the constructed data stream.

18. The system of claim 16, wherein the enhanced event processing server comprises an operations module, wherein the operations module is configured for:

receiving the enhanced event processing request with an indication of input data in a database, the input data is not associated with a temporal element; and

accessing the input data using a constructed data stream, wherein the constructed data stream comprises the input data associated with a temporal element.

19. The system of claim 16, wherein the enhanced event processing server comprises a validity time module, wherein the validity time module is configured for:

providing a validity temporal element that indicates a time where the output based on the constructed data stream accurately reflects data in the database data.

20. The system of claim 19, wherein the validity temporal element is accelerated to advance processing of enhanced event processing requests.