Industrial internet of things data pipeline for a data lake

A method for monitoring industrial data, comprising:

• transferring, by a system comprising at least one processor, industrial data collected from one or more industrial devices of an industrial enterprise to cloud-based storage as a data stream, wherein the data stream is associated with the industrial enterprise;
• appending, by the system, harmonization envelope data to data items of the data stream to yield harmonized data that conforms to a common data schema;
• retrieving, by the system, a subset of analytic rules stored on cloud-based rule storage, wherein the subset of the analytic rules are identified by a manifest associated with the data stream;
• processing, by the system, one or more of the data items in accordance with the one or more analytic rules to yield one or more analytic results;
• and
• storing, by the system, the data items and the one or more analytic results on the cloud-based storage.

A non-transitory computer-readable medium having stored thereon instructions that, in response to execution, cause a system comprising a processor to perform operations, the operations comprising:

• transferring industrial data collected from one or more industrial devices of an industrial enterprise to cloud-based storage as a data stream, wherein the data stream is associated with the industrial enterprise;
• appending harmonization envelope data to data items of the data stream to yield harmonized data that conforms to a common data schema;
• referencing a manifest associated with the data stream to identify a subset of analytic rules stored on cloud-based rule storage;
• processing one or more of the data items in accordance with the subset of analytic rules to yield one or more analytic results;
• and
• storing the data items and the one or more analytic results on cloud-based storage.