Processing events generated by internet of things (IoT)
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.
1. A method, comprising:
performing, by a state processing network configured to implement a multi-step progression of monitoring a first event generating device based on a declarative specification of stateful event processing, a transition trigger to cause a state transition to or from a state in the multi-step progression based on a status of the first event generating device, wherein the stateful event processing corresponds to the multi-step progression, the declarative specification includes the state in the multi-step progression and the transition trigger, and the first event generating device is a network connected device;
triggering, by the state processing network, an action responsive to the state transition based on data associated with a first event being processed,
compiling monitoring information corresponding to a second event that indicates an anomalous performance of the first event generating device;
compiling monitoring information corresponding to a plurality of events comprising an event history of anomalous performances of a plurality of additional event generating devices; and
triggering, via the state processing network, an additional action based on whether a pattern of the anomalous performance of the first event generating device based on a historical frequency is in the event history of the anomalous performances of the plurality of additional event generating devices.
2. The method of claim 1 , further comprising:
configuring the first event generating device and the plurality of additional event generating devices under a device deployment scheme, wherein the first event generating device is an anomalous device and the plurality of additional event generating devices is a plurality of other anomalous devices;
determining, via the state processing network, the historical frequency of the anomalous performances of the plurality of other anomalous devices; and
triggering, via the state processing network, a potential mismatch action when the historical frequency meets a threshold condition.
3. The method of claim 2 , wherein the anomalous device is a smart uninterruptible power supply (UPS) device and the anomalous performance is a spike in power voltage.
4. The method of claim 2 , wherein the event history of the anomalous performances of the plurality of other anomalous devices includes a surge in power load, a swing in power voltage, circuit breaks, a spike in power voltage, low battery voltage, or battery failure.
5. The method of claim 1 , further comprising:
configuring the plurality of additional event generating devices under a device deployment scheme, wherein the first event generating device is an anomalous device and the plurality of additional event generating devices is a plurality of other anomalous devices;
determining, via the state processing network, the historical frequency of the anomalous performances of the plurality of other anomalous devices based on a threshold condition and a time period condition; and
triggering, via the state processing network, a false positive action when the historical frequency fails to meets at least one of the threshold condition or the time period condition.
6. The method of claim 5 , wherein the anomalous device is a smart thermostat and the anomalous performance is a low battery voltage.
7. The method of claim 5 , wherein the event history of the anomalous performances of the plurality of other anomalous devices includes low connectivity signal, lengthy constant readings, low battery voltage or battery failure.
8. A system comprising:
a memory; and
one or more processors and/or circuits coupled to the memory and configured to:
perform, by a state processing network configured to implement a multi-step progression of monitoring a first event generating device based on a declarative specification of stateful event processing, a transition trigger to cause a state transition to or from a state in the multi-step progression based on a status of the first event generating device, wherein the stateful event processing corresponds to the multi-step progression, the declarative specification includes the state in the multi-step progression and the transition trigger, and the first event generating device is a network connected device;
trigger, by the state processing network, an action responsive to the state transition based on data from a first event being processed;
compile monitoring information corresponding to a second event that indicates an anomalous performance of the first event generating device;
compile monitoring information corresponding to a plurality of events comprising an event history of anomalous performances of a plurality of additional event generating devices; and
trigger, via the state processing network, an additional action based on whether a pattern of the anomalous performance of the first event generating device based on a historical frequency is in the event history of the anomalous performances of the plurality of additional event generating devices.
9. The system of claim 8 , wherein the transition trigger is an event based trigger that causes the state transition based upon registering of the first event, and the declarative specification includes a definition of a condition applicable to the event based trigger.
10. The system of claim 8 , wherein the transition trigger is a time based trigger that causes the state transition based upon an overrunning of a timer.
11. The system of claim 8 , wherein the one or more processors and/or circuits are further configured to:
configure the first event generating device and the plurality of event generating devices under a device deployment scheme, wherein the first event generating device is an anomalous device and the plurality of additional event generating devices is a plurality of other anomalous devices;
determine, via the state processing network, the historical frequency of the anomalous performances of the plurality of other anomalous devices; and
trigger, via the state processing network, a potential mismatch action when the historical frequency meets a threshold condition.
12. The system of claim 11 , wherein the anomalous device is a smart uninterruptible power supply (UPS) device and the anomalous performance is a spike in power voltage.
13. The system of claim 11 , wherein the event history of the anomalous performances of the plurality of other anomalous devices includes surge in power load, swing in power voltage, circuit breaks, spike in power voltage, low battery voltage or battery failure.
14. The system of claim 8 , wherein the one or more processors and/or circuits are further configured to:
configure the plurality of additional event generating devices and a plurality of event generating devices under a device deployment scheme, wherein the first event generating device is an anomalous device and the plurality of additional event generating devices is a plurality of other anomalous devices;
determine, via the state processing network, the historical frequency of the anomalous performances of the plurality of other anomalous devices based on a threshold condition and a time period condition; and
trigger, via the state processing network, a false positive action when the historical frequency fails to meets at least one of the threshold condition or the time period condition.
15. The system of claim 14 , wherein the anomalous device is a smart thermostat and the anomalous performance is a low battery voltage.
16. The system of claim 14 , wherein the event history of the anomalous performances of the plurality of other anomalous devices includes low connectivity signal, lengthy constant readings, low battery voltage or battery failure.
17. A non-transitory computer-readable device having instructions stored thereon that, when executed by at least one computing device, cause the at least one computing device to perform operations comprising:
performing, by a state processing network configured to implement a multi-step progression of monitoring a first event generating device based on a declarative specification of stateful event processing, a transition trigger to cause a state transition to or from a state in the multi-step progression based on a status of the first event generating device, wherein the stateful event processing corresponds to the multi-step progression, the declarative specification includes the state in the multi-step progression and the transition trigger, and the first event generating device is a network connected device;
triggering, by the state processing network, an action responsive to the state transition based on data from a first event being processed;
compiling monitoring information corresponding to a second event that indicates an anomalous performance of the first event generating device;
compiling monitoring information corresponding to a plurality of events comprising an event history of anomalous performances of a plurality of additional event generating devices; and
triggering, via the state processing network, an additional action based on whether a pattern of the anomalous performance of the first event generating device based on a historical frequency is in the event history of the anomalous performances of the plurality of additional event generating devices.
18. The non-transitory computer-readable device of claim 17 , wherein the operations further comprise:
configuring the first event generating device and a plurality of event generated devices under a device deployment scheme, wherein the first event generating device is an anomalous device and the plurality of additional event generating devices is a plurality of other anomalous devices;
determining, via the state processing network, the historical frequency of the anomalous performances of the plurality of other anomalous devices; and
triggering, via the state processing network, a potential mismatch action when the historical frequency meets a threshold condition.
19. The non-transitory computer-readable device of claim 17 , wherein the operations further comprise:
configuring the plurality of additional event generating devices and a plurality of event generated devices under a device deployment scheme, wherein the first event generating device is an anomalous device and the plurality of additional event generating devices is a plurality of other anomalous devices;
determining, via the state processing network, the historical frequency of the anomalous performances of the plurality of other anomalous devices based on a threshold condition and a time period condition; and
triggering, via the state processing network, a false positive action when the historical frequency fails to meets at least one of the threshold condition or the time period condition.