Processing events generated by internet of things (IoT)
First Claim
1. A method of processing events generated by Internet of Things (IoT) devices, the method including:
- storing a machine-readable declarative specification of stateful event processing of an automated multi-step progression of monitoring of IoT devices that generate events, wherein the declarative specification includes;
states in the multi-step progression;
time based transition triggers;
event based transition triggers;
definitions of conditions applicable to the event based triggers; and
alternative actions responsive to state transitions caused by the time based transition triggers and the event based transition triggers;
compiling into tangible memory, in response to the declarative specification;
a state processing network that implements the automated multi-step progression of monitoring the events generated by the IoT devices, the time based transition triggers and the event based transition triggers after being initiated by the IoT devices, and a first plurality of data structures that record monitoring status of the IoT devices, wherein the state processing network further selects an alternative action to trigger, and triggers the alternative action using at least some data from a particular event being processed;
compiling a second plurality of data structures corresponding to a first event that indicates a first anomalous performance of a particular IoT device installed with a plurality of other IoT devices under a device deployment scheme;
compiling a third plurality of data structures corresponding to event history indicating various anomalous performances of the plurality of other IoT devices at different times;
using the state processing network to determine historical frequency of the first anomalous performance among the plurality of other IoT devices by applying a definition of a threshold condition to the first event, the event history, and variables derived from the first event and the event history; and
using the state processing network to select and trigger a potential mismatch action when the historical frequency meets the threshold condition, wherein the potential mismatch action represents a potential mismatch between the particular IoT device and the plurality of other IoT devices and the device deployment scheme.
1 Assignment
0 Petitions
Accused Products
Abstract
The technology disclosed relates to processing events generated by Internet of Things (IoT) devices. In particular, it relates to storing a machine-readable declarative specification of stateful event processing of an automated multi-step progression of monitoring of Internet of Things (IoT) devices that generate events. It includes compiling into tangible memory, in response to the declarative specification, a state processing network that implements a multi-step progression of monitoring events generated by the IoT devices. The state processing network implements both the time based transition triggers and the event based transition triggers after being initiated by the IoT devices. Further, data structures, which record monitoring status of particular IoT devices, are compiled. Finally, the state processing network further selects an alternative action to trigger, and triggers the selected action using at least some data from a particular event being processed.
-
Citations
17 Claims
-
1. A method of processing events generated by Internet of Things (IoT) devices, the method including:
-
storing a machine-readable declarative specification of stateful event processing of an automated multi-step progression of monitoring of IoT devices that generate events, wherein the declarative specification includes; states in the multi-step progression; time based transition triggers; event based transition triggers; definitions of conditions applicable to the event based triggers; and alternative actions responsive to state transitions caused by the time based transition triggers and the event based transition triggers; compiling into tangible memory, in response to the declarative specification; a state processing network that implements the automated multi-step progression of monitoring the events generated by the IoT devices, the time based transition triggers and the event based transition triggers after being initiated by the IoT devices, and a first plurality of data structures that record monitoring status of the IoT devices, wherein the state processing network further selects an alternative action to trigger, and triggers the alternative action using at least some data from a particular event being processed; compiling a second plurality of data structures corresponding to a first event that indicates a first anomalous performance of a particular IoT device installed with a plurality of other IoT devices under a device deployment scheme; compiling a third plurality of data structures corresponding to event history indicating various anomalous performances of the plurality of other IoT devices at different times; using the state processing network to determine historical frequency of the first anomalous performance among the plurality of other IoT devices by applying a definition of a threshold condition to the first event, the event history, and variables derived from the first event and the event history; and using the state processing network to select and trigger a potential mismatch action when the historical frequency meets the threshold condition, wherein the potential mismatch action represents a potential mismatch between the particular IoT device and the plurality of other IoT devices and the device deployment scheme. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. A non-transitory computer readable storage medium impressed with computer program instructions to process events generated by Internet of Things (IoT) devices, the instructions, when executed on a processor, implement a method comprising:
-
storing a machine-readable declarative specification of stateful event processing of an automated multi-step progression of monitoring of IoT devices that generate events, wherein the declarative specification includes; states in the multi-step progression; time based transition triggers; event based transition triggers; definitions of conditions applicable to the event based triggers; and alternative actions responsive to state transitions caused by the time based transition triggers and the event based transition triggers; compiling into tangible memory, in response to the declarative specification; a state processing network that implements a multi-step progression of monitoring events generated by the IoT devices, the time based transition triggers and the event based transition triggers after being initiated by the IoT devices, and a first plurality of data structures that record monitoring status of the IoT devices, wherein the state processing network further selects an alternative action to trigger, and triggers the alternative action using at least some data from a particular event being processed; compiling a second plurality of data structures corresponding to a first event that indicates a first anomalous performance of a particular IoT device; compiling a third plurality of data structures corresponding to event history indicating various anomalous performances of the particular IoT device at different times; using the state processing network to determine historical frequency of the first anomalous performance within a predetermined time window by applying a definition of a threshold condition and a time period condition to the first event and the event history and to variables derived from the first event and the event history; and using the state processing network to select and trigger a false positive action when the historical frequency fails to meet the threshold condition and the time period condition. - View Dependent Claims (9, 10, 11, 12, 13, 14)
-
-
15. A system including one or more processors coupled to memory, the memory loaded with computer instructions to process events generated by Internet of Things (IoT) devices, the instructions, when executed on the processors, implement actions comprising:
-
storing a machine-readable declarative specification of stateful event processing of an automated multi-step progression of monitoring of Internet of Things (IoT) devices that generate events, wherein the declarative specification includes; states in the multi-step progression; time based transition triggers; event based transition triggers; definitions of conditions applicable to the event based triggers; and alternative actions responsive to state transitions caused by the time based transition triggers and the event based transition triggers; compiling into tangible memory, in response to the declarative specification; a state processing network that implements a multi-step progression of monitoring events generated by the IoT devices, the time based transition triggers and the event based transition triggers after being initiated by the IoT devices, and a first plurality of data structures that record monitoring status of the IoT devices; and wherein the state processing network further selects an alternative action to trigger, and triggers the alternative action using at least some data from a particular event being processed; compiling a second plurality of data structures corresponding to a first event that indicates a first anomalous performance of the particular IoT device; compiling a third plurality of data structures corresponding to event history indicating various anomalous performances of the particular IoT device at different times; using the state processing network to determine historical frequency of the first anomalous performance within a predetermined time window by applying a definition of a threshold condition and a time period condition to the first event and the event history and to variables derived from the first event and the event history; and using the state processing network to select and trigger a false positive action when the historical frequency fails to meet the threshold condition and the time period condition. - View Dependent Claims (16, 17)
-
Specification