LOCAL EVENT PROCESSING

• US 20130031567A1
• Filed: 07/25/2011
• Published: 01/31/2013
• Est. Priority Date: 07/25/2011
• Status: Abandoned Application

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Corporation
• Inventors: Nano, Olivier, Tilly, Marcel, Verona, Tomer, Santos, Ivo
• Application Number:
  US13/189,566
• Publication Number:
  US 20130031567A1
• Time in Patent Office: Days
• US Class Current: 719/318
• CPC Class Codes: G05B 21/02 electric
• CPC Class Codes: G05B 23/0264 Control of logging system, e.g. decision on which data to store; time-stamping measurements

Abstract

The claimed subject matter provides a method for processing a stream of events. The method includes receiving a stream of events at a local device. The stream of events is associated with the local device. Further, the stream of events includes one or more out-of-order events. The method also includes executing a first complex event processing query against the stream of events. The stream of events is processed based on multiple levels of consistency defined by a set of operators. Additionally, the method includes correcting the out-of-order events based on the set of operators. A first output is generated in which consistency is guaranteed based on the corrected out-of-order events. The method also includes sending the first output to a server that performs complex event processing on the output.

Claims

1. A method for complex event processing, comprising:

receiving a stream of events at a local device, wherein the stream of events are associated with the local device, and the stream of events include one or more out-of-order events;

executing a first complex event processing query against the stream of events;

processing the stream of events based on multiple levels of consistency defined by a set of operators;

correcting the out-of-order events based on the set of operators;

generating a first output in which consistency is guaranteed based on the corrected out-of-order events; and

sending the first output to a server that performs complex event processing on the output.

2. The method recited in claim 1, comprising:

identifying an alert condition for the local device; and

displaying an alert at the local device based on the alert condition.

3. The method recited in claim 1, wherein the first output comprises local analytics.

4. The method recited in claim 1, comprising:

receiving a stream of aggregated events from a plurality of local devices, wherein the aggregated stream of events from the plurality of local devices comprise;

the output; and

one or more out-of-order aggregated events;

executing a second complex event processing query against the stream of aggregated events;

processing the stream of aggregated events based on the multiple levels of consistency defined by the set of operators;

correcting the out-of-order aggregated events based on the set of operators;

generating a second output in which consistency is guaranteed based on the corrected out-of-order aggregated events.

5. The method recited in claim 4, wherein the plurality of local devices comprise a plurality of device categories.

6. The method recited in claim 4, wherein the second output comprises global analytics.

7. The method recited in claim 4, wherein the second complex event processing query and the first complex event processing query are executed as a chained operation.

8. The method recited in claim 4, wherein the first complex event query is executable on the back end server, and the second complex event query is executable on the local device.

9. The method recited in claim 4, wherein the server comprises a cloud service comprising the second complex event processing query.

10. The method recited in claim 4, wherein the server comprises a back end server comprising the second complex event processing query.

11. A system for executing a transaction on a distributed platform, comprising:

a processing unit; and

a system memory, wherein the system memory comprises code configured to direct the processing unit to;

perform complex event processing on a local device, for a local stream for the local device that comprises one or more out-of-order events;

generate an aggregate stream based on the complex event processing on the local device, wherein each of a specified set of operators;

performs an operation; and

places the out-of-order events in sequence in the aggregate stream; and

send the aggregate stream to a server for further complex event processing.

12. The system recited in claim 11, wherein the specified set of operators comprises one of:

select;

join;

sum;

align;

finalize;

aggregation;

windowing;

alterlifetime;

or

combinations thereof.

13. The system recited in claim 11, comprising code configured to direct the processing unit to generate local analytics based on the complex event processing.

14. The system recited in claim 11, comprising code configured to direct the processing unit to:

perform complex event processing on the server, for a plurality of aggregate streams, comprises one or more out-of-order aggregate events;

generate a global stream based on the complex event processing on the server, wherein each of the specified set of operators;

performs an operation; and

places the out-of-order aggregate events in sequence in the global stream.

15. The system recited in claim 14, wherein the plurality of aggregate streams are generated by a plurality of local devices, wherein the plurality of devices varies by type.

16. The system recited in claim 14, wherein the complex event processing query on the local device and the complex event processing on the server are executed as a chained operation.

17. The system recited in claim 11, comprising code configured to direct the processing unit to:

detect an alert condition on the local device based on the local analytics; and

activate a diagnostic complex event processing query on the local device in response to detecting the alert condition.

18. The system recited in claim 17, comprising code configured to direct the processing unit to:

determine a resolution to the alert condition; and

deploy new complex event processing based on the resolution to a plurality of local devices.

19. One or more computer-readable storage media, comprising code configured to direct a processing unit to:

perform complex event processing on a local device, for a local stream for the local device that comprises one or more out-of-order events;

generate an aggregate stream based on the complex event processing on the local device, wherein each of a specified set of operators;

performs an operation; and

places the out-of-order events in sequence in the aggregate stream;

generate local analytics for the local device based on the complex event processing; and

display an interface comprising the local analytics.

20. The computer-readable storage media recited in claim 19, comprising code configured to direct the processing unit to send the aggregate stream to a server for further complex event processing.