From 0ad29842396ad735e5f69dd30343c933445876ec Mon Sep 17 00:00:00 2001 From: Robert Piotrowski <robert.piotrowski1@pg.edu.pl> Date: Tue, 19 Jan 2021 21:29:09 +0000 Subject: [PATCH] Poprawiono publisher mqtt w pierwszym przykladzie: dodano reconnect --- lab01/README.md | 28 ++++++++++++++++++++++++---- 1 file changed, 24 insertions(+), 4 deletions(-) diff --git a/lab01/README.md b/lab01/README.md index 3929de5..f010f1c 100644 --- a/lab01/README.md +++ b/lab01/README.md @@ -135,13 +135,33 @@ client.loop_forever() ```python import paho.mqtt.client as mqtt import time + +flag_connected = 0 +def on_connect(client, userdata, flags, rc): + global flag_connected + flag_connected = 1 + +def on_disconnect(client, userdata, rc): + global flag_connected + flag_connected = 0 + client = mqtt.Client() +client.on_connect = on_connect +client.on_disconnect = on_disconnect client.connect("localhost", 1883, 60) + + + while(True): - client.publish("led/504", "1") - time.sleep(0.5) - client.publish("led/504", "0") - time.sleep(0.5) + if flag_connected == 1: + # Publish message + client.publish("led/504", "1") + time.sleep(1) + client.publish("led/504", "0") + time.sleep(1) + else: + # Wait to reconnect + client.reconnect() ``` - Zadanie: NaleĹźy napisaÄ oprogramowanie wg poniĹźszego schamatu, ktĂłre za pomocÄ serwera MQTT bedzie odbierac wiadomoĹci z aplikacji button.py oraz odpowiednio nadwaÄ wiadmosci do aplikacji led.py.  -- GitLab