Event processing method in stream processing system and stream processing system

  • US 9,483,332 B2
  • Filed: 09/09/2015
  • Issued: 11/01/2016
  • Est. Priority Date: 06/30/2014
  • Status: Active Grant
First Claim
Patent Images

1. An event processing method in a stream processing system, wherein the stream processing system comprises an input unit and a rule engine, wherein matching modes of the rule engine comprise at least a full-loop mode, a half-loop mode, and a non-loop mode, wherein each matching mode of the rule engine is corresponding to one engine memory, wherein each engine memory stores at least one basic event, and wherein the method comprises:

  • acquiring, by using the input unit, the at least one basic event that is used to represent a status of a target object, wherein the basic event comprises at least one of a condition and attribute information of the target object;

    matching the basic event with basic events stored in engine memories that are corresponding to each matching mode in the rule engine, to determine an engine memory comprising the basic event;

    inputting the basic event into the full-loop mode of the rule engine when it is determined that the engine memory comprising the basic event is an engine memory corresponding to the full-loop mode;

    adding a full-loop identifier to the basic event when it is determined that the engine memory comprising the basic event is an engine memory corresponding to the full-loop mode;

    using the basic event to which the full-loop identifier is added as a full-loop matching result;

    executing the basic event to obtain an execution result when it is determined that the engine memory comprising the basic event is an engine memory corresponding to the full-loop mode;

    modifying, according to the execution result, the attribute information of the target object in the engine memory corresponding to the full-loop mode;

    matching the execution result with the basic events that are stored in the engine memories in the rule engine;

    inputting the basic event into the half-loop mode of the rule engine when it is determined that the engine memory comprising the basic event is an engine memory corresponding to the half-loop mode;

    adding a half-loop identifier to the basic event when it is determined that the engine memory comprising the basic event is an engine memory corresponding to the half-loop mode;

    using the basic event to which the half-loop identifier is added as a half-loop matching result;

    executing the basic event to obtain an execution result when it is determined that the engine memory comprising the basic event is an engine memory corresponding to the half-loop mode;

    modifying, according to the execution result, the attribute information of the target object in the engine memory corresponding to the half-loop mode;

    outputting the execution result; and

    inputting the basic event into the non-loop mode of the rule engine when it is determined that the engine memory comprising the basic event is an engine memory corresponding to the non-loop mode;

    adding a non-loop identifier to the basic event when it is determined that the engine memory comprising the basic event is an engine memory corresponding to the non-loop mode;

    using the basic event to which the non-loop identifier is added as a non-loop matching result;

    executing the basic event to obtain an execution result when it is determined that the engine memory comprising the basic event is an engine memory corresponding to the non-loop mode; and

    outputting the execution result.

View all claims
    ×
    ×

    Thank you for your feedback

    ×
    ×