mqtt-thread 1.6.4

Connection MQTT with thread

#mqtt_Thread

Connexion à un server mqtt via un thread
Envoi et réception des messages mqtt en Python
Sauvegarde des données reçues au format csv

INSTALLATION :
py -m pip install mqtt_thread
ou
py -m pip install mqtt_thread==x.x.x (mettre numéro de version)

exemple :
Trace de graphe mathPlotlib temps réel

---------------------
import matplotlib.pyplot as plt
import matplotlib.animation as animation
from matplotlib import style
from matplotlib.ticker import FormatStrFormatter
import numpy as np
import time
import mqtt_thread as MQTT # bibliothèque pypi

Creation de la figure pour la charge

fig = plt.figure(num=1, figsize=(10, 6), dpi=120, facecolor='w', edgecolor='k')# configuration du graphe
ax = fig.add_subplot(1, 1, 1)
labelGraphe = "Titre du graphe"

def messageArrived(): # fonction appelée par le thread MQTT quand un message arrive
if m.verbose:
print("msg arrivé")
try:
print("temp : ",m.lastLinedata[1])
except:
print("pas de dernière ligne")

def acquisition(i, xs, ys):
# Dessine les graphes
ax.clear()
ax.plot(xs, ys, 'r-o', label=labelGraphe)
ax.yaxis.set_major_formatter(FormatStrFormatter('%.2f'))
# Format du graphe
plt.xticks(rotation=45, ha='right')# rotation et alignement du texte axe x
plt.subplots_adjust(bottom=0.20)
plt.title('Graphe temps réel avec Python')
plt.ylabel('Valeur 1')
plt.xlabel('temps (s)')
plt.legend()
plt.grid()# la grille sera affichée

m = MQTT.MQTT_Thread("mqtt.url.fr",443,"login","pwd") # crée le thread
m.selectTopic(["node_iot2020/#","FABLAB_21_22/contes/bureau/temperature/out/"]) # topics auxquels on s'abonne
m.selectKey([["ecl","temps"],["temp","pression"]]) # selection des clés des données voulues , les données seront dans m.data[0][], m.data[1][],...

le dernier élement de m.data[i] est le temps de réception du message en secondes (donné par python avec la fonction time)

m.messageArrived = messageArrived # personnalisation fonction qui sera appelée à chaque réception de message
m.nomFichier = "donnees" # nom du fichier csv sans extension qui enregistrera les données
m.record = True # enregistre les données dans un fichier csv
m.eraseFile = True # efface le fichier csv avant d'enregistrer les données
m.verbose = True # affiche les messages MQTT
m.start() # démarre le thread, (exécution indépendante du programme principal)
time.sleep(1)
#m.client.publish("node_iot2020/test/in",payload="{"pression":1024}",qos=0)#publication d'un message vers MQTT

Appelle la fonction animation périodiquement

#m.data[0][1] est une liste !!!
ani = animation.FuncAnimation(fig, acquisition, fargs=(m.data[1][2], m.data[1][0]), frames=20,interval=1000,repeat=True)# intervall temps en ms entre 2 animations
plt.show()