Micropython MQTT for ESP8266

MQTT

  import random import time from umqtt_simply import MQTTClient import ubinascii import machine import micropython import network import esp esp.osdebug(None) import gc gc.collect() ssid = 'AFFAN' password = '66666666' mqtt_server = 'broker.hivemq.com' #EXAMPLE IP ADDRESS #mqtt_server = '192.168.1.144' client_id = ubinascii.hexlify(machine.unique_id()) topic_sub = b'notification' topic_pub = b'hello' last_message = 0 message_interval = 5 counter = 0 def genstr(): str0= "TXTs" return ''.join(str0) station = network.WLAN(network.STA_IF) station.active(True) station.connect(ssid, password) while station.isconnected() == False: pass while station.isconnected() == True: print('Connection successful') print(station.ifconfig()) c = MQTTClient("umqtt_client", mqtt_server) c.connect() c.publish(b"relay1", b"Off") c.disconnect() time.sleep(10)

MQTT 2

import time from umqtt_simply import MQTTClient import ubinascii import machine import micropython import network import esp esp.osdebug(None) import gc gc.collect() ssid = 'AFFAN' password = '66666666' mqtt_server = 'broker.hivemq.com' #EXAMPLE IP ADDRESS #mqtt_server = '192.168.1.144' client_id = ubinascii.hexlify(machine.unique_id()) topic_sub = b'relay0' topic_pub = b'relay1' last_message = 0 message_interval = 15 counter = 0 station = network.WLAN(network.STA_IF) station.active(True) station.connect(ssid, password) while station.isconnected() == False: pass def sub_cb(topic, msg): print((topic, msg)) if topic == b'relay0' and msg == b'off': print('ESP received OFF message') def connect_and_subscribe(): global client_id, mqtt_server, topic_sub client = MQTTClient(client_id, mqtt_server) client.set_callback(sub_cb) client.connect() client.subscribe(topic_sub) print('Connection successful') print(station.ifconfig()) print('Connected to %s MQTT broker, subscribed to %s topic' % (mqtt_server, topic_sub)) return client def restart_and_reconnect(): print('Failed to connect to MQTT broker. Reconnecting...') time.sleep(10) machine.reset() try: client = connect_and_subscribe() except OSError as e: restart_and_reconnect() while True: try: client.check_msg() if (time.time() - last_message) > message_interval: msg = 'Hello #%d' % counter client.publish(topic_pub, msg) last_message = time.time() counter += 1 except OSError as e: restart_and_reconnect()