Capteur de température et serveur MQTT

Cet article montre l’utilisation d’un capteur de température DHT22 connecté sur un ESP32 pour envoyer régulièrement les valeurs de température et d’humidité vers un serveur MQTT. Il est conseillé d’utiliser un module DHT22, car celui-ci est compatible en tension 3.3V avec l’esp32.

L’ESP32 utilisé dans cette présentation est une carte de développement ESP-VROOM-32 de Espressif.

Le développement a été réalisé avec Thonny en MicroPython(esp32). L’application utilise un fichier « mqtt_pub.ini » situé sur la mémoire flash permettant de configurer le logiciel:

Plain Text

[mqtt_dht22]
# Informations de connexion au wifi et au serveur MQTT
ssid_id=xxxxxxxxxxx
ssid_passwd=xxxxxxxx
mqtt_server=999.999.9.999
client_id=xxxxxxxx
# Nom et mot de passe pour le server MQTT
username=xxxxxxxx
password=xxxxxxxx
# numero de broche du capteur dht22
dhtpin=99
# periode d'envoi des messages en secondes
periode=99

Normalement la bibliothèque dht est disponible dans toutes les implémentations MicroPython. Le brochage est simple, on peut utiliser n’importe quelle broche (GPIO) de l’esp32. Exemple:

Ce schéma a été réalisé avec TinyCad. Les modules DHT11 et DHT22 ont le méme brochage

L’application envoie à la période fixée dans le fichier de configuration trois topics

numéro de bloc
température
humidité

Le numéro de bloc est un entier à quatre chiffres permettant de numéroter les messages. Lorsque le compteur passe par 9999, il revient à zéro. Cela permet de faciliter les contrôles pour déterminer si l’application est toujours active.

Sur l’esp32, on utilise la LED bleue pour indiquer si tout est ok (LED bleue allumée).

Sur la mémoire flash, un fichier log « mqtt_out.log » contient les 30 dernières informations décrivant le fonctionnement de l’application. Ce nombre peut être facilement modifié dans le programme source (voir la fonction « pl »).

En cas de problème de connexion wifi, l’application essaie automatiquement de se reconnecter au wifi et au serveur MQTT.

Source à copier sous le nom boot.py de l’esp32:

Python

import time
import network
import dht
import machine 
import utime
import uos
from umqtt.simple import MQTTClient

def get_config(path):
    global ssid_id,ssid_passwd
    global mqtt_server,client_id,username,password
    global dhtpin,periode
    dico={}
    finp=open(path,"r")
    for ligne in finp:
        if ligne.startswith("#"):
            pass
        elif ligne.startswith("["):
            pass
        else:
            t=ligne.strip().split("=")
            if len(t)==2:
                dico[t[0]]=t[1]        
    ssid_id=dico["ssid_id"]
    ssid_passwd=dico["ssid_passwd"]
    mqtt_server =dico["mqtt_server"]
    client_id =dico["client_id"]
    username =dico["username"]
    password =dico["password"]
    dhtpin=int(dico["dhtpin"])
    periode=int(dico["periode"])

def padz(n,maxi=2):
    r=str(n)
    while len(r)<maxi:
        r="0"+r
    return r

def pl(message,maxligne=30):
    print(message)
    path='mqtt_out.log'
    with open(path, 'a') as f:
        f.write(message + '\n')
    with open(path, 'r') as f:
        lignes = f.readlines()
    if len(lignes)>maxligne:
        with open(path, 'w') as f:
            f.write(''.join(lignes[-maxligne:]))

def connect_wifi(ssid,passwd,maxtry=20):
    wlan=network.WLAN(network.STA_IF)
    wlan.active(True)
    if not wlan.isconnected():
        wlan.connect(ssid,passwd)
        nbtry=1
        while not wlan.isconnected():
            time.sleep_ms(500)
            nbtry+=1
            if nbtry>=maxtry:
                return "timeout"
    ip,masque,x,y=wlan.ifconfig()
    return str(ip)        
    
def send_message():
    global client,numero
    dht22.measure()
    temperature = dht22.temperature()
    humidity = dht22.humidity()
    numero+=1
    if numero>=10000:
        numero=1
    pl("pub numero")    
    client.publish("maison/garage/numero",padz(numero,4))
    pl("pub temperature")
    client.publish("maison/garage/temperature",padz(temperature))
    pl("pub humidite")
    client.publish("maison/garage/humidite",padz(humidity))
    
def redemarrer():
    time.sleep(10)
    pl("reset")
    machine.reset()
    
#— MAIN ——————————-
led = machine.Pin(2, machine.Pin.OUT)
led.off()
numero=0
try:    
    get_config("mqtt_pub.ini")
    pin = machine.Pin(dhtpin, machine.Pin.IN)
    dht22 = dht.DHT22(pin)
    pl("Connexion Wifi")
    retcode=connect_wifi(ssid_id,ssid_passwd)
    pl(retcode)
    if retcode=="timeout":
        redemarrer()
    pl("Connexion au broker")
    client = MQTTClient(client_id, mqtt_server, user=username, password=password)
    client.connect()
    pl("connexion serveur mqtt ok")
    led.on()
    while True:
        send_message()
        time.sleep(periode)
except Exception as e:
    pl(str(e))
    pl("Application stoppee")
    redemarrer()

Grimeco

Capteur de température et serveur MQTT

A DECOUVRIR EGALEMENT

Reconnaissance vocale et synthèse de parole

Mesure d’un niveau d’eau avec un ESP32

Laisser un commentaire Annuler la réponse