ADAPTERS FOR EVENT PROCESSING SYSTEMS

• US 20110093631A1
• Filed: 10/21/2009
• Published: 04/21/2011
• Est. Priority Date: 10/21/2009
• Status: Active Grant

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Corporation
• Inventors: Sezgin, Beysim, Krishnan, Ramkumar, Gerea, Ciprian, Verona, Tomer, Raman, Balan Sethu
• Granted Patent: US 8,132,184 B2
• Time in Patent Office: Days
• US Class Current: 710/104
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications

Abstract

Methods, systems, and computer-readable media are disclosed for implementing adapters for event processing systems. A particular system includes an input adapter configured to store event objects received from a source at an input queue. The system also includes a query engine configured to remove event objects from the input queue, to perform a query with respect to the removed event objects to generate result objects, and to insert result objects into an output queue. The system also includes an output adapter configured to remove result objects from the output queue and to transmit the result objects to a sink.

Claims

1. A computer system, comprising:

a processor;

a memory coupled to the processor; and

a first interface configured to receive an event object from a source; and

a second interface configured to transmit a result object to a sink;

wherein the processor is configured to retrieve and execute instructions from the memory configured to;

insert the event object into an input queue when the input queue is not full;

stop receipt of event objects at the first interface when the input queue is full;

execute at least one declarative complex event processing (CEP) query with respect to the event object to generate the result object;

insert the result object into an output queue; and

remove the result object from the output queue and transmit the result object to the sink via the second interface.

2. The computer system of claim 1, further comprising a CEP query engine that is configured to perform queue control with respect to the input queue.

3. The computer system of claim 2, wherein the CEP query engine is further configured to perform queue control with respect to the output queue.

4. The computer system of claim 3, further comprising a second processor, wherein the CEP query engine is executed by the second processor.

5. The computer system of claim 1, wherein the computer system comprises a plurality of processors.

6. The computer system of claim 1, wherein the processor is further configured to not insert a particular event object into the input queue upon determining that the particular event object does not satisfy a threshold condition included in the declarative CEP query, wherein the threshold condition includes at least one relational algebra operator.

7. The computer system of claim 1, wherein the first interface is further configured to receive event objects from the source via an input event object stream and wherein the second interface is further configured to transmit result objects to the sink via an output result object stream.

8. The computer system of claim 7, wherein at least one of the input event object stream and the output result object stream is characterized by steady flow, intermittent flow, bursty flow, or any combination thereof.

9. The computer system of claim 7, wherein the input event object stream and the output result object stream are finite streams.

10. The computer system of claim 7, wherein the input event object stream and the output result object stream are continuous streams.

11. The computer system of claim 1, wherein the source is a database, a server, an event store, a ticker, a network port, a sensor, or any combination thereof.

12. The computer system of claim 1, wherein the sink is a communications device, a mobile device, a computer system, a database, a server, an event store, or any combination thereof.

13. A computer-implemented method of operating a complex event processing (CEP) adapter, the method comprising:

receiving a start message at the CEP adapter;

executing a running state at the CEP adapter in response to the start message;

during execution of the running state, receiving an event object from a source;

attempting to execute a queue operation with respect to the event object;

when the queue operation is successful, remaining in the running state;

when the queue operation is unsuccessful, entering a suspended state, wherein

the CEP adapter is configured to not perform the queue operation during the suspended state;

receiving a resume message while in the suspended state; and

terminating the suspended state and re-executing the running state in response to the resume message.

14. The computer-implemented method of claim 13, wherein the CEP adapter is a CEP input adapter.

15. The computer-implemented method of claim 14, wherein the CEP adapter is a CEP output adapter.

16. The computer-implemented method of claim 13, wherein the queue operation is one of an enqueue operation that inserts the event object into a queue and a dequeue operation that retrieves the event object from the queue.

17. The computer-implemented method of claim 13, wherein the CEP adapter is instantiated based on an adapter factory class that includes data common to two or more of a point event model, an interval event model, and an edge event model.

18. The computer-implemented method of claim 17, wherein instantiating the adapter includes configuring the adapter based on an extensible markup language (XML) serializable configuration scheme.

19. A complex event processing (CEP) system, comprising:

a CEP input adapter configured to store event objects received from a source at an input queue;

a CEP query engine configured to;

remove event objects from the input queue;

perform a declarative CEP query with respect to the removed event objects to generate result objects; and

insert result objects into an output queue;

a CEP output adapter configured to;

remove result objects from the output queue; and

transmit result objects retrieved from the output queue to a sink.

20. The CEP system of claim 19, wherein when the declarative CEP query terminates:

the CEP input adapter is further configured to stop receipt of event objects at the CEP input adapter; and

the CEP output adapter is further configured to stop transmission of result objects.