Event processing with XML query based on reusable XML query template

• US 9,348,868 B2
• Filed: 01/22/2015
• Issued: 05/24/2016
• Est. Priority Date: 10/21/2009
• Status: Active Grant

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Inventors: Schindlauer, Roman, Sezgin, Beysim, Grabs, Torsten
• Primary Examiner(s): DANG, THANH HA T
• Application Number:
  US14/602,742
• Publication Number:
  US 20150134698A1
• Time in Patent Office: 488 Days
• Field of Search: 707/769, 707/760, 707/763, 707/779
• US Class Current: 1/1
• CPC Class Codes: G06F 16/2455 Query execution
• CPC Class Codes: G06F 16/835 Query processing

Abstract

Methods, systems, and computer-readable media are disclosed for event processing with a query based on a reusable XML query template. A particular method includes receiving a plurality of events from a source and generating a plurality of event objects based on the plurality of events. A query represented by an XML file based on a reusable XML query template is executed with respect to the plurality of event objects to produce a plurality of result objects. Each result object is produced based on an application of at least one operator of the query. A plurality of results is generated based on the plurality of result objects, and the plurality of results is transmitted to a sink.

Claims

1. A system comprising:

a memory; and

a processor connected with the memory, the processor executing as a query engine configured to execute queries with respect to event objects to produce result objects, wherein a query is represented by an extensible markup language (XML) file that is based on a reusable XML query template that is bindable to a plurality of input adapters and a plurality of output adapters, the processor executing;

binding the reusable XML query template to a first input adapter for a source to input data for execution of the query to produce a first result for the query,

binding the reusable XML query template to a second input adapter, different from the first input adapter, for another source to input data for execution of the query to produce a second result for the query, and

executing processing of the query.

2. The system according to claim 1, wherein the processor further executing outputting of the first result.

3. The system according to claim 2, wherein at least one of the first input adapter, the second input adapter, the query engine, the first output adapter, and the second output adapter are integrated into a complex event processing (CEP) system.

4. The system according to claim 2, wherein the input adapter generates event objects that match an input type specification of the reusable XML query template and wherein the first output adapter accepts result objects that match an output type specification of the reusable XML query template.

5. The system according to claim 1, wherein the processor further executing outputting of the second result.

6. The system according to claim 1, wherein the binding to the first input adapter further comprises binding the reusable XML query template to a first output adapter for a sink to output the first result of the query, and the binding to the second input adapter further comprises binding the reusable XML query template to a second output adapter, different from the first output adapter, for another sink to output the second result.

7. The system according to claim 6, wherein the first input adapter transmits an event object to the query engine via an input stream and the first output adapter receives a result object from the query engine via an output stream.

8. The system according to claim 1, wherein both the first input adapter and the second input adapter are used to produce identically typed event objects in accordance with a type specification of the reusable XML query template.

9. The system according to claim 1, wherein the XML file includes a directed graph of the at least one operator.

10. The system according to claim 9, wherein the directed graph includes a projection operator, a windowing operator, an aggregation operator, a grouping operator, a join operator, a selection operator, or any combination thereof.

11. The system according to claim 1, wherein the XML file representing the query is generated based on a language integrated query (LINQ) language, a query in a .NET programming language other than LINQ, a complex event detection and response (CEDR) algebra query, or any combination thereof.

12. The system according to claim 1, wherein the system is integrated into an embedded dynamically linked library (DLL), an executable file, an operating system service, or a server farm.

13. The system according to claim 1, wherein at least one of the first input adapter, the second input adapter and the query engine are integrated into a complex event processing (CEP) system.

14. A system comprising:

a memory; and

a processor connected with the memory, the processor executing as a query engine configured to execute queries with respect to event objects to produce result objects, wherein a query is represented by an extensible markup language (XML) file that is based on a reusable XML query template that is bindable to a plurality of input adapters and a plurality of output adapters, the processor executing;

binding the reusable XML query template to a first output adapter for a sink to output first results from execution of the query,

binding the reusable XML query template to a second output adapter, different from the first output adapter, for another sink to output second results from execution of query, and

executing the query to generate the first results and the second results.

15. The system according to claim 14, wherein the processor further executing binding the reusable XML query template to a first input adapter for a source to input data for execution of the query.

16. The system according to claim 14, wherein the processor further executing binding the reusable XML query template to a second input adapter, different from the first input adapter, for another source to input data for execution of the query.

17. The system according to claim 14, wherein the processor further executing outputting of at least one of the first results and the second results.

18. The system according to claim 14, wherein both the first input adapter and the second input adapter are used to produce identically typed event objects in accordance with a type specification of the reusable XML query template.

19. The system according to claim 14, wherein the reusable XML query template is integrated into a complex event processing (CEP) system.

20. A computer-implemented method comprising:

binding a reusable XML query template to a first input adapter for a source and a first output adapter for a sink to produce a first result for a query;

binding the reusable XML query template to a second input adapter for another source and a second output adapter for another sink to produce a second result for the query; and

executing, using a query engine operating on a processing device, the query to produce the first result and the second result,

wherein the query engine is configured to execute queries with respect to event objects to produce result objects, and wherein a query is represented by an extensible markup language (XML) file that is based on the reusable XML query template that is bindable to a plurality of input adapters and a plurality of output adapters.