Systems and methods for condition-based deployment of chainable compute operations for constrained computing devices
A non-transitory computer readable medium stores instructions that cause a processor to receive an indication of an event associated with an industrial automation system, wherein the industrial automation system includes a plurality of devices configured to perform a plurality of operations within the industrial automation system, and wherein each of the plurality of devices includes a compute surface configured to perform one or more software tasks, determine a plurality of data processing tasks to perform based on the event, identify a portion of the plurality of devices to perform the plurality of data processing tasks based on the compute surface available for each of the plurality of devices, and deploy a container to each of the portion of the plurality of devices, wherein each container of each of the portion of the plurality of devices is configured to perform at least one of the plurality of data processing tasks.
1 . A non-transitory computer readable medium storing instructions that, when executed by a processor, cause the processor to perform actions comprising:
receiving an indication of an event associated with an industrial automation system, wherein the industrial automation system comprises a plurality of devices configured to perform a plurality of operations within the industrial automation system, and wherein each of the plurality of devices comprises a compute surface configured to perform one or more software tasks;
determining a plurality of data processing tasks to perform based on the event;
identifying a portion of the plurality of devices to perform the plurality of data processing tasks based on the compute surface available for each of the plurality of devices; and
deploying a container to each of the portion of the plurality of devices, wherein each container of each of the portion of the plurality of devices is configured to perform at least one of the plurality of data processing tasks, and wherein at least one of each container deployed to each of the portion of the plurality of devices is configured to:
receive resultant data from at least two additional containers of each container deployed to the portion of the plurality of devices; and
compare the resultant data received from the at least two additional containers of each container deployed to the portion of the plurality of devices.
2 . The non-transitory computer readable medium of claim 1 , wherein at least two of the containers deployed to the portion of the plurality of devices are configured to perform parallel data processing tasks.
3 . The non-transitory computer readable medium of claim 2 , wherein the parallel data processing tasks are the same.
4 . The non-transitory computer readable medium of claim 2 , wherein the parallel data processing tasks are different from one another.
5 . The non-transitory computer readable medium of claim 1 , wherein the at least one of the containers deployed to the portion of the plurality of devices is configured to:
combine the resultant data received from a first container and a second container of the at least two of the containers deployed to the portion of the plurality of devices; and
transmit the combined resultant data to a third container deployed to a device of the portion of the plurality of devices.
6 . The non-transitory computer readable medium of claim 1 , wherein the instructions, when executed by the processor, cause the processor to perform the actions comprising:
receiving an indication that one of the deployed containers has stopped executing; and
deploy a replacement container, wherein the replacement container is configured to reconstruct data lost as a result of the one of the deployed containers stopping execution.
7 . The non-transitory computer readable medium of claim 1 , wherein deploying the container to each of the portion of the plurality of devices comprises deploying a pod of containers, wherein the pod of containers comprises a plurality of containers configured to coordinate to perform one or more of the plurality of data processing tasks.
8 . A method, comprising:
receiving, via one or more processors, an alert associated with an industrial automation system, wherein the industrial automation system comprises a plurality of devices configured to perform a plurality of operations within the industrial automation system, and wherein each of the plurality of devices comprises a respective compute surface configured to perform one or more software tasks;
determining, via the one or more processors, a plurality of data processing tasks to perform based on the alert;
identifying, via the one or more processors, a portion of the plurality of devices to perform the plurality of data processing tasks based on respective resources available to the respective compute surface available for each of the plurality of devices;
generating, via the one or more processors, a data processing flow identifying one or more of the plurality of data processing tasks assigned to each of the portion of the plurality of devices; and
deploying, via the one or more processors, a plurality of containers to the portion of the plurality of devices, wherein each of the plurality of containers is configured to perform the one or more of the plurality of data processing tasks, and wherein at least one the plurality of containers deployed to the portion of the plurality of devices is configured to:
receive resultant data from at least two additional containers of the plurality of containers deployed to the portion of the plurality of devices; and
compare the resultant data received from the at least two additional containers of the plurality of containers.
9 . The method of claim 8 , wherein the plurality of containers comprises a data acquisition container configured to collect data from the industrial automation system.
10 . The method of claim 8 , wherein the plurality of containers comprises a condition identification container configured to identify a condition associated with the alert based on data collected from the industrial automation system.
11 . The method of claim 8 , wherein the plurality of containers comprises a causal analysis container configured to identify a cause associated with the alert based on data collected from the industrial automation system.
12 . The method of claim 8 , wherein the plurality of containers comprises a remedial action identification container configured to identify a remedial action to remedy a condition associated with the alert based on data collected from the industrial automation system.
13 . The method of claim 12 , comprising: transmitting for display via a graphical user interface (GUI), an indication of the identified remedial action to remedy the condition associated with the alert.
14 . The method of claim 13 , comprising: receiving, via the GUI, an input approving the remedial action.
15 . The method of claim 12 , comprising: automatically implementing the identified remedial action.
16 . The method of claim 12 , wherein the remedial action comprises adjusting one or more operating parameters, replacing a part, replacing a component, performing a maintenance operation, restarting a device of the plurality of devices, updating software, updating firmware, scheduling service, scheduling maintenance, or any combination thereof.
17 . A non-transitory computer readable medium storing instructions that, when executed by a processor, cause the processor to perform actions comprising:
receiving an indication of an event associated with a device of a plurality of devices of an industrial automation system configured to perform a plurality of operations within the industrial automation system;
determining a plurality of data processing tasks to perform based on the event;
determining that the device does not have sufficient resources to perform the plurality of data processing tasks;
identifying a portion of the plurality of devices to perform the plurality of data processing tasks based on resources available for each of the plurality of devices;
assigning one or more of the plurality of data processing tasks to each of the portion of the plurality of devices; and
deploying a container to each of the portion of the plurality of devices, wherein each container of each of the portion of the plurality of devices is configured to perform a respective one or more of the plurality of data processing tasks, and wherein at least one of each container deployed to each of the portion of the plurality of devices is configured to:
receive resultant data from at least two additional containers of each container deployed to the portion of the plurality of devices;
combine the resultant data; and
transmit the combined resultant data to a third container of each container deployed to the portion of the plurality of devices.
18 . The non-transitory computer readable medium of claim 17 , wherein the instructions, when executed by the processor, cause the processor to perform the actions comprising: determining that the device does not have sufficient computing resources to perform the plurality of operations.