# .';:cc;. # .,',;lol::c. # ;';lddddlclo # lcloxxoddodxdool:,. # cxdddxdodxdkOkkkkkkkd:. # .ldxkkOOOOkkOO000Okkxkkkkx:. # .lddxkkOkOOO0OOO0000Okxxxxkkkk: # 'ooddkkkxxkO0000KK00Okxdoodxkkkko # .ooodxkkxxxOO000kkkO0KOxolooxkkxxkl # lolodxkkxxkOx,. .lkdolodkkxxxO. # doloodxkkkOk .... .,cxO; # ddoodddxkkkk: ,oxxxkOdc'..o' # :kdddxxxxd, ,lolccldxxxkkOOOkkkko, # lOkxkkk; :xkkkkkkkkOOO000OOkkOOk. # ;00Ok' 'O000OO0000000000OOOO0Od. # .l0l.;OOO000000OOOOOO000000x, # .'OKKKK00000000000000kc. # .:ox0KKKKKKK0kdc,. # ... # # Author: peppe8o # Date: Jul 28th, 2022 # Version: 1.0 # https://peppe8o.com import netman import time from umqttsimple import MQTTClient from machine import Pin country = 'IT' ssid = 'yourWiFiSSID' password = 'yourWiFiPassword' wifi_connection = netman.connectWiFi(ssid,password,country) #mqtt config mqtt_server = '192.168.1.91' client_id = 'PicoW' user_t = 'pico' password_t = 'picopassword' topic_pub = 'hello' last_message = 0 message_interval = 5 counter = 0 #MQTT connect def mqtt_connect(): client = MQTTClient(client_id, mqtt_server, user=user_t, password=password_t, keepalive=60) client.connect() print('Connected to %s MQTT Broker'%(mqtt_server)) return client #reconnect & reset def reconnect(): print('Failed to connected to MQTT Broker. Reconnecting...') time.sleep(5) machine.reset() while True: try: client = mqtt_connect() except OSError as e: reconnect() while True: try: client.publish(topic_pub, msg='Hello from Pico!') print('published') time.sleep(3) except: reconnect() pass client.disconnect()