PROCESSING EVENTS GENERATED BY INTERNET OF THINGS (IoT)

• US 20170083386A1
• Filed: 04/01/2016
• Published: 03/23/2017
• Est. Priority Date: 09/17/2015
• Status: Active Grant

• Current Assignee: Salesforce.com, Inc.
• Original Assignee: Salesforce.com, Inc.
• Inventors: Wing, Aubrey, Mamut, Tatyana, Che, Arthur Ping-Tak, Chin, Tiffany Joy, Poon, Amy Kar Sin, Layman, Andrew
• Granted Patent: US 10,324,773 B2
• Time in Patent Office: Days
• CPC Class Codes: G06F 1/30 Means for acting in the event of power-supply failure or interruption, e.g. power-supply fluctuations for resetting only G06F1/24
• CPC Class Codes: G06Q 10/10 Office automation; Time management
• CPC Class Codes: G06Q 50/01 Social networking

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.

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 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 state processing network implements both the time based transition triggers and the event based transition triggers after being initiated by the IoT devices, and

data structures that record monitoring status of particular IoT devices; and

wherein 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.

2. The method of claim 1, wherein the state processing network further selects and triggers a global action using at least some data from a particular event being processed.

3. The method of claim 1, wherein a particular IoT device is installed with a plurality of other IoT devices under a device deployment scheme, further including:

compiling data structures corresponding to a first event that indicates a first anomalous performance of the particular IoT device;

compiling data structures corresponding to event history indicating various anomalous performances of the other IoT devices at different times;

using the state processing network to determine historical frequency of the first anomalous performance among the other IoT devices by applying a definition of a threshold 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 potential mismatch action when the historical frequency meets the threshold condition, wherein the action represents a potential mismatch between the particular and other IoT devices and the device deployment scheme.

4. The method of claim 3, wherein the particular IoT device is a smart uninterruptible power supply (UPS) device and the first anomalous performance is spike in power voltage.

5. The method of claim 3, wherein the event history of the other IoT devices includes surge in power load, swing in power voltage, circuit breaks, spike in power voltage, low battery voltage and battery failure.

6. The method of claim 1, further including:

compiling data structures corresponding to a first event that indicates a first anomalous performance of the particular IoT device;

compiling 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.

7. The method of claim 6, wherein the particular IoT device is a smart thermostat and the first anomalous performance is low battery voltage.

8. The method of claim 6, wherein the event history of the other IoT devices includes low connectivity signal, lengthy constant readings, low battery voltage and battery failure.

9. 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 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 state processing network implements both the time based transition triggers and the event based transition triggers after being initiated by the IoT devices, and

data structures that record monitoring status of particular IoT devices; and

wherein 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.

10. The non-transitory computer readable storage medium of claim 9, wherein the state processing network further selects and triggers a global action using at least some data from a particular event being processed.

11. The non-transitory computer readable storage medium of claim 9, wherein a particular IoT device is installed with a plurality of other IoT devices under a device deployment scheme, implementing the method further comprising:

compiling data structures corresponding to a first event that indicates a first anomalous performance of the particular IoT device;

compiling data structures corresponding to event history indicating various anomalous performances of the other IoT devices at different times;

using the state processing network to determine historical frequency of the first anomalous performance among the other IoT devices by applying a definition of a threshold 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 potential mismatch action when the historical frequency meets the threshold condition, wherein the action represents a potential mismatch between the particular and other IoT devices and the device deployment scheme.

12. The non-transitory computer readable storage medium of claim 11, wherein the particular IoT device is a smart uninterruptible power supply (UPS) device and the first anomalous performance is spike in power voltage.

13. The non-transitory computer readable storage medium of claim 11, wherein the event history of the other IoT devices includes surge in power load, swing in power voltage, circuit breaks, spike in power voltage, low battery voltage and battery failure.

14. The non-transitory computer readable storage medium of claim 9, implementing the method further comprising:

compiling data structures corresponding to a first event that indicates a first anomalous performance of the particular IoT device;

compiling 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.

15. The non-transitory computer readable storage medium of claim 14, wherein the particular IoT device is a smart thermostat and the first anomalous performance is low battery voltage.

16. The non-transitory computer readable storage medium of claim 14, wherein the event history of the other IoT devices includes low connectivity signal, lengthy constant readings, low battery voltage and battery failure.

17. 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 state processing network implements both the time based transition triggers and the event based transition triggers after being initiated by the IoT devices, and

data structures that record monitoring status of particular IoT devices; and

wherein 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.

18. The system of claim 17, wherein the state processing network further selects and triggers a global action using at least some data from a particular event being processed.

19. The system of claim 17, wherein a particular IoT device is installed with a plurality of other IoT devices under a device deployment scheme, further implementing actions comprising:

compiling data structures corresponding to a first event that indicates a first anomalous performance of the particular IoT device;

compiling data structures corresponding to event history indicating various anomalous performances of the other IoT devices at different times;

using the state processing network to determine historical frequency of the first anomalous performance among the other IoT devices by applying a definition of a threshold 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 potential mismatch action when the historical frequency meets the threshold condition, wherein the action represents a potential mismatch between the particular and other IoT devices and the device deployment scheme.

20. The system of claim 17, further implementing actions comprising:

compiling data structures corresponding to a first event that indicates a first anomalous performance of the particular IoT device;

compiling 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.