Uso de InfluxDB en el VPS del Máster de Industria 4.0 el curso 2019-2020
Contingut
Acceso[modifica]
Hay una base de datos creada en el InfluxDB con el nombre aulaVirtual2020
El usuario masteri40 con contraseña upcschool tiene permisos de escritura y lectura sobre la base datos aulaVirtual2020
El usuario convidat con contraseña benvingut tiene permisos de lectura sobre la base datos aulaVirtual2020
Uso de prefijos en función del usuario[modifica]
El InfluxDB en el VPS del Máster es un recurso compartido. Para diferenciar las medidas (measurements) introducidas por cada usuario sugerimos el uso del prefijo mxy_ (cambiando xy por vuestro número asignado).
Por ejemplo una medida de temperatura será m05_temperatura.
$ 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 > insert m05_nAleat value=20.0 > quit $
$ 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_nAleat name: m05_nAleat time value ---- ----- 1589883858824341140 20 > quit
Nodos InfluxDB en NodeRed[modifica]
Instalación de los nodos InfluxDB para NodeRED
Lectura con usuario de InfluxDB con permisos de lectura[modifica]
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[modifica]
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[modifica]
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[modifica]
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 $
