Complex event processing method, apparatus, and system
First Claim
1. A complex event processing method comprising:
- at a complex event processing apparatus, receiving an input event sent by an event source, wherein the input event is triggered at the event source by an object, and the input event comprises an identifier of the object and an event type;
acquiring, according to a preset database, M mode rules corresponding to the event type, wherein each mode rule comprises one sending primary key, the preset database comprises at least one event type and mode rules corresponding to the event type, and M is greater than or equal to 1;
performing mode matching between the input event and the M mode rules separately to acquire N output events, wherein each output event comprises a sending primary key in a mode rule for acquiring each output event, wherein N is greater than or equal to 0, and N is less than or equal to M; and
in response to determining that N is greater than or equal to 1, sending at least one piece of event information to a real-time decision apparatus, wherein each piece of the event information that is sent comprises Q output events and indication information, wherein the Q output events are output events that are comprised in the N output events and have a same sending primary key, wherein Q is greater than or equal to 1, and the indication information comprises the identifier of the object, so that the real-time decision apparatus is instructed to send execution information of an execution action to the object.
1 Assignment
0 Petitions
Accused Products
Abstract
Embodiments of the present invention relate to the field of communications technologies, and provide a complex event processing method, apparatus, and system, so that when complex event processing is performed, a system requiring a synchronous response provides a synchronous response externally and avoids information flooding. A solution provided by the present invention includes: receiving an input event sent by an event source, where the input event includes an identifier of an object and an event type; acquiring, according to a preset database, M mode rules corresponding to the event type; performing mode matching between the input event and the M mode rules separately to acquire N output events; and if N is greater than or equal to 1, sending at least one piece of event information to a real-time decision apparatus, where each piece of the event information includes Q output events and indication information.
10 Citations
10 Claims
-
1. A complex event processing method comprising:
-
at a complex event processing apparatus, receiving an input event sent by an event source, wherein the input event is triggered at the event source by an object, and the input event comprises an identifier of the object and an event type; acquiring, according to a preset database, M mode rules corresponding to the event type, wherein each mode rule comprises one sending primary key, the preset database comprises at least one event type and mode rules corresponding to the event type, and M is greater than or equal to 1; performing mode matching between the input event and the M mode rules separately to acquire N output events, wherein each output event comprises a sending primary key in a mode rule for acquiring each output event, wherein N is greater than or equal to 0, and N is less than or equal to M; and in response to determining that N is greater than or equal to 1, sending at least one piece of event information to a real-time decision apparatus, wherein each piece of the event information that is sent comprises Q output events and indication information, wherein the Q output events are output events that are comprised in the N output events and have a same sending primary key, wherein Q is greater than or equal to 1, and the indication information comprises the identifier of the object, so that the real-time decision apparatus is instructed to send execution information of an execution action to the object. - View Dependent Claims (2, 3, 4, 5, 6)
-
-
7. A complex event processing apparatus comprising:
-
at least one communications bus configured to implement connection and mutual communication between components; and a receiver configured to receive an input event sent by an event source, wherein the input event is triggered at the event source by an object, and the input event comprises an identifier of the object and an event type; at least one processor; and a program for execution in the at least one processor, wherein the program comprises instructions for acquiring, according to a preset database, M mode rules corresponding to the event type, wherein each mode rule comprises one sending primary key, the preset database comprises at least one event type and mode rules corresponding to the event type, and M is greater than or equal to 1; and performing mode matching between the input event and the M mode rules separately to acquire N output events, wherein each output event comprises a sending primary key in a mode rule for acquiring each output event, wherein N is greater than or equal to 0, and N is less than or equal to M; in response to determining that N is greater than or equal to 1, sending at least one piece of event information to a real-time decision apparatus, wherein each piece of the event information comprises Q output events and indication information, wherein the Q output events are output events that are comprised in the N output events and have a same sending primary key, wherein Q is greater than or equal to 1, and the indication information comprises the identifier of the object, so that the real-time decision apparatus is instructed to send execution information of an execution action to the object. - View Dependent Claims (8, 9)
-
-
10. A complex event processing system, comprising:
-
a complex event processing apparatus configured to receive an input event sent by an event source, wherein the input event is triggered at the event source by an object, and the input event comprises an identifier of the object and an event type; acquire, according to a preset database, M mode rules corresponding to the event type, wherein each mode rule comprises one sending primary key, the preset database comprises at least one event type and mode rules corresponding to the event type, and M is greater than or equal to 1; perform mode matching between the input event and the M mode rules separately to acquire N output events, wherein each output event comprises a sending primary key in a mode rule for acquiring each output event, N is greater than or equal to 0, and N is less than or equal to M;
whereinin response to determining that N is greater than or equal to 1, send event information to a real-time decision apparatus, wherein the event information comprises Q output events and indication information, wherein the Q output events are output events that are comprised in the N output events and have a same sending primary key, wherein Q is greater than or equal to 1, and the indication information comprises the identifier of the object, so that the real-time decision apparatus is instructed to send execution information of an execution action to the object; the real-time decision apparatus configured to receive the event information sent by the complex event processing apparatus; match each event in the event information with decision rules in the preset database separately to acquire P execution actions, wherein P is greater than or equal to 1, and the preset database comprises at least one decision rule and an execution action corresponding to the at least one decision rule; and send, according to the indication information, execution information for executing at least one execution action in the P execution actions.
-
Specification