EVENT STREAM PROCESSING SYSTEM, METHOD AND MACHINE-READABLE STORAGE
First Claim
1. An event stream processing system, comprising:
- a gateway device, comprising;
an event processing engine, processing a plurality of events of an event stream corresponded with a rule, comprising;
an event grouping unit, grouping the events corresponded with the rule;
a catch-collector, coupling to the event grouping unit, configured to store a first group event from the events;
a processor, coupling to the event grouping unit, configured to process a second group event; and
an event generator, integrating a first processing result of the first group event and a second processing result of the second group event and generating a derived event; and
at least one external module, coupling to the gateway device, each external module comprising;
an external processor, calculating the first group event and generating the first processing result.
1 Assignment
0 Petitions
Accused Products
Abstract
The present disclosure provides an event stream processing system, comprises a gateway device and an external module. The gateway device comprises an event processing engine, and the external module comprises external processor. The event processing engine comprises an event grouping unit, a catch-collector, a processor and an event generator. The event processing engine processes a plurality events of the event stream corresponded to a rule. The event grouping unit groups the events corresponded to the rule. The catch-collector couples to the event group unit, configured for storing a first group event. The processor couples to the event group unit, configured for processing a second group event. The external module calculates the first group event and generates a first processing result. The event generator integrates the first processing result of the first group event and a second processing result of the second group event and generates a derived event.
31 Citations
20 Claims
-
1. An event stream processing system, comprising:
a gateway device, comprising; an event processing engine, processing a plurality of events of an event stream corresponded with a rule, comprising; an event grouping unit, grouping the events corresponded with the rule; a catch-collector, coupling to the event grouping unit, configured to store a first group event from the events; a processor, coupling to the event grouping unit, configured to process a second group event; and an event generator, integrating a first processing result of the first group event and a second processing result of the second group event and generating a derived event; and at least one external module, coupling to the gateway device, each external module comprising; an external processor, calculating the first group event and generating the first processing result. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9)
-
10. An event stream processing method, used for an event stream processing system, the event stream processing system comprising a gateway device and at least one external module, the event stream processing method comprising:
-
filtering and grouping a plurality of events of an event stream corresponded with a rule via the gateway device; transmitting a first group event to at least one of external modules to calculate and calculating a second group event via the gateway device; generating and transmitting back a first processing result to the gateway device via the external module; and integrating the first processing result of the first group event and a second processing result of the second group event and generating a derived event via the gateway device. - View Dependent Claims (11, 12, 13, 14, 15, 16, 17, 18, 19)
-
-
20. A machine-readable storage, storing a code configured for implementing a process of event stream, and the code is implemented via a gateway device and an external module in the following steps:
-
filtering and grouping a plurality of events of an event stream corresponded to a rule; transmitting the first group event from the gateway device to at least one external module to calculate and calculating a second group event in the gateway device; generating and transmitting back a first processing result to the gateway device via the external module; and integrating a first processing result of the first group event and a second processing result of the second group event and generating a derived event.
-
Specification