Techniques for activation triggering using time-series based event data
Aspects of the present disclosure relate to detecting occurrence of triggers related to properties of objects indicated in event data in a discoverable event stream. These techniques may include identifying a namespace associated with an activation trigger, and identifying a plurality of time-series based objects of a discoverable event stream associated with the namespace. The techniques may further include determining that an activation rule is met over the plurality of time-series based objects. Additionally, the techniques may include transmitting an activation trigger event to an activation component, the activation trigger event including a generic activation identifier identifying an action to perform, and an actor identifier identifying an actor to perform the action.
1 . A method comprising:
identifying a namespace associated with an activation trigger;
identifying a plurality of time-series based events of a discoverable event stream associated with the namespace, wherein the discoverable event stream includes the plurality of time-series based events, received from multiple objects, in a single stream ordered by time;
determining that an activation rule is met over the plurality of time-series based events;
publishing an activation trigger event to the discoverable event stream, the activation trigger event including a generic activation identifier identifying an action to perform, and an actor identifier identifying an actor to perform the action;
obtaining, based on monitoring the discoverable event stream, the activation trigger event via the discoverable event stream, the activation trigger event including the generic activation identifier and the actor identifier;
generating, based on the generic activation identifier and the actor identifier, an activation instruction event for causing an action associated with the generic activation identifier at an actor corresponding to the actor identifier, including mapping a field within the activation instruction event to a configuration value within the activation trigger event to which the field corresponds;
configuring, based on the activation trigger event, the activation instruction event to trigger the action at the actor; and
transmitting the activation instruction event to the actor based on the actor identifier.
2 . The method of claim 1 , wherein the generic activation identifier identifies at least one of sending a notification, sending a state change instruction to an external device, sending a state change instruction to an external system, sending an invocation instruction to an external system, sending an invocation instruction to a data processing system, or sending an analysis instruction to a data processing system.
3 . The method of claim 1 , wherein generating the activation instruction event for causing the action comprises:
identifying a collection of commands associated with the actor; and
selecting, from the collection of commands, a command for the activation instruction event.
4 . The method of claim 1 , wherein configuring the activation instruction event comprises:
detecting a presence of a parameterized value within the activation trigger event;
identifying a parameterized value field of the activation instruction event that corresponds to the parameterized value;
determining a static value for the parameterized value field based on the parameterized value; and
mapping the parameterized value field to the static value within the activation instruction event.
5 . The method of claim 4 , wherein the parameterized value is a role and/or role group, and the static value is one or more communication addresses.
6 . The method of claim 1 , wherein generating the activation instruction event comprises:
detecting a presence of the configuration value within the activation trigger event;
identifying the field of the activation instruction event that corresponds to the configuration value.
7 . The method of claim 1 , wherein activation instruction event is a first activation instruction event, the action is a first action, and further comprising:
generating a second activation instruction event for causing a second action associated with the actor;
identifying a conflict between the first action and the second action; and
determining, based on the conflict, not to send the second activation instruction event to the actor.
8 . The method of claim 1 , wherein the activation trigger event is a first activation trigger event, activation instruction event is a first activation instruction event, and further comprising:
receiving a second activation trigger event via the discoverable event stream;
identifying a conflict between the first activation trigger event and the second activation trigger event; and
determining, based on the conflict, not to generate a second activation instruction event corresponding to the second activation trigger event.
9 . The method of claim 1 , wherein the activation instruction event causes the actor to perform the action, and generate an activation event corresponding to the action within the discoverable event stream.
10 . The method of claim 1 , further comprising:
identifying the plurality of time-series based events of the discoverable event stream that triggered the activation rule;
determining explainability information based on the plurality of time-series based events, the explainability information identifying an importance value of the plurality of time-series based events; and
presenting the explainability information via a graphical user interface.
11 . The method of claim 10 , further comprising:
generating a tree structure representing one or more activation rules including the activation rule, and wherein determining the explainability information comprises determining the explainability information based on a relationship between the activation rule and other activation rules within the tree structure.
12 . An apparatus, comprising:
a memory; and
a processor coupled with the memory and configured to:
identify a namespace associated with an activation trigger;
identify a plurality of time-series based events of a discoverable event stream associated with the namespace, wherein the discoverable event stream includes the plurality of time-series based events, received from multiple objects, in a single stream ordered by time;
determine that an activation rule is met over the plurality of time-series based events;
publish an activation trigger event to the discoverable event stream, the activation trigger event including a generic activation identifier identifying an action to perform, and an actor identifier identifying an actor to perform the action;
obtain, based on monitoring the discoverable event stream, the activation trigger event via the discoverable event stream, the activation trigger event including the generic activation identifier and the actor identifier;
generate, based on the generic activation identifier and the actor identifier, an activation instruction event for causing an action associated with the generic activation identifier at an actor corresponding to the actor identifier, including mapping a field within the activation instruction event to a configuration value within the activation trigger event to which the field corresponds;
configure, based on the activation trigger event, the activation instruction event to trigger the action at the actor; and
transmit the activation instruction event to the actor based on the actor identifier.
13 . The apparatus of claim 12 , wherein the activation instruction event is a first activation instruction event, the action is a first action, and wherein the processor is further configured to:
generate a second activation instruction event for causing a second action associated with the actor;
identify a conflict between the first action and the second action; and
determine, based on the conflict, not to send the second activation instruction event to the actor.
14 . The apparatus of claim 12 , wherein the activation trigger event is a first activation trigger event, the activation instruction event is a first activation instruction event, and wherein the processor is further configured to:
receive a second activation trigger event via the discoverable event stream;
identify a conflict between the first activation trigger event and the second activation trigger event; and
determine, based on the conflict, not to generate a second activation instruction event corresponding to the second activation trigger event.
15 . The apparatus of claim 12 , wherein the processor is further configured to:
identify the plurality of time-series based events of the discoverable event stream that triggered the activation rule;
determine explainability information based on the plurality of time-series based events, the explainability information identifying an importance value of the plurality of time-series based events; and
present the explainability information via a graphical user interface.
16 . The apparatus of claim 12 , wherein the generic activation identifier identifies at least one of sending a notification, sending a state change instruction to an external device, sending a state change instruction to an external system, sending an invocation instruction to an external system, sending an invocation instruction to a data processing system, or sending an analysis instruction to a data processing system.
17 . The apparatus of claim 12 , wherein the processor is configured to generate the activation instruction event for causing the action including:
identifying a collection of commands associated with the actor; and
selecting, from the collection of commands, a command for the activation instruction event.
18 . The apparatus of claim 12 , wherein the processor is configured to configure the activation instruction event including:
detecting a presence of a parameterized value within the activation trigger event;
identifying a parameterized value field of the activation instruction event that corresponds to the parameterized value;
determining a static value for the parameterized value field based on the parameterized value; and
mapping the parameterized value field to the static value within the activation instruction event.
19 . A non-transitory computer-readable device having instructions thereon that, when executed by at least one computing device, causes the at least one computing device to perform operations comprising:
identifying a namespace associated with an activation trigger;
identifying a plurality of time-series based events of a discoverable event stream associated with the namespace, wherein the discoverable event stream includes the plurality of time-series based events, received from multiple objects, in a single stream ordered by time;
determining that an activation rule is met over the plurality of time-series based events;
publishing an activation trigger event to the discoverable event stream, the activation trigger event including a generic activation identifier identifying an action to perform, and an actor identifier identifying an actor to perform the action;
obtaining, based on monitoring the discoverable event stream, the activation trigger event via the discoverable event stream, the activation trigger event including the generic activation identifier and the actor identifier;
generating, based on the generic activation identifier and the actor identifier, an activation instruction event for causing an action associated with the generic activation identifier at an actor corresponding to the actor identifier, including mapping a field within the activation instruction event to a configuration value within the activation trigger event to which the field corresponds;
configuring, based on the activation trigger event, the activation instruction event to trigger the action at the actor; and
transmitting the activation instruction event to the actor based on the actor identifier.
20 . The non-transitory computer-readable device of claim 19 , wherein the operations further comprise:
identifying the plurality of time-series based events of the discoverable event stream that triggered the activation rule;
determining explainability information based on the plurality of time-series based events, the explainability information identifying an importance value of the plurality of time-series based events; and
presenting the explainability information via a graphical user interface.