Industrial analytics data processing

A system comprising:

• at least one data processor;
• memory coupled to the at least one data processor, the memory storing instructions to cause the at least one data processor to perform operations comprising:
• receiving, by a reconfiguration system and from an industrial system, data characterizing a first segregator code of a first segregator, a first aggregator code of a first aggregator of a plurality of aggregators associated with a data transmission system, and a plurality of configuration parameters for reconfiguring components of the data transmission system, wherein the data transmission system comprises the first segregator, a data router, the plurality of aggregators and a plurality of analytic models that are reached using different data transmission routes and are configured to receive operation data characterizing an operation of the industrial system and transmits a portion of the operation data to a first analytical model of the plurality of analytic models by one of the different data transmission routes;
• modifying, by the reconfiguration system, the first segregator code and the first aggregator code based on one or more configuration parameters of the plurality of configuration parameters to adjust processing and data transmission routes of the operation data;
• deploying, by the reconfiguration system, the first segregator code to the first segregator and the first aggregator code to the first aggregator in the data transmission system, wherein the first segregator code is configured to assign a first identifier to a first portion of the operation data in order to provide the first portion of the operation data to the first analytical model, via a first data transmission route of a plurality of data transmission routes based on the first identifier, the first portion of the operation data being generated by dividing the operation data into a plurality of data subsets using the first segregator code, routing a first set of data subsets based on the assigned first identifier along a first data transmission route to combine a portion of the plurality of data subsets using the configured first aggregator and provide the combined portion of the plurality of data subsets to the first analytic model;
• receiving operation data characterizing an operation of the industrial system at the configured transmission system;
• and
• executing the first segregator code on the first segregator and the first aggregator code on the first aggregator to provide the first portion of the operation data to the first analytical model via the first data transmission route.

A computer program product comprising a non-transitory machine-readable medium storing instructions that, when executed by at least one programmable processor that comprises at least one physical core and a plurality of logical cores, cause the at least one programmable processor to perform operations comprising:

• receiving, by a reconfiguration system and from an industrial system, data characterizing a first segregator code of a first segregator, a first aggregator code of a first aggregator of a plurality of aggregators associated with a data transmission system, and a plurality of configuration parameters for reconfiguring components of the data transmission system, wherein the data transmission system comprises the first segregator, a data router, the plurality of aggregators and a plurality of analytic models that are reached using different data transmission routes and are configured to receive operation data characterizing an operation of the industrial system and transmits a portion of the operation data to a first analytical model of the plurality of analytic models by one of the different data transmission routes;
• modifying, by the reconfiguration system, the first segregator code and the first aggregator code based on one or more configuration parameters of the plurality of configuration parameters to adjust processing and data transmission routes of the operation data;
• deploying, by the reconfiguration system, the first segregator code to the first segregator and the first aggregator code to the first aggregator in the data transmission system, wherein the first segregator code is configured to assign a first identifier to a first portion of the operation data in order to provide the first portion of the operation data to the first analytical model, via a first data transmission route of a plurality of data transmission routes based on the first identifier, the first portion of the operation data being generated by dividing the operation data into a plurality of data subsets using the first segregator code, routing a first set of data subsets based on the assigned first identifier along a first data transmission route to combine a portion of the plurality of data subsets using the configured first aggregator and provide the combined portion of the plurality of data subsets to the first analytic model;
• receiving operation data characterizing an operation of the industrial system at the configured transmission system;
• and
• executing the first segregator code on the first segregator and the first aggregator code on the first aggregator to provide the first portion of the operation data to the first analytical model via the first data transmission route that comprises the first segregator code.