Diferència entre revisions de la pàgina «Uso de la base de datos MariaDB desde NodeRED (2023)»
m |
|||
Línia 106: | Línia 106: | ||
msg.topic = `CREATE VIEW '''m28XX'''_T_RH_v AS select UNIX_TIMESTAMP(time) as time, valueT, valueRH from '''m28XX'''_T_RH;`; | msg.topic = `CREATE VIEW '''m28XX'''_T_RH_v AS select UNIX_TIMESTAMP(time) as time, valueT, valueRH from '''m28XX'''_T_RH;`; | ||
return msg; | return msg; | ||
+ | == Tratamiento de datos leídos de la tabla == | ||
+ | |||
+ | [[Image:22nodoMariaDbNodeRed.png|center|Tratamiento de datos leídos de la tabla]] | ||
+ | |||
+ | Añadir salidas a la función: | ||
+ | |||
+ | [[Image:23nodoMariaDbNodeRed.png|center|Añadir salidas a la función]] | ||
+ | |||
+ | Código de la función '''Tratamiento datos / Últimas entradas''': | ||
+ | |||
+ | [[Image:24nodoMariaDbNodeRed.png|center|Código de la función '''Tratamiento datos / Últimas entradas''']] | ||
+ | |||
+ | Función '''Tratamiento datos / Últimas entradas''' en modo texto: | ||
+ | var a = msg.payload; | ||
+ | var val = ""; | ||
+ | var lastEntryValueT, lastEntryValueRH; | ||
+ | a.forEach(function (entry) { | ||
+ | val += "timestamp: " + entry.time + ", valueT: " + entry.valueT + ", valueRH: " + entry.valueRH + "\r"; | ||
+ | lastEntryValueT = entry.valueT; | ||
+ | lastEntryValueRH = entry.valueRH; | ||
+ | }); | ||
+ | msg.payload = val; | ||
+ | var msg_valT = { payload: lastEntryValueT }; | ||
+ | return [msg, msg_valT, { payload: lastEntryValueRH}]; | ||
== Lectura con usuario de InfluxDB con permisos de lectura == | == Lectura con usuario de InfluxDB con permisos de lectura == |
Revisió del 16:53, 10 abr 2023
¡¡¡ HACE FALTA ADAPTARLO A MARIA-DB !!!
Contingut
- 1 Acceso
- 2 Nodos MariaDB en NodeRed
- 2.1 Instalación
- 2.2 Configuración de la base de datos en el nodo MySQL
- 2.3 Creación de una tabla en la base de datos MySQL
- 2.4 Borrado de una tabla en la base de datos MySQL
- 2.5 Inserción de datos en una tabla de la base de datos MySQL
- 2.6 Lectura de datos en una tabla de la base de datos MySQL
- 2.7 Creación de una tabla vista en la base de datos MySQL
- 2.8 Tratamiento de datos leídos de la tabla
- 2.9 Lectura con usuario de InfluxDB con permisos de lectura
- 2.10 Aleatorización controlada por el panel de control
- 2.11 Escritura con usuario de InfluxDB con permisos de lectura y escritura
- 3 Escritura de múltiples datos al mismo tiempo. Uso del formato de datos json
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
Hace falta instalar el conjunto de nodos node-red-node-mysql
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
- Ir al lápiz a la derecha del desplegable Add new MySQL database... presente en la fila Database
- 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 para hacer un SELECT:
Campo msg.topic del nodo inject con nombre SELECT en formato texto:
select UNIX_TIMESTAMP(time) as time, valueT, valueRH from m28XX_T_RH
Creación de una tabla vista en la base de datos MySQL
Función CREATE VIEW m28XX_T_RH_v:
msg.topic = `CREATE VIEW m28XX_T_RH_v AS select UNIX_TIMESTAMP(time) as time, valueT, valueRH from m28XX_T_RH;`; return msg;
Tratamiento de datos leídos de la tabla
Añadir salidas a la función:
Código de la función Tratamiento datos / Últimas entradas:
Función Tratamiento datos / Últimas entradas en modo texto:
var a = msg.payload; var val = ""; var lastEntryValueT, lastEntryValueRH; a.forEach(function (entry) { val += "timestamp: " + entry.time + ", valueT: " + entry.valueT + ", valueRH: " + entry.valueRH + "\r"; lastEntryValueT = entry.valueT; lastEntryValueRH = entry.valueRH; }); msg.payload = val; var msg_valT = { payload: lastEntryValueT }; return [msg, msg_valT, { payload: lastEntryValueRH}];
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
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 $