Message bus-based streaming rules engine
First Claim
Patent Images
1. A data analysis system, comprising:
- a communication interface configured to receive log data; and
a processor coupled to the communication interface and configured to;
parse the log data to generate a data unit comprising a data value; and
send the data unit via a message bus to a rule actor configured to apply a rule based at least in part on the data value;
wherein;
the rule actor comprises one of a plurality of rule actors each associated with a corresponding rule;
each rule actor is configured to implement a corresponding rule based at least in part on a rule definition; and
the processor is further configured to compile the rule definition, including by creating a class based on which the rule actor is instantiated.
1 Assignment
0 Petitions
Accused Products
Abstract
A message bus-based streaming rules engine is disclosed. In various embodiments, a data analysis system as disclosed herein includes a communication interface configured to receive log data; and a processor coupled to the communication interface and configured to: parse the log data to generate a data unit comprising a data value; and send the data unit via a message bus to a rule actor configured to apply a rule based at least in part on the data value.
-
Citations
20 Claims
-
1. A data analysis system, comprising:
-
a communication interface configured to receive log data; and a processor coupled to the communication interface and configured to; parse the log data to generate a data unit comprising a data value; and send the data unit via a message bus to a rule actor configured to apply a rule based at least in part on the data value; wherein; the rule actor comprises one of a plurality of rule actors each associated with a corresponding rule; each rule actor is configured to implement a corresponding rule based at least in part on a rule definition; and the processor is further configured to compile the rule definition, including by creating a class based on which the rule actor is instantiated. - View Dependent Claims (2, 3, 4, 5, 6, 7, 10, 11, 12)
-
-
8. A data analysis system, comprising:
-
a communication interface configured to receive log data; and a processor coupled to the communication interface and configured to; parse the log data to generate a data unit comprising a data value; and send the data unit via a message bus to a rule actor configured to apply a rule based at least in part on the data value; wherein compiling the rule definition includes configuring a router to route the data unit to the rule actor based at least in part on the presence of the data value in the data unit.
-
-
9. A data analysis system, comprising:
-
a communication interface configured to receive log data; and a processor coupled to the communication interface and configured to; parse the log data to generate a data unit comprising a data value; and send the data unit via a message bus to a rule actor configured to apply a rule based at least in part on the data value; wherein the rule actor is based at least in part on a rule definition and wherein the processor is configured to receive a modified version of the rule definition and to replace the rule actor with a modified rule actor based on the modified version of the rule definition.
-
-
13. A method to analyze log data, comprising:
-
receiving log data via a communication interface; using a processor coupled to the communication interface to; parse the log data to generate a data unit comprising a data value; and send the data unit via a message bus to a rule actor configured to apply a rule based at least in part on the data value wherein; the rule actor comprises one of a plurality of rule actors each associated with a corresponding rule; each rule actor is configured to implement a corresponding rule based at least in part on a rule definition; and the method further includes using the processor to compile the rule definition, including by creating a class based on which the rule actor is instantiated. - View Dependent Claims (14, 15, 16)
-
-
17. A computer program product to analyze log data, the computer program product being embodied in a non-transitory computer readable medium and comprising computer instructions for:
-
receiving log data; parsing the log data to generate a data unit comprising a data value; and sending the data unit via a message bus to a rule actor configured to apply a rule based at least in part on the data value; wherein; the rule actor comprises one of a plurality of rule actors each associated with a corresponding rule; each rule actor is configured to implement a corresponding rule based at least in part on a rule definition; and the computer program product further includes computer instructions to compile the rule definition, including by creating a class based on which the rule actor is instantiated. - View Dependent Claims (18, 19, 20)
-
Specification