Systems and methods for controlling asset operation using stream-based processing in multi-node networks

A method, comprising:

• receiving, via a processor, a first set of stream-based data from a first asset disposed in an industrial environment;
• receiving, via the processor, a second set of stream-based data from a second asset disposed in the industrial environment, wherein the first set of stream-based data and the second set of stream-based data are received in real time or near real time;
• determining, via the processor, a respective degree of truth value for each of a plurality of possible conditions for the second asset based on a comparison of the first set of stream-based data to the second set of stream-based data;
• and
• determining, via the processor, that the respective degree of truth value for a condition of the plurality of possible conditions for the second asset exceeds a threshold degree of truth value;
• identifying, via the processor, a remedial action to address the condition of the second asset based on the first set of stream-based data, the second set of stream-based data, the comparison of the first set of stream-based data to the second set of stream-based data, the condition, or a combination thereof, wherein the remedial action comprises adjusting one or more operational parameters of the second asset to cause one or more operations of the second asset to be within one or more expected ranges of values for the second set of stream-based data;
• generating, via the processor, a command to implement the remedial action;
• and
• transmitting, via the processor, the command to the second asset.

A non-transitory computer-readable medium comprising computer-executable instructions that, when executed by a processor, cause the processor to perform operations comprising:

• receiving a first set of stream-based data from a first asset disposed in an industrial environment;
• receiving a second set of stream-based data from a second asset disposed in the industrial environment, wherein the first set of stream-based data and the second set of stream-based data are received in real time or near real time;
• determining that the first set of stream-based data and the second set of stream-based data are of a common data type by referencing metadata for the first set of stream-based data and the second set of stream-based data;
• determining, via one or more truth tables, a respective degree of truth value for each of a plurality of possible conditions for the second asset based on a comparison of the first set of stream-based data to the second set of stream-based data;
• and
• determining that the respective degree of truth value for a condition of the plurality of possible conditions for the second asset exceeds a threshold degree of truth value;
• identifying, via one or more decision tables, a remedial action to address the condition of the second asset based on the first set of stream-based data, the second set of stream-based data, the comparison of the first set of stream-based data to the second set of stream-based data, the condition, or a combination thereof, wherein the remedial action comprises adjusting one or more operational parameters of the second asset to cause one or more operations of the second asset to be within one or more expected ranges of values for the second set of stream-based data;
• generating a command to implement the remedial action;
• and
• transmitting the command to the second asset.