COMPLEX EVENT PROCESSING FOR DYNAMIC DATA

• US 20140237487A1
• Filed: 02/10/2014
• Published: 08/21/2014
• Est. Priority Date: 02/15/2013
• Status: Abandoned Application

• Current Assignee: University of Southern California
• Original Assignee: University of Southern California
• Inventors: Prasanna, Viktor K., Patri, Om Prasad, Sorathia, Vikrambhai S., Panangadan, Anand V.
• Application Number:
  US14/177,099
• Publication Number:
  US 20140237487A1
• Time in Patent Office: Days
• US Class Current: 719/318
• CPC Class Codes: G05B 19/0428 Safety, monitoring G05B19/0423 takes precedence
• CPC Class Codes: G06Q 10/0639 Performance analysis of employees; Performance analysis of enterprise or organisation operations
• CPC Class Codes: G06Q 10/10 Office automation; Time management
• CPC Class Codes: G06Q 50/02 Agriculture; Fishing; Forestry; Mining

Abstract

A complex event processing system and method of operation are disclosed. The system includes, in one example, a monitor configured to detect, from measurements received from one or more data streams, observations relating to the measurements, and interpretations of the observations, a plurality, an occurrence of an event, and a state transition engine configured to receive the event and, based at least in part on the event, determine a current state of a particular entity of a dynamic system based on a state model as well as a next state of the particular entity to which the state model should transition, wherein the particular entity of the dynamic system is associated with the event. The system also includes an action determination component configured to determine an action to be taken based on the current state and the next state, a role determination component configured to determine a role associated with the action to be taken, and a notification component configured to generate one or more notifications to entities associated with the role, the one or more notifications including the action to be taken.

Claims

1. A complex event processing system comprising:

a monitor configured to detect, from measurements received from one or more data streams, observations relating to the measurements, and interpretations of the observations, an occurrence of an event;

a state transition engine configured to receive the event and, based at least in part on the event, determine a current state of a particular entity of a dynamic system based on a state model as well as a next state of the particular entity to which the state model should transition, wherein the particular entity of the dynamic system is associated with the event;

an action determination component configured to determine an action to be taken based on the current state and the next state;

a role determination component configured to determine a role associated with the action to be taken; and

a notification component configured to generate one or more notifications to entities associated with the role, the one or more notifications including the action to be taken.

2. The complex event processing system of claim 1, further comprising a feedback monitoring component configured to wait a predetermined time for the action to be taken.

3. The complex event processing system of claim 2, wherein, based on whether the action to be taken has occurred, a feedback message is generated.

4. The complex event processing system of claim 3, wherein the feedback message results in an escalation event detected at the monitor, the escalation event resulting in the action determination component determining an escalation action to be taken.

5. The complex event processing system of claim 1, wherein the data streams are received from one or more entities of the dynamic system, and include one or more observations of observable properties associated with the entities.

6. The complex event processing system of claim 1, wherein the current state of the particular entity of the dynamic system is determined by the state transition engine.

7. The complex event processing system of claim 1, wherein the state model comprises an automaton comprising at least one of a non-deterministic finite automaton and a deterministic finite automaton, in which each state corresponds to a type of action performed by one or more entities of the dynamic system.

8. The complex event processing system of claim 1, wherein the event is associated with an entity of the dynamic system, a time, and a property.

9. The complex event processing system of claim 1, wherein the monitor detects an occurrence of an event based on a critical change observed in an entity of the dynamic system.

10. The complex event processing system of claim 1, wherein the action is selected from a group of actions including complex event processing actions, system actions, and middleware actions.

11. The complex event processing system of claim 1, wherein the role is selected from a group of roles including complex event processing roles, system roles, and middleware roles.

12. The complex event processing system of claim 1, wherein, if the current state of the particular entity of the dynamic system corresponds to the next state of the particular entity to which the state model should transition, discarding the event.

13. A method of processing complex events in an oil production system, the method comprising:

receiving a plurality of data streams from the oil production system at a complex event processing system;

defining measurements based on data in the data streams, and observations associated with the measurements;

detecting an occurrence of an event based on interpretation of the observations;

upon occurrence of the event, determining a current state of a state model;

if the current state is not a goal state, determining a next state to which the state model should transition;

based on the current state and the next state, determining an action, a role, and a notification to be generated; and

sending the notification and action to an entity assigned the role.

14. The method of claim 13, further comprising waiting a predetermined time after sending the notification for the action to be performed.

15. The method of claim 14, further comprising, if the action is not performed within the predetermined time, escalating the event.

16. The method of claim 15, wherein escalating the event includes providing feedback in the data streams received at the complex event processing system of non-action by the entity assigned the role.

17. The method of claim 16, further comprising, upon receiving the feedback, determining a second action, a second role, and a second notification to be generated that address the escalated event.

18. The method of claim 13, wherein detecting the occurrence of the event is based on matching one or more interpretations of the observations to one or more event profiles.

19. The method of claim 18, wherein the one or more event profiles each include a particular entity, an observation relating to a measurement of the entity, and an interpretation of the observation.

20. The method of claim 19, wherein at least one complex event profile includes a plurality of event profiles.

21. The method of claim 13, wherein the action includes a plurality of actions, the role includes a plurality of roles, and the notification includes a plurality of notifications leading to the goal state.

22. A computer-readable storage medium having computer-executable instructions stored thereon which, when executed by a computing system, perform a method of processing complex events in a dynamic system, the method comprising:

receiving a plurality of data streams from a dynamic system at a complex event processing system;

defining measurements based on data in the data streams, and observations associated with the measurements;

detecting an occurrence of an event based on interpretation of the observations;

upon occurrence of the event, determining a current state of a state model;

if the current state is not a goal state, determining a next state to which the state model should transition;

based on the current state and the next state, determining an action to be taken, a role associated with the action, and a notification based on the role and the action; and

sending the notification and action to an entity assigned the role.

23. The computer-readable storage medium of claim 22, further comprising waiting a predetermined time after sending the notification for the action to be performed, and, if the action is not performed within the predetermined time, escalating the event.