Proyecto aTIC (III) - Broker MQTT

-

 Broker MQTT. 

En el primer post (Proyecto aTIC (I) - Introducción) ya se ha determinado que la RPI2 va a alojar un broker MQTT en el que el ordenador, mediante un script de python, publicará los datos recogidos del sensor bajo un topic. El nombre del topic es "Datos OBD".


Este broker MQTT es de mosquitto (como se puede ver en la siguiente sección de código), donde se muestra el Docker Compose de la RPI2. De nuevo, como en la RPI1, se emplea Docker Compose y se especifican los servicios de Portainer, Grafana, Mosquitto y Python.

 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
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

  grafana:
    container_name: grafana
    image: grafana/grafana:6.3.6
    restart: unless-stopped
    user: "0"
    ports:
      - 3000:3000
    env_file:
      - ./services/grafana/grafana.env
    volumes:
      - ./volumes/grafana/data:/var/lib/grafana
      - ./volumes/grafana/log:/var/log/grafana

  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

Como se observa, el servicio de Mosquitto es accesible desde el puerto 1883 y gracias a que se ha configurado una DNS mediante Duck DNS como en el caso de la base de datos InfluxDB de la RPI1, el broker es accesible remotamente mediante la dirección:

http://aticrpi2.duckdns.org:1883

Así, el ordenador que recoge los datos del sensor puede publicar datos en el topic aunque no se encuentre conectado a la misma red. Para comprobar que esta publicación de datos se realizaba correctamente remotamente, se ha hecho uso de MQTT.fx para visualizar las publicaciones bajo el topic "Datos OBD". Se ha confiurado el broker al que acceder de la siguiente manera en la herramienta MQTT.fx, donde se ve que se emplea la DNS y se accede remotamente.

Gracias a esto, y suscribiéndose al topic "Datos OBD", se pudo comprobar que los datos se publicaban correctamente desde el ordenador y quedaban disponibles para la RPI2 para enviarlos por HTTP a la base de datos de InfluxDB alojada en la RPI1.
Este servicio bridge que realiza la RPI2 que se acaba de describir, se explica con más profundidad en el siguiente post de esta serie: Proyecto aTIC (IV) - Bridge MQTT/InfluxDB.

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