Scribd
Importer
12 vues2 pages

Client MQTT en Python avec Paho

Ce code Python explique comment créer un client et un publisher MQTT à l'aide de la bibliothèque Paho pour se connecter à un broker HiveMQ et publier/souscrire à des topics.

Transféré par

Aziz Bech
Copyright
© All Rights Reserved
Nous prenons très au sérieux les droits relatifs au contenu. Si vous pensez qu’il s’agit de votre contenu, signalez une atteinte au droit d’auteur ici.
Formats disponibles
Téléchargez aux formats DOCX, PDF, TXT ou lisez en ligne sur Scribd
12 vues2 pages

Client MQTT en Python avec Paho

Ce code Python explique comment créer un client et un publisher MQTT à l'aide de la bibliothèque Paho pour se connecter à un broker HiveMQ et publier/souscrire à des topics.

Transféré par

Aziz Bech
Copyright
© All Rights Reserved
Nous prenons très au sérieux les droits relatifs au contenu. Si vous pensez qu’il s’agit de votre contenu, signalez une atteinte au droit d’auteur ici.
Formats disponibles
Téléchargez aux formats DOCX, PDF, TXT ou lisez en ligne sur Scribd

EXPLICATION DE CODE PYTHON REALISE (subscriber) :

Code SUBSCRIBER :
import [Link] as

mqtt broker_address = "[Link]"

broker_port = 1883

topic= "mon_tpiot1"

def on_message(client, userdata, message): print(f"Received message on


topic {[Link]}: {[Link]()}")

if [Link]() in ["on","off"] :

print("led is "+[Link]())

client = [Link]()

client.on_message = on_message

[Link]("[Link]")

[Link]("mon_tpiot1")

client.loop_forever()

Ce code Python utilise la bibliothèque Paho MQTT pour créer


un client MQTT qui se connecte au broker HiveMQ public. Il
souscrit également au topic "mon_tpiot1" et définit une
fonction de rappel "on_message" pour gérer les messages
entrants.
La fonction "on_message" est appelée chaque fois qu'un
message est reçu sur le topic "mon_tpiot1". Elle affiche
ensuite un message avec le nom du topic et la charge utile du
message décodée. Si la charge utile est "on" ou "off", elle
affiche également un message indiquant l'état de la LED.
Enfin, la boucle de client MQTT est exécutée en permanence
à l'aide de la méthode "loop_forever()" pour traiter les
messages entrants de manière continue.
EXPLICATION DE CODE PYTHON REALISE(publisher) :
Code PUBLISHER:

import [Link] as publish

topic = "mon_tpiot1"

topic = "TP3"

while True :

message = input()

broker [Link](topic_1, message, hostname="[Link]",


port=broker_port)

[Link](topic_2, message, hostname="[Link]",


port=broker_port)

Ce code Python utilise la bibliothèque Paho MQTT pour


publier des messages à deux topics différents, "mon_tpiot1"
et "TP3", à l'aide de la fonction "[Link]".
Il utilise également une boucle "while True" pour attendre
une entrée utilisateur, puis publier le message entré à chacun
des deux topics. Les messages sont envoyés en utilisant le
broker HiveMQ public avec l'adresse IP "[Link]"
et le port 1883, qui est le port par défaut pour MQTT.
R

Vous aimerez peut-être aussi