Alerting system having a network of stateful transformation nodes

• US 10,275,298 B2
• Filed: 10/12/2016
• Issued: 04/30/2019
• Est. Priority Date: 10/12/2016
• Status: Active Grant

• Current Assignee: Salesforce.com, Inc.
• Original Assignee: Salesforce.com, Inc.
• Inventors: Melanchenko, Dmytro
• Primary Examiner(s): Iqbal, Nadeem
• Application Number:
  US15/291,858
• Publication Number:
  US 20180101429A1
• Time in Patent Office: 930 Days
• CPC Class Codes: G06F 11/0772 Means for error signaling, e.g. using interrupts, exception flags, dedicated error registers

Abstract

An alerting system is provided that includes a network of transformation nodes, and state change processors. The transformation nodes include input transformation nodes, output transformation nodes, and intermediate nodes that connect the input and output transformation nodes. Each input transformation node can receive an events stream, and is coupled to one of the output transformation nodes by one or more intermediate transformation nodes. Each transformation node (except the input transformation nodes) can receive state updates from those transformation nodes that it subscribes to. Each output transformation node can generate a check result when stored state information for each of the transformation nodes that the output transformation node subscribes to collectively indicates that the check result should be generated. Each output transformation node is coupled to one of the state change processors that can determine whether the check results should trigger an action, and if so, can then perform an action.

Claims

1. A system, comprising:

an events producer comprising one or more hardware processors configured to generate events that are part of an events stream;

an alerting system that is configured to run in a reactive streaming mode on a server system comprising processing hardware, the alerting system configured to directly process the events and to generate actions, the alerting system comprising;

a streams transformer comprising;

a network of transformation nodes comprising;

an input transformation node configured to receive at least some of the events;

an output transformation node; and

a plurality of intermediate transformation nodes coupled between the input transformation node and the output transformation node, wherein each of the intermediate transformation nodes comprises;

a state module for each transformation node that the intermediate transformation node subscribes to, wherein each state module is configured to;

receive state updates from any of the transformation nodes that the intermediate transformation node is subscribed to;

store each of the state updates as state information; and

update state information for each transformation node that the intermediate transformation node is connected to each time a state update is received from another transformation node that the intermediate transformation node is connected to;

a transformation rule for that intermediate transformation node; and

a re-computation trigger function for that intermediate transformation node that is configured to;

determine whether state information for that intermediate transformation node is to be updated only when state information stored by any of the state modules changes; and

call the transformation rule to re-compute the state information for that intermediate transformation node, wherein the transformation rule is configured to communicate a state update comprising the re-computed state information to all transformation nodes that subscribe to the intermediate transformation node; and

wherein the output transformation node is configured to;

generate a check result when stored state information for each of the transformation nodes that the output transformation node subscribes to collectively indicates that the check result should be generated; and

a state change processor configured to;

perform an action when it is determined that the check result should trigger the action; and

a consumer system that is configured to consume and react to the action generated by the alerting system.

2. The system of claim 1, wherein the intermediate transformation node subscribes to at least the input transformation node and is configured to receive state updates from at least the input transformation node, and

wherein the output transformation node subscribes to at least the intermediate transformation node and is configured to receive state updates from at least the intermediate transformation node.

3. The system of claim 2, wherein the input transformation node comprises:

an input connector that is configured to receive the events stream from the events producer that the input transformation node subscribes to, wherein the events stream includes time series of events received from the events producer, wherein each event represents something that has happened; and

a transformation rule, for that input transformation node, that is configured to;

process the events and compute state information for the input transformation node in accordance with the transformation rule, and

provide state updates that indicate the state information to all transformation nodes that subscribe to the input transformation node.

4. The system of claim 1, wherein each state module comprises:

a memory element that stores current state information for a particular transformation node that the intermediate transformation node subscribes to; and

a state updater that is configured to;

receive state updates from the particular transformation node;

compare, each time a state update is received, new state information that is indicated in the state update with the current state information stored at the memory element; and

update the current state information that is stored at the memory element with the new state information that is indicated in the state update.

5. The system of claim 1, wherein the transformation rule of each intermediate transformation node is configured to:

compute state information for that intermediate transformation node in accordance with the transformation rule and provide state updates that indicate the state information to all transformation nodes that subscribe to that intermediate transformation node, and wherein the re-computation trigger function of each intermediate transformation node is configured to;

determine whether state information for that intermediate transformation node is to be updated based on current state information stored by each of the state modules for each of the transformation nodes that the intermediate transformation node subscribes to when state information stored by any of the state modules changes each time a state update is received from at least one of the transformation nodes that the intermediate transformation node subscribes to.

6. The system of claim 1, wherein the transformation rule is a rule that describes how state information for each transformation node that the intermediate transformation node subscribes to is to be transformed into state information for the intermediate transformation node.

7. The system of claim 1, wherein the transformation rule of the intermediate transformation node is defined based on one or more operations.

8. The system of claim 7, wherein the one or more operations that define the transformation rule of the intermediate transformation node comprise at least one of:

logical operations;

mathematical operations;

analytic operations;

filter-based operations;

buffered operations;

or any combination thereof.

9. The system of claim 1, wherein the output transformation node, comprises:

a state module for each transformation node that the output transformation node subscribes to, wherein each state module is configured to;

receive state updates from any of the transformation nodes the output transformation node is subscribed to;

store each of the state updates as state information; and

update state information for each transformation node that the output transformation node is connected to each time a state update is received from another transformation node that the output transformation node is connected to

a transformation rule; and

a re-computation trigger function that is configured to;

determine, based on the current state information stored by each of the state modules when state information stored by any of the state modules changes, whether state information of the output transformation node is to be updated; and

call the transformation rule to;

re-compute the state information of the output transformation node in accordance with the transformation rule of the output transformation node, and output a check result that corresponds to the re-computed state information,

wherein the transformation rule is configured to communicate the check result to the state change processor when stored state information for each of the transformation nodes that the output transformation node subscribes to collectively indicates that the check result should be generated,

wherein the state change processor is further configured to;

receive the check results from the output transformation node;

determine, each time a check result is received, whether that check result should trigger an action; and

then perform the action when it is determined that the check result should trigger the action.

10. The system of claim 1, wherein the state change processor comprises:

a state module that is configured to receive the check result from the transformation rule of the output transformation node; and

to store and update check results from the output transformation node each time a check result is received;

an action trigger function configured to;

determine whether the check result or the updated check results provided from the state module should trigger an action; and

communicate a trigger command when it determines that the check result or the updated check results should trigger the action; and

an action function that performs the action in response to the trigger command.

11. The system of claim 1, wherein the action performed by the action function comprises:

(1) generation and communication of an alert signal or message;

(2) generation and communication of command to trigger an action, or

(3) an action triggered from a signal, message or command.

12. The system of claim 1, wherein the action performed by the action function comprises:

a call to an application programming interface (API).

13. The system of claim 1, wherein a path that includes the input transformation node, one or more of the intermediate transformation nodes and the output transformation node defines a check performed that produces the check result.

14. A system, comprising:

an events producer comprising one or more hardware processors configured to generate events that are part of an events stream;

an alerting system that is configured to run in a reactive streaming mode on a server system comprising processing hardware, the alerting system configured to directly process the events and to generate actions, the alerting system comprising;

a streams transformer comprising;

a network of transformation nodes comprising;

a plurality of input transformation nodes each being configured to receive a particular events stream comprising at least some of the events;

a plurality of output transformation nodes; and

a plurality of intermediate transformation nodes coupled between the input transformation nodes and the output transformation nodes, wherein each of the intermediate transformation nodes and output transformation nodes subscribe to and receive state updates from one or more of the transformation nodes that are part of the network;

wherein each of the intermediate transformation nodes is configured to;

generate a state update when stored state information for the transformation nodes that the intermediate transformation node subscribes to collectively indicates that the state update should be generated, wherein each of the intermediate transformation nodes comprises;

a state module for each transformation node that the intermediate transformation node subscribes to, wherein each state module is configured to;

receive state updates from any of the transformation nodes that the intermediate transformation node is subscribed to;

store each of the state updates as state information; and

update state information for each transformation node that the intermediate transformation node is connected to each time a state update is received from another transformation node that the intermediate transformation node is connected to;

a transformation rule for that intermediate transformation node; and

a re-computation trigger function for that intermediate transformation node that is configured to;

determine whether state information for that intermediate transformation node is to be updated only when state information stored by any of the state modules changes; and

call the transformation rule to re-compute the state information for that intermediate transformation node, wherein the transformation rule is configured to communicate a state update comprising the re-computed state information to all transformation nodes that subscribe to the intermediate transformation node; and

wherein each of the output transformation nodes is configured to;

generate a check result when stored state information for each of the transformation nodes that the output transformation node subscribes to collectively indicates that the check result should be generated; and

a plurality of state change processors each being configured to;

perform an action when that state change processor determines, based on a check result received from a corresponding output transformation node, that the check result should trigger the action; and

a consumer system that is configured to consume and react to the action generated by the alerting system.

15. The system of claim 14, wherein the network of transformation nodes comprises a plurality of different paths, wherein each path comprises:

a particular input transformation node, one or more of the intermediate transformation nodes and a particular output transformation node, wherein each path defines a check performed that produces a check result.

16. The system of claim 14, wherein each the input transformation node comprises:

a transformation rule that is configured to;

compute state information, based on events received in an events stream from the events producer, and provide state updates that indicate the state information to all transformation nodes that subscribe to that input transformation node.

17. The system of claim 14, wherein each of the intermediate transformation nodes and the output transformation nodes are configured to:

store and update state information for each transformation node that they subscribe to, wherein the state information is updated each time a state update is received from one of the transformation nodes that they subscribe to; and

determine whether state information for that intermediate transformation node or a check result for that output transformation node should be updated based on state information for each of the transformation nodes that the intermediate transformation node or output transformation node subscribes to, respectively.

18. The system of claim 17,

wherein each transformation rule re-computes the state information when current state information, stored at that intermediate transformation node for transformation nodes that the intermediate transformation node subscribes to, indicates that state information of that intermediate transformation node is to be updated.

19. The system of claim 17, wherein the output transformation node, comprises:

a transformation rule configured to;

re-compute state information of that intermediate transformation node in accordance with the transformation rule of that output transformation node, wherein the transformation rule re-computes the state information when current state information, stored at that intermediate transformation node for transformation nodes that the intermediate transformation node subscribes to, indicates that state information of that intermediate transformation node is to be updated, and

communicate a check result to a corresponding state change processor, wherein the check result comprises the re-computed state information.

20. A method performed by an alerting system that is configured to run in a reactive streaming mode on a server system comprising processing hardware, wherein the alerting system comprises at least an input transformation node, an output transformation node and a plurality of intermediate transformation nodes coupled between the input transformation node and the output transformation node, the method comprising:

receiving, at the alerting system from an events producer comprising one or more hardware processors configured to generate events, an events stream comprising at least some of the events;

receiving, at each of the intermediate transformation nodes, state updates from any of the transformation nodes that the intermediate transformation node is subscribed to;

storing, at each of the intermediate transformation nodes, each of the state updates as state information;

updating, at each of the intermediate transformation nodes, state information for each transformation node that the intermediate transformation node is connected to each time a state update is received from another transformation node that the intermediate transformation node is connected to;

determining, at each of the intermediate transformation nodes, whether state information for that intermediate transformation node is to be updated only when state information stored by any of the state modules changes;

calling, at each of the intermediate transformation nodes, a transformation rule for that intermediate transformation node to re-compute the state information for that intermediate transformation node;

communicating, from each transformation rule for each intermediate transformation node to all transformation nodes that subscribe to that intermediate transformation node, a state update comprising re-computed state information;

generating a check result at the output transformation node when stored state information for each of the transformation nodes that the output transformation node subscribes to collectively indicates that the check result should be generated;

determining at a state change processor whether the check result should trigger an action;

performing the action at the state change processor when it is determined that the check result should trigger the action; and

at a consumer system;

consuming and reacting to the action generated by the alerting system.