Lightweight MQTT Publish works on esp8266

[slzatz]

Andrew published a simple script in the WiPy section http://forum.micropython.org/viewtopic. ... mqtt#p6545 to do MQTT publish and just wanted to note that it works on the esp8266 with just updating to the current version of micropython code available in the git repository.

Code: Select all

# Borrowed from Andrew http://forum.micropython.org/viewtopic.php?t=1101#p6545

import network
import lwip
from time import sleep

def mtStr(s):
  return bytes([len(s) >> 8, len(s) & 255]) + s.encode('utf-8')

def mtPacket(cmd, variable, payload):
  return bytes([cmd, len(variable) + len(payload)]) + variable + payload

def mtpConnect(name):
  return mtPacket(
       0b00010000,
       mtStr("MQTT") + # protocol name
       b'\x04' +       # protocol level
       b'\x00' +       # connect flag
       b'\xFF\xFF',    # keepalive
       mtStr(name)
                 )

def mtpDisconnect():
  return bytes([0b11100000, 0b00000000])

def mtpPub(topic, data):
  return  mtPacket(0b00110001, mtStr(topic), data)

wlan = network.WLAN(network.STA_IF) 
wlan.active(True)    
wlan.connect('essid', 'password') 
print('Connected =',wlan.isconnected())      

s = lwip.socket()
s.connect('xx.xx...', 1883)
s.send(mtpConnect("somename"))
time.sleep(2) 
s.send(mtpPub("topic...", b'message'))
s.send(mtpDisconnect())
s.close()

[pfalcon]

Thanks for sharing. That's the whole idea of MicroPython - power of Python language and our (MicroPython's) adherence to standard APIs makes developing and porting many things very easy. As a small comment, you don't need to do "import lwip", just use standard "socket" module. You can also test and debug your code on desktop version of MicroPython (and usually, Python3) - that's another benefit of MicroPython.