programowanie:python:mqtt

Różnice

Różnice między wybraną wersją a wersją aktualną.

Odnośnik do tego porównania

Poprzednia rewizja po obu stronach Poprzednia wersja
Nowa wersja		 Poprzednia wersja
programowanie:python:mqtt [2024/09/08 12:19] – sasesprogramowanie:python:mqtt [2024/10/18 15:58] (aktualna) – [Publikacja] sases
Linia 9: Linia 9:
 <code python> <code python>
 import random import random
 +import logging
 from paho.mqtt import client as mqtt_client from paho.mqtt import client as mqtt_client
 +
 +logging.basicConfig(level=logging.INFO)
  
 broker = '127.0.0.1' broker = '127.0.0.1'
Linia 21: Linia 24:
     def on_connect(client, userdata, flags, rc):     def on_connect(client, userdata, flags, rc):
         if rc == 0:         if rc == 0:
-            print("Connected to MQTT Broker!")+            logging.info("Connected to MQTT Broker!")
         else:         else:
-            print("Failed to connect, return code %d\n", rc)+            logging.error(f"Failed to connect, return code {rc}") 
 +            # Attempt to reconnect 
 +            client.reconnect()
  
     client = mqtt_client.Client(client_id)     client = mqtt_client.Client(client_id)
Linia 36: Linia 41:
 ===== Subskrypcja ===== ===== Subskrypcja =====
 <code python> <code python>
-def subscribe(client: mqtt_client):+def subscribe(client: mqtt_client, topics):
     def on_message(client, userdata, msg):     def on_message(client, userdata, msg):
-        print(f"Received `{msg.payload.decode()}` from `{msg.topic}` topic")+        logging.info(f"Received `{msg.payload.decode()}` from `{msg.topic}` topic")
  
-    client.subscribe('topic/topic')+    for topic in topics: 
 +        client.subscribe(topic)
     client.on_message = on_message     client.on_message = on_message
 </code> </code>
Linia 53: Linia 59:
 status = result[0] status = result[0]
 if status == 0: if status == 0:
-   print(f"Send `{msg}` to topic `{topic}`")+   logging.info(f"Send `{msg}` to topic `{topic}`")
 else: else:
-   print(f"Failed to send message to topic {topic}")+   logging.error(f"Failed to send message to topic {topic}")
 </code> </code>
 \\ \\
Linia 61: Linia 67:
  
 ===== Pętla obsługująca MQTT ===== ===== Pętla obsługująca MQTT =====
-Przykład 1:+ 
 +== Przykład 1: ==
 <code python> <code python>
 client.loop_start() client.loop_start()
Linia 71: Linia 78:
 </code> </code>
  
-Przykład 2:+== Przykład 2: ==
 <code python> <code python>
 while True: while True:
  • programowanie/python/mqtt.1725790786.txt.gz
  • ostatnio zmienione: 2024/09/08 12:19
  • przez sases