Diferència entre revisions de la pàgina «Uso de la base de datos MariaDB desde NodeRED (2023)»
m (→Escritura síncrona de múltiples datos asíncronos al mismo tiempo. Uso del formato de datos json) |
|||
(Hi ha 29 revisions intermèdies del mateix usuari que no es mostren) | |||
Línia 1: | Línia 1: | ||
− | |||
− | |||
= Acceso = | = Acceso = | ||
Hay una base de datos creada en el MariaDB con el nombre '''aula206''' | Hay una base de datos creada en el MariaDB con el nombre '''aula206''' | ||
Línia 75: | Línia 73: | ||
=== Configuración de nodos ''inject'' para generar datos de tipo JSON === | === Configuración de nodos ''inject'' para generar datos de tipo JSON === | ||
[[Image:17nodoMariaDbNodeRed.png|center|Nodos ''inject'' para generar datos de tipo JSON]] | [[Image:17nodoMariaDbNodeRed.png|center|Nodos ''inject'' para generar datos de tipo JSON]] | ||
− | Doble clic sobre el nodo ''inject'': | + | Doble clic sobre el nodo ''inject'' (seleccionar la opción '''{}'''): |
[[Image:1701nodoMariaDbNodeRed.png|center|Edición del nodo ''inject'' para generar datos de tipo JSON]] | [[Image:1701nodoMariaDbNodeRed.png|center|Edición del nodo ''inject'' para generar datos de tipo JSON]] | ||
− | Clic sobre '''...''': | + | Clic sobre '''...''' (los tres puntos): |
[[Image:1702nodoMariaDbNodeRed.png|center|Edición del nodo ''inject'' para generar datos de tipo JSON]] | [[Image:1702nodoMariaDbNodeRed.png|center|Edición del nodo ''inject'' para generar datos de tipo JSON]] | ||
+ | En formato texto: | ||
+ | { | ||
+ | "valueT": 17.89, | ||
+ | "valueRH": 44.32 | ||
+ | } | ||
=== Inserción de datos de tipo JSON en columnas de la tabla === | === Inserción de datos de tipo JSON en columnas de la tabla === | ||
[[Image:18nodoMariaDbNodeRed.png|center|Inserción de datos de tipo JSON en columnas de la tabla]] | [[Image:18nodoMariaDbNodeRed.png|center|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 == | == Lectura de datos en una tabla de la base de datos MySQL == | ||
+ | [[Image:19nodoMariaDbNodeRed.png|center|Ejemplo de SELECT para MariaDB]] | ||
+ | Campo '''msg.topic''' del nodo ''inject'' para hacer un '''SELECT''': | ||
+ | [[Image:20nodoMariaDbNodeRed.png|center|Nodo ''inject'' para enviar un ''query'' de tipo ''SELECT'' a MariaDB]] | ||
+ | |||
+ | 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 == | == Creación de una tabla vista en la base de datos MySQL == | ||
− | + | [[Image:21nodoMariaDbNodeRed.png|center|Creación de una tabla vista partiendo de otra tabla en una base de datos MariaDB]] | |
+ | |||
+ | 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 == | ||
− | + | [[Image:22nodoMariaDbNodeRed.png|center|Tratamiento de datos leídos de la tabla]] | |
− | |||
− | |||
− | |||
− | + | Añadir salidas a la función (en '''Outputs''' se ha cambiado de 1 a 3 salidas): | |
− | [[Image: | + | [[Image:23nodoMariaDbNodeRed.png|center|Añadir salidas a la función]] |
− | + | Código de la función '''Tratamiento datos / Últimas entradas''': | |
− | Función ''' | + | [[Image:24nodoMariaDbNodeRed.png|center|Código de la función '''Tratamiento datos / Últimas entradas''']] |
− | a = msg.payload; | + | |
+ | Función '''Tratamiento datos / Últimas entradas''' en modo texto: | ||
+ | var a = msg.payload; | ||
var val = ""; | var val = ""; | ||
− | var | + | var lastEntryValueT, lastEntryValueRH; |
− | a.forEach(function(entry) { | + | a.forEach(function (entry) { |
− | val+="timestamp: "+entry.time+", | + | val += "timestamp: " + entry.time + ", valueT: " + entry.valueT + ", valueRH: " + entry.valueRH + "\r"; |
− | + | lastEntryValueT = entry.valueT; | |
+ | lastEntryValueRH = entry.valueRH; | ||
}); | }); | ||
msg.payload = val; | msg.payload = val; | ||
− | var | + | var msg_valT = { payload: lastEntryValueT }; |
− | return [msg, | + | return [msg, msg_valT, { payload: lastEntryValueRH}]; |
== Aleatorización controlada por el panel de control == | == Aleatorización controlada por el panel de control == | ||
− | Aprovechando el ejercicio hecho en la introducción al [[Uso del NodeRED ( | + | Aprovechando el ejercicio hecho en la introducción al [[Uso del NodeRED (2023) | Uso del NodeRED]], añadiremos otro valor de aleatorización y haremos una escritura a la base de datos MariaDB. |
− | [[Image: | + | [[Image:25nodoMariaDbNodeRed.png|center|Generación de datos aleatorios]] |
Al seleccionar el conmutador (''switch'') '''Randomize''' comienza la generación de datos aleatorios. Al deseleccionarlo se para la generación de datos. | Al seleccionar el conmutador (''switch'') '''Randomize''' comienza la generación de datos aleatorios. Al deseleccionarlo se para la generación de datos. | ||
− | [[Image: | + | [[Image:26nodoMariaDbNodeRed.png|center|Generación de datos aleatorios]] |
− | [https://binefa.cat/training/upcSchool/ | + | [https://www.binefa.cat/training/upcSchool/2023/20230415/26nodeRedRandomUi.nodered.json Código para el NodeRED que genera dos datos aleatorios] |
Función '''Randomizing (On/Off)''': | Función '''Randomizing (On/Off)''': | ||
Línia 125: | Línia 144: | ||
return msg; | return msg; | ||
− | Función '''random value in range | + | Función '''random JSON value in range {"T": <20.0,30.0>,"RH": <45.0,55.0>}''': |
− | + | var randomT = parseFloat((200 + Math.floor(Math.random() * 101)) / 10); // value between 20.0 and 30.0 | |
− | + | var randomRH = parseFloat((450 + Math.floor(Math.random() * 101)) / 10); // value between 45.0 and 55.0 | |
− | + | var jsonR = {}; | |
− | = | + | jsonR["T"] = randomT; |
− | + | jsonR["RH"] = randomRH; | |
− | + | ||
− | + | var msg_jsonR = { payload: jsonR }; | |
− | + | var msg_valT = { payload: randomT }; | |
− | + | var msg_valRH = { payload: randomRH }; | |
− | + | ||
− | + | return [msg_jsonR, msg_valT, msg_valRH]; | |
− | |||
− | |||
− | |||
− | |||
− | [ | ||
− | |||
− | |||
− | [ | ||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | |||
− | + | = Escritura síncrona de múltiples datos asíncronos al mismo tiempo. Uso del formato de datos '''json''' = | |
− | + | [[Image:27nodoMariaDbNodeRed.png|center|Uso del formato de datos '''json''']] | |
− | |||
− | [https://www.binefa.cat/training/upcSchool/ | + | [https://www.binefa.cat/training/upcSchool/2023/20230415/27nodeRedJson.nodered.json Código en NodeRED para el uso de Json en MariaDB] |
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''): | 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''): | ||
Línia 214: | Línia 187: | ||
return msg; | return msg; | ||
− | $ | + | Función '''INSERT INTO m28XX_T_RH_P_LDR(valueT,valueRH,valueP,valueLDR)''': |
− | + | msg.topic = `insert into m28XX_T_RH_P_LDR(valueT,valueRH,valueP,valueLDR) values(${msg.payload.T},${msg.payload.RH},${msg.payload.P},${msg.payload.LDR})`; | |
− | + | return msg; | |
− | > '''use | + | |
− | + | Consulta a MariaDB desde el terminal del VPS: | |
− | > '''select * from | + | convidat@vps656540:~$ '''mysql -u convidat -p''' |
− | + | Enter password: ''(la contraseña es '''benvingut''')'' | |
− | time | + | Welcome to the MariaDB monitor. Commands end with ; or \g. |
− | ---- | + | Your MariaDB connection id is 133 |
− | + | Server version: 10.3.38-MariaDB-0+deb10u1 Debian 10 | |
− | + | ||
− | > quit | + | Copyright (c) 2000, 2018, Oracle, MariaDB Corporation Ab and others. |
− | + | ||
+ | Type 'help;' or '\h' for help. Type '\c' to clear the current input statement. | ||
+ | |||
+ | MariaDB [(none)]> '''use aula206;''' | ||
+ | Reading table information for completion of table and column names | ||
+ | You can turn off this feature to get a quicker startup with -A | ||
+ | |||
+ | Database changed | ||
+ | MariaDB [aula206]> '''select * from m28XX_T_RH_P_LDR_v;''' | ||
+ | +------------+--------+---------+--------+----------+ | ||
+ | | time | valueT | valueRH | valueP | valueLDR | | ||
+ | +------------+--------+---------+--------+----------+ | ||
+ | | 1681149647 | 24.7 | 74.6 | 1007.2 | 47.3 | | ||
+ | | 1681149886 | 21.3 | 48.2 | 1003.5 | 89.4 | | ||
+ | +------------+--------+---------+--------+----------+ | ||
+ | 2 rows in set (0.000 sec) | ||
+ | |||
+ | MariaDB [aula206]> '''quit''' | ||
+ | Bye |
Revisió de 18:08, 10 abr 2023
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 Aleatorización controlada por el panel de control
- 3 Escritura síncrona de múltiples datos asíncronos al mismo tiempo. Uso del formato de datos json
Acceso[modifica]
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[modifica]
Instalación[modifica]
Hace falta instalar el conjunto de nodos node-red-node-mysql
Configuración de la base de datos en el nodo MySQL[modifica]
- 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[modifica]
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[modifica]
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[modifica]
Configuración de nodos inject para generar datos de tipo JSON[modifica]
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[modifica]
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[modifica]
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[modifica]
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[modifica]
Añadir salidas a la función (en Outputs se ha cambiado de 1 a 3 salidas):
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}];
Aleatorización controlada por el panel de control[modifica]
Aprovechando el ejercicio hecho en la introducción al Uso del NodeRED, añadiremos otro valor de aleatorización y haremos una escritura a la base de datos MariaDB.
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 dos datos aleatorios
Función Randomizing (On/Off):
flow.set("Randomizing",msg.payload); return msg;
Función random JSON value in range {"T": <20.0,30.0>,"RH": <45.0,55.0>}:
var randomT = parseFloat((200 + Math.floor(Math.random() * 101)) / 10); // value between 20.0 and 30.0 var randomRH = parseFloat((450 + Math.floor(Math.random() * 101)) / 10); // value between 45.0 and 55.0 var jsonR = {}; jsonR["T"] = randomT; jsonR["RH"] = randomRH; var msg_jsonR = { payload: jsonR }; var msg_valT = { payload: randomT }; var msg_valRH = { payload: randomRH }; return [msg_jsonR, msg_valT, msg_valRH];
Escritura síncrona de múltiples datos asíncronos al mismo tiempo. Uso del formato de datos json[modifica]
Código en NodeRED para el uso de Json en MariaDB
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;
Función INSERT INTO m28XX_T_RH_P_LDR(valueT,valueRH,valueP,valueLDR):
msg.topic = `insert into m28XX_T_RH_P_LDR(valueT,valueRH,valueP,valueLDR) values(${msg.payload.T},${msg.payload.RH},${msg.payload.P},${msg.payload.LDR})`; return msg;
Consulta a MariaDB desde el terminal del VPS:
convidat@vps656540:~$ mysql -u convidat -p Enter password: (la contraseña es benvingut) Welcome to the MariaDB monitor. Commands end with ; or \g. Your MariaDB connection id is 133 Server version: 10.3.38-MariaDB-0+deb10u1 Debian 10 Copyright (c) 2000, 2018, Oracle, MariaDB Corporation Ab and others. Type 'help;' or '\h' for help. Type '\c' to clear the current input statement. MariaDB [(none)]> use aula206; Reading table information for completion of table and column names You can turn off this feature to get a quicker startup with -A Database changed MariaDB [aula206]> select * from m28XX_T_RH_P_LDR_v; +------------+--------+---------+--------+----------+ | time | valueT | valueRH | valueP | valueLDR | +------------+--------+---------+--------+----------+ | 1681149647 | 24.7 | 74.6 | 1007.2 | 47.3 | | 1681149886 | 21.3 | 48.2 | 1003.5 | 89.4 | +------------+--------+---------+--------+----------+ 2 rows in set (0.000 sec) MariaDB [aula206]> quit Bye