Cloud-driven hybrid data flow and collection

A system for cloud-to-edge data flow migration, comprising:

• one or more network edge devices residing at a network edge along a network path;
• one or more cloud computers residing at a cloud environment;
• at least one memory storing computer-executable instructions;
• and
• at least one processor, wherein the at least one processor is configured to access the at least one memory and execute the computer-executable instructions to:
• receive input data;
• classify the input data based at least in part on one or more classification criteria to obtain classified input data;
• determine a first portion of cloud-based data processing functionality to migrate from the one or more cloud computers to the network edge based at least in part on at least one of:
• i) the classified input data, ii) one or more network characteristics, or iii) one or more device characteristics in the cloud environment or along the network path;
• migrate, in a container, the first portion of the cloud-based data processing functionality from the one or more cloud computers to the network edge to obtain migrated data processing functionality at the network edge;
• and
• process, by the container, at a first at least one network edge device, at least a subset of the input data using the migrated data processing functionality,
• wherein migrating the first portion of the cloud-based data processing functionality from the one or more cloud computers to the network edge to obtain migrated data processing functionality at the network edge comprises migrating a first function of the first portion of the cloud-based data processing functionality to a first edge device at the network edge to obtain first migrated data processing functionality and migrating, based at least in part on a dependency relationship with the first function, a second function of the first portion of the cloud-based data processing functionality to a second edge device at the network edge to obtain second migrated data processing functionality, and
• wherein processing, at the network edge, the at least a subset of the input data using the migrated data processing functionality comprises:
• processing a first subset of the input data at the first edge device using the first migrated data processing functionality to obtain first processed input data;
• providing the first processed input data as input to the second edge device;
• and processing the first processed input data at the second edge device using the second migrated data processing functionality to obtain second processed input data.

A computer program product for cloud-to-edge data flow migration, the computer program product comprising a non-transitory storage medium readable by a processing circuit, the storage medium storing instructions executable by the processing circuit to cause a method to be performed, the method comprising:

• receiving input data;
• classifying the input data based at least in part on one or more classification criteria to obtain classified input data;
• determining a first portion of cloud-based data processing functionality to migrate from a cloud environment that includes one or more cloud computers to a network edge that includes one or more devices along a network path based at least in part on at least one of:
• i) the classified input data, ii) one or more network characteristics or iii) one or more device characteristics in the cloud environment or along the network path;
• migrating, in a container, the first portion of the cloud-based data processing functionality from the one or more cloud computers to the network edge to obtain migrated data processing functionality at the network edge;
• and
• processing, by the container, at the network edge, at least a subset of the input data using the migrated data processing functionality,
• wherein migrating the first portion of the cloud-based data processing functionality from the one or more cloud computers to the network edge to obtain migrated data processing functionality at the network edge comprises migrating a first function of the first portion of the cloud-based data processing functionality to a first edge device at the network edge to obtain first migrated data processing functionality and migrating, based at least in part on a dependency relationship with the first function, a second function of the first portion of the cloud-based data processing functionality to a second edge device at the network edge to obtain second migrated data processing functionality, and
• wherein processing, at the network edge, the at least a subset of the input data using the migrated data processing functionality comprises:
• processing a first subset of the input data at the first edge device using the first migrated data processing functionality to obtain first processed input data;
• providing the first processed input data as input to the second edge device;
• and processing the first processed input data at the second edge device using the second migrated data processing functionality to obtain second processed input data.