9. Almacenar en InfluxDB

Como vimos desde mqtt llega un JSON con los datos de humedad y temperatura. Esto lo podríamos enviar directamente a un bloque influxdb out pero, pensando en escalabilidad, agregaremos el identificador de nodo como un Tag. Esto lo hacemos con un bloque function que me permite implementar código javascript.

En la documentación del nodo influxdb out leemos: "Si msg.payload es una matriz que contiene dos objetos, el primer objeto se escribirá como el conjunto de campos con nombre, el segundo es el conjunto de etiquetas (tags)."


Ahora obtenemos un array con dos objetos JSON.



Solo resta insertar en la base de datos. Para ello utilizamos el bloque influxdb out. Tendremos que configurar nuestro servidor InfluxDB. Utilizamos el token que generamos en la base de datos.


Así queda nuestro nodo



Usando el explorador de datos de InfluxDB