pikapython/test/python/mqtt/mqtt_connect.py

import mqtt

client = mqtt.MQTT('192.168.1.255')

client.setHost('broker.emqx.io')
client.setPort(1883)
client.setClientID('123456dddecetdc')
client.setUsername('test1')
client.setPassword('aabbccdd')
client.setVersion('4')
client.setKeepAlive('10')

ret = client.connect()
print("ret:%d" % ret)

client.publish('topic1234', 'hello pikascript')


def callback1(signal):
    print("py cb: %s:%s" % (client.recv_topic, client.recv_msg))


ret = client.subscribe('topic', 1, callback1)

client.listSubscribrTopic()

#ret = client.disconnect()
#print("ret:%d" % ret)