diff --git a/lab01/README.md b/lab01/README.md index ef89e2c5943f81cb1964d838c699db04dce4d4ed..ec47916daf65bf86459e9015f08b0a50e33d3abc 100644 --- a/lab01/README.md +++ b/lab01/README.md @@ -136,22 +136,27 @@ client.loop_forever() import paho.mqtt.client as mqtt import time +# def on_log(client, userdata, level, buf): +# print("log: ",buf) + flag_connected = 0 def on_connect(client, userdata, flags, rc): global flag_connected flag_connected = 1 + print("Connected with result code "+str(rc)) def on_disconnect(client, userdata, rc): global flag_connected flag_connected = 0 + print("Disconnected with result code "+str(rc)) client = mqtt.Client() client.on_connect = on_connect client.on_disconnect = on_disconnect +#client.on_log=on_log client.connect("localhost", 1883, 60) client.loop_start() - while(True): if flag_connected == 1: # Publish message @@ -161,7 +166,9 @@ while(True): time.sleep(1) else: # Wait to reconnect + time.sleep(5) 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. 