Node-RED, una herramienta de código abierto basada en la programación en streaming, ofrece a los desarrolladores un enfoque de programación visual flexible que permite IOTRouter's Pasarela EG Edge Computing para conectarse fácilmente a diversas fuentes de datos para su procesamiento y conversión. La pasarela EG Edge Computing Gateway es capaz de recopilar y analizar inicialmente los datos en tiempo real en el borde donde se están generando los datos, lo que reduce los requisitos de ancho de banda y mejora la eficiencia del procesamiento de datos. También puede recopilar datos a través de diversos protocolos (por ejemplo, Modbus, MQTT, OPC UA, etc.) y realizar la conversión y el almacenamiento de datos necesarios.
I. Funciones básicas de la pasarela EG Edge Computing
EG Edge Computing Gateway desempeña el papel de capa intermedia de recogida y procesamiento de datos en el sistema, y procesa de forma flexible los datos procedentes de múltiples sensores y dispositivos para filtrarlos en tiempo real y realizar análisis preliminares. Pasarela EG Edge Computing tiene las siguientes funciones:
Conversión de protocolos: Soporta protocolos de transmisión de datos entre diferentes dispositivos, como Modbus, OPC UA, MQTT, etc.
Procesamiento y análisis local: Proporciona potencia de cálculo para filtrar, convertir y simplemente analizar datos.
Almacenamiento y transmisión de datos: Transmite los datos procesados a través de la red a una base de datos en la nube o a un servidor local.
II. Mecanismo de funcionamiento de Node-RED
Node-RED proporciona un editor de flujos basado en navegador que permite a los usuarios arrastrar y soltar nodos para crear flujos de procesamiento de datos. Cada nodo tiene características de entrada y salida y es capaz de realizar tareas específicas de procesamiento de datos. Node-RED cuenta con un amplio soporte de plug-ins, como Modbus, MQTT, OPC UA, etc., lo que lo hace capaz de integrar múltiples fuentes de datos.
III. Adquisición y tratamiento de datos
Proceso de referencia: recoger datos de los dispositivos esclavos regularmente a través de la pasarela EG, y formatear los datos recogidos en un formato reconocible por la base de datos MySQL, y cargar la propia base de datos MySQL del usuario. Tomemos como ejemplo la recogida de datos de esclavos Modbus RTU, el flujo de operación es el siguiente:
1. Conectarse a la base de datos MySQL
Primero asegúrese de instalar el nodo MySQL, luego en el editor Node-RED, añada el nodo MySQL y configure los parámetros de conexión a la base de datos, incluyendo host, puerto, nombre de usuario, contraseña y nombre de la base de datos.
Utilice el nodo MySQL para configurar los parámetros de conexión a la base de datos MySQL del usuario, la configuración se completa y se despliega, y la visualización conectado significa que la conexión se ha realizado correctamente.
2. Recopilar datos de esclavos
Utilizar la adquisición de datos Modbus RTU
Configure la dirección de host y el puerto del nodo Modbus y especifique los registros de datos que se van a recopilar.
Cree un proceso de recogida de datos para conectar el nodo Modbus al nodo MySQL. Configure un nodo temporizador para activar periódicamente la tarea de recopilación de datos para garantizar datos precisos y en tiempo real.
3. Formateo de datos
Cuando los datos se cargan en la base de datos MySQL, es necesario formatearlos en la sentencia SQL correcta de acuerdo con los requisitos de MySQL. Utilice el nodo de cálculo de funciones para formatear los datos. El formato de datos a convertir es el siguiente:
| Formato de los datos de salida del nodo Modbus | Descripción | Formato SQL de MySQL para cargar datos |
| {
"temp": 31.0, "hum": 45.5 } |
Convierte la salida de datos de objeto del nodo Modbus a la izquierda en la sentencia SQL requerida por MySQL a la derecha. | INSERT INTO mi_tabla (temp, hum) VALUES (25.55, 45.5); |
Código de muestra:
var data = msg.payload
var sql = `INSERT INTO mi_tabla (temp, hum) VALUES(${datos.temp},${datos.hum});`
msg.tema = sql
return msg;
4. Carga de datos
Una vez finalizado el formateo de datos, conecte el nodo de cálculo de funciones y el nodo MySQL, y haga clic en el nodo de inyección para realizar la recogida y carga de datos. Si la prueba es satisfactoria, puede configurar el nodo de inyección para que se ejecute periódicamente con el fin de recopilar y cargar datos en la base de datos MySQL a intervalos regulares.
La pasarela EG Edge Computing recopila datos a intervalos regulares y los convierte a formatos compatibles con MySQL, un método que permite procesar en tiempo real y almacenar a largo plazo grandes cantidades de datos de dispositivos de campo. Mejora la eficiencia del procesamiento de datos y puede proporcionar una base para el posterior análisis de datos y la toma de decisiones. La introducción de la computación de borde permite que el procesamiento inicial de los datos se complete cerca de la fuente de datos, lo que reduce la dependencia de la computación en nube y disminuye la latencia y el coste de la transmisión de datos.
Nota: Si necesita obtener datos de la base de datos MySQL, también puede cargar un nodo MySQL pasando una sentencia SQL de referencia a la propiedad msg.topic para hacer una petición de datos.