Unified data ingestion adapter for migration of industrial data to a cloud platform

A method for processing industrial data for migration to a cloud platform, comprising:

• sending, by a cloud gateway device comprising a processor, gateway registration information to a registration server device, wherein the gateway registration information comprises at least identification information for the cloud gateway device and an indication of a number of industrial data points being collected by the cloud gateway device, and wherein the registration server device stores identity information and status information for data repository devices connected to a same network as the cloud gateway device;
• collecting, by the cloud gateway device, industrial data from an industrial control device associated with an industrial enterprise;
• converting, by the cloud gateway device, the industrial data to conform to a defined data format to yield formatted data;
• adding, by the cloud gateway device, header information to the formatted data to yield a data packet;
• sending, by the cloud gateway device, the data packet to a cloud platform device over a first communication link;
• in response to determining that the first communication link has been interrupted:
• sending, by the cloud gateway device, a query to the registration server device requesting an identity of a data repository device of the data repository devices;
• receiving, by the cloud gateway device, response data comprising the identity of the data repository device, wherein the data repository device is selected by the registration server device based on the number of industrial data points and the status information for the data repository devices;
• establishing, by the cloud gateway device, a second communication link to the data repository device;
• and
• redirecting, by the cloud gateway device, the formatted data to the data repository device over the second communication link.

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

• sending, to a registration server device, gateway registration information comprising at least identification information for the cloud gateway device and an indication of a number of industrial data points being collected by the cloud gateway device, wherein the registration server device stores identity information and status information for data repository devices accessible by the cloud gateway device;
• receiving industrial data from one or more industrial devices comprising an industrial process;
• formatting the industrial data to accord to a common data format to yield formatted data;
• encapsulating the formatted data with header information to yield a data packet;
• sending the data packet to a cloud platform over a first communication channel;
• and
• in response to determining that the first communication channel has faulted:
• querying the registration server device for an identity of a data repository device of the data repository devices;
• receiving, in response to the querying, the identity of the data repository from the registration server device, wherein the data repository is selected by the registration server device based on the number of industrial data points and the status information for the data repository devices;
• instantiating a second communication channel to the data storage device based on the identity;
• and
• sending the formatted data to the data storage device over the second communication channel.