Poprawka przykladu z publish mqtt: brakowalo client.loop_start()

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.
 ![Schamat zadania z MQTT](lab01/img/ztb_lab01_sch.png "Schamat zadania z MQTT")