MPY Official

Machine ESP32
MPY Docs

UIFlow 1.0 API

Hardwares

IR

Extensions

Unit

M5mqtt

Use APIs from the M5mqtt module to connect to an MQTT server and subscribe/publish message content.

  • Connect to MQTT Server

from m5mqtt import M5mqtt

// Create connection instance
m5mqtt = M5mqtt(
    client_id,
    server, 
    port=0, 
    user=None, 
    password=None, 
    keepalive=0,
    ssl=False, 
    ssl_params=None
)

// Start connection
m5mqtt.start()

while True:
  • Subscribe and Publish Messages

// Subscribe to messages
def callback(topic_data):
    print(topic_data)

m5mqtt.subscribe(topic, callback)


// Publish message
m5mqtt.publish(topic, data)
  • Other Configurations

// Set client last will message
m5mqtt.set_last_will(topic, msg)

// Disconnect
m5mqtt.deinit()
On This Page