Scalable centralized internet-of-things manager

At least one non-transitory computer-readable storage medium including instructions that, when executed, cause a system to:

• receive, at a first instance of a centralized IoT manager, a user message to deploy a data pipeline to an edge system connected to a second instance of the centralized IoT manager;
• determine a communication channel for the edge system;
• and
• publish the user message on the determined communication channel for the edge system.

An Internet of Things (IoT) system comprising an IoT manager, the IoT manager comprising:

• a first cloud manager instance configured to publish a received message to a communication channel, wherein the message is directed to an edge system;
• a second cloud manager instance configured to connect to the edge system corresponding to the communication channel and to subscribe to the communication channel, wherein the second cloud manager instance is configured to receive the received message published on the communication channel and to provide the received message to the edge system in response to receipt;
• and
• a containerized system configured to route the received message published by the first cloud manager instance to the second cloud manager instance.

A method, comprising:

• publishing, via a first cloud manager instance of an Internet of Thing (IoT) manager of an IoT system a received message to a communication channel, wherein the message is directed to an edge system;
• routing, via a containerized system of the IoT manager, the published message to a second cloud manager instance of the IoT manager;
• and
• providing, via the second cloud manager instance, the received message to the edge system in response to receipt.