Proyecto aTIC (II) - Servidor de InfluxDB

-

 Servidor de InfluxDB.

Como se ha mencionado en el anterior post (Proyecto aTIC (I) - Introducción), una de las raspberrys que intervienen en el proyecto contiene un servidor de InfluxDB sobre el sistema operativo Raspbian de la RaspberryPi (RPI1). Para la gestión del servidor y el resto de aplicaciones que se han necesitado (como el servicio Duck DNS que se menciona más adelante) se ha instalado Docker, una herramienta de virtualización para la creación de contenedores.

Adicionalmente, se ha hecho uso también de Portainer.io, una herramienta web open-source que permite gestionar contenedores Docker de una manera sencilla e intiutiva. Se ha configurado el sistema para que el servicio Portainer corra en el puerto 9000. 

También se ha hecho uso de Docker Compose, que permite definir y ejecutar aplicaciones Docker multicontenedor, como la desarrollada para este proyecto. Docker Compose requiere de un archivo tipo .yaml en el que se especifique la configuración deseada y así, con un único comando, se descargan e instalan las imágenes necesarias para montar todos los contenedores. El archivo Docker Compose desarrollado para RPI1 se muestra a continuación.

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
version: '2'
services:

  portainer:
    container_name: portainer
    image: portainer/portainer
    restart: unless-stopped
    ports:
      - 9000:9000
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock
      - ./volumes/portainer/data:/data

  influxdb:
    container_name: influxdb
    image: "influxdb:latest"
    restart: unless-stopped
    ports:
      - 8086:8086
      - 8083:8083
      - 2003:2003
    env_file:
      - ./services/influxdb/influxdb.env
    volumes:
      - ./volumes/influxdb/data:/var/lib/influxdb
      - ./backups/influxdb/db:/var/lib/influxdb/backup

  mosquitto:
    container_name: mosquitto
    image: eclipse-mosquitto
    restart: unless-stopped
    user: "1883"
    ports:
      - 1883:1883
      - 9001:9001
    volumes:
      - ./volumes/mosquitto/data:/mosquitto/data
      - ./volumes/mosquitto/log:/mosquitto/log
      - ./services/mosquitto/mosquitto.conf:/mosquitto/config/mosquitto.conf


  python:
    container_name: python
    build: ./services/python/.
    restart: unless-stopped
    network_mode: host
    volumes:
      - ./volumes/python/app:/usr/src/app

 Se observa cómo en el script se definen los servicios de Portainer, InfluxDB, Mosquitto y Python.

Como se ha mencionado con anterioridad, también se ha hecho uso de una DNS para poder acceder a la base de datos InfluxDB alojada en esta RaspberryPi (RPI1) de forma remota. Se ha empleado el servicio Duck DNS ya que es gratuito y muy sencillo de utilizar. Se ha reservado un dominio y se accede remotamente a la base de datos mediante el puerto 8086 (que se puede ver definido en el script anterior).

Para continuar con el siguiente post que define el proyecto desarrollado accede a Proyecto aTIC (III) - Broker MQTT. 


Comentarios

Publicar un comentario

Entradas populares de este blog

Proyecto aTIC (I) - Introducción

-
Imagen
INTRODUCCIÓN. El objetivo principal del proyecto es realizar una comunicación HTTP con un servidor, aplicando los conocimimentos aprendidos en clase. El proyecto que se ha desarrollado no sólo realiza una comunicación HTTP con un servidor, sino que también se hace uso de MQTT y contenedores para transmitir datos desde un sensor a una base de datos. El diagrama principal del proyecto desarrollado se muestra en la siguiente figura, donde se ve cómo intervienen cuatro dispositivos: un sensor, un ordenador y dos RaspberryPi.   El sensor es un dispositivo conectado a la ECU de un vehículo que permite realizar lecturas de distintas variables del vehículo y se comunica por bluetooth, en este caso con un ordenador. Esta comunicación se ha configurado y realizado mediante un script de python que también realiza la tarea de publicar las lecturas realizadas en el broker MQTT alojado en la RPI2.  Esta RaspberryPi (RPI2), además, ejecuta una aplicación que se suscribe al topic MQTT donde e...
Leer más

Proyecto aTIC (V) - Grafana

-
Imagen
 Grafana.  Como se ha podido ver en Proyecto aTIC (IV) - Bridge MQTT/InfluxDB , la RPI2 también dispone de la herramienta Grafana. Ésta está asignada a su puerto 3000 y es una herramienta de software libre que permite crear cuadros de mando y gráficos ( dashboards ). Se ha escogido esta herramienta para la visualización ya que se puede implementar sencillamente con Docker y porque tiene un API HTTP completo, además de que es compatible con InfluxDB. En este proyecto esta herramienta ha sido empleada para crear el dashboard que se muestra a continuación. En él se visualizan las lecturas de velocidad, nivel de batería y revoluciones por minuto del vehículo al que está conectado el sensor. Se emplean distiontos tipo s de gráficos, así como distintos colores para diferenciar fácilmente las lecturas. Además, se han añadido las visualizaciones de los valores medios, mínimos y máximos de la velocidad y el nivel de batería.    Estos datos se obtienen de la base de datos de ...
Leer más

Proyecto aTIC (IV) - Bridge MQTT/InfluxDB

-
Imagen
 Bridge MQTT/InfluxDB.  En el post anterior ( Proyecto aTIC (III) - Broker MQTT ) ya se ha comentado que la RPI2 funciona como bridge entre los datos publicados en el topic MQTT y la base de datos de InfluxDB. Esta función de brigde la realiza ejecutando un script en python que se define a continuación. 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 from influxdb import InfluxDBClient from typing import NamedTuple import random import time import paho.mqtt.client as mqtt import json from ast import literal_eval MQTT_CLIENT = 'RPI2' MQTT_ADDRESS = 'aticrpi2.duckdns.org' MQTT_TOPIC = 'Datos OBD' def on_connect (client, userdata, flags, rc): # Conexión y suscripción al topic print ( 'Connected with result code ' + str (rc)) client . subscribe(MQTT_TOPIC) def on_message (client, userdata, msg...
Leer más