Uso de la base de datos MariaDB desde NodeRED (2023)

¡¡¡ HACE FALTA ADAPTARLO A MARIA-DB !!!

Acceso

Hay una base de datos creada en el MariaDB con el nombre aula206

El usuario iot con contraseña iot tiene permisos de escritura y lectura sobre la base datos aula206

El usuario convidat con contraseña benvingut tiene permisos de lectura sobre la base datos aula206

El MariaDB en el VPS del Máster es un recurso compartido. Vamos a compartir la misma base de datos (aula206), los datos que vamos a introducir los diferenciaremos por el nombre de la tabla. Vamos a poner un prefijo identificativo al nombre de la tabla. Cambiad el número 28XX por el número de puerto que se os ha assignado.

Explicación detallada en uso de MariaDB en el VPS del Máster de Industria 4.0

Nodos MariaDB en NodeRed

Instalación

Instalación de los nodos de MariaDB (MySQL) en NodeRED

Hace falta instalar el conjunto de nodos node-red-node-mysql

Aspecto del nodo MySQL en NodeRED

Configuración de la base de datos en el nodo MySQL

• Poner un nodo MySQL en el tapiz Node-RED

• Hacer doble clic sobre el nodo MySQL

Configuración del nodo MySQL

• Ir al lápiz a la derecha del desplegable Add new MySQL database... presente en la fila Database

Configuración del nodo MySQL

- En Host escribir la IP local del servidor (127.0.0.1). Por seguridad, no le permitimos a la base de datos que tenga visibilidad externa.

- En Port escribir el puerto TCP (3306) por defecto de las bases de datos MySQL

- En User escribir un usuario con permisos de escritura (iot), debido a que queremos escribir. Si no hace falta escribir en la base de datos escribiríamos un usuario con permisos de solo lectura (como convidat).

- En Password escribir la contraseña del usuario (para el usuario iot es iot. Para el usuario convidat es benvingut).

- En Database escribir la base de datos que queremos acceder (aula206)

- En Charset escribir la codificación de carácteres (UTF8)

Creación de una tabla en la base de datos MySQL

Hay cuatro nodos enlazados: inject, function, mysql y debug.

• Los nodos inject y debug no se modifican. Dejar la configuración por defecto.

• El nodo mysql ha estado configurado en el paso anterior.

• El nodo function se ha configurado de este modo:

• Cambiar el nombre de la tabla substituyendo 28XX por el número de puerto que se os ha asignado.

Función CREATE TABLE m28XX_T_RH:

msg.topic = `
CREATE TABLE m28XX_T_RH (
 time TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
 valueT FLOAT,
 valueRH FLOAT,
 PRIMARY KEY (time));
`;
return msg;

Borrado de una tabla en la base de datos MySQL

Función DROP TABLE m28XX_T_RH:

msg.topic = `DROP TABLE m28XX_T_RH;`;
return msg;

Inserción de datos en una tabla de la base de datos MySQL

Configuración de nodos inject para generar datos de tipo JSON

Doble clic sobre el nodo inject (seleccionar la opción {}):

Clic sobre ... (los tres puntos):

En formato texto:

{
   "valueT": 17.89,
   "valueRH": 44.32
}

Inserción de datos de tipo JSON en columnas de la tabla

Función INSERT DATA:

msg.topic = `insert into m28XX_T_RH(valueT,valueRH) values(${msg.payload.valueT},${msg.payload.valueRH}})`;
return msg;

Lectura de datos en una tabla de la base de datos MySQL

Campo msg.topic del nodo inject con nombre SELECT en formato texto:

select UNIX_TIMESTAMP(time) as time, valueT, valueRH, valueP from m28XX_T_RH

Lectura con usuario de InfluxDB con permisos de lectura

Cuando se usen los nodos InfluxDB del NodeRED se tiene que especificar la versión de InfluxDB. En nuestro caso es la 1.8.0:

$ influx --version
InfluxDB shell version: 1.8.0

Configuración de InfluxDB para lectura

Código para NodeRED de lectura de InfluxDB

Función --> timestamp, value con dos salidas:

a = msg.payload;
var val = "";
var lastEntryValue;
a.forEach(function(entry) {
   val+="timestamp: "+entry.time+", value: "+entry.value + "\n";
   lastEntryValue = entry.value;
});
msg.payload = val;
var msg_val = {payload : lastEntryValue} 
return [msg,msg_val];

Aleatorización controlada por el panel de control

Aprovechando el ejercicio hecho en la introducción al Uso del NodeRED, añadiremos una escritura a la base de datos temporal InfluxDB.

Al seleccionar el conmutador (switch) Randomize comienza la generación de datos aleatorios. Al deseleccionarlo se para la generación de datos.

Código para el NodeRED que genera datos aleatorios

Función Randomizing (On/Off):

flow.set("Randomizing",msg.payload);
return msg;

Función random value in range (20.0,30.0):

msg.payload = parseFloat( (200 + Math.floor(Math.random() * 101))/10); // value between 20.0 and 30.0
return msg;

Escritura con usuario de InfluxDB con permisos de lectura y escritura

Código de NodeRED para la escritura desde el panel de control

Una vez puesto en marcha (botón ON apretado) los datos se almacenan a InfluxDB. Para parar la alimentación de la base de datos apretar el botón OFF. Paralelamente se pueden ver los datos introducidos al campo nAleat en tiempo real.

$ influx -username masteri40 -password upcschool
Connected to http://localhost:8086 version 1.7.6
InfluxDB shell version: 1.8.0
> use aulaVirtual2020
Using database aulaVirtual2020
> select * from m05_nAleat
name: m05_nAleat
time                value
----                -----
1589883858824341140 20
> select * from m05_nAleat
name: m05_nAleat
time                value
----                -----
1589883858824341140 20
1589917797335467035 25.8
1589917798315048933 24.9
1589917799300711846 27.9
1589917800302525288 25.9
1589917801303458891 22.1
1589917802303580896 27.1
1589917803305577403 22.6
1589917804304937828 28.7
1589917805305797039 22.1
1589917806319523948 20.3
1589917807308901024 21.5
1589917808330402290 26.5
> quit
$

Para hacer la lectura de los datos era suficiente ser usuario con permisos exclusivos de lectura (usuario convidat).

Escritura de múltiples datos al mismo tiempo. Uso del formato de datos json

Código en NodeRED para el uso de Json en InfluxDB

Función T:24.7,RH:74.6,P:1007.2,LDR:47.3 (esta función se ejecuta al desplegar el flujo, debido a la configuración del nodo inject):

flow.set("IoT-02_RH",74.6);
flow.set("IoT-02_T",24.7);
flow.set("IoT-02_P",1007.2);
flow.set("IoT-02_LDR",47.3);
return msg;

Función T:21.3,RH:48.2,P:1003.5,LDR:89.4:

flow.set("IoT-02_RH",48.2);
flow.set("IoT-02_T",21.3);
flow.set("IoT-02_P",1003.5);
flow.set("IoT-02_LDR",89.4);
return msg;

Función --> json:

var json00 = {};
json00.RH = flow.get("IoT-02_RH");
json00.T = flow.get("IoT-02_T");
json00.P = flow.get("IoT-02_P");
json00.LDR = flow.get("IoT-02_LDR");
msg.payload = json00;
return msg;

$ influx -username convidat -password benvingut
Connected to http://localhost:8086 version 1.7.6
InfluxDB shell version: 1.8.0
> use aulaVirtual2020
Using database aulaVirtual2020
> select * from m05_json_00
name: m05_json_00
time                LDR  P      RH   T
----                ---  -      --   -
1589965283616685236 47.3 1007.2 74.6 24.7
1589965290073574911 89.4 1003.5 48.2 21.3
> quit
$