In [ ]:
import mosquitto
In [ ]:
client = mosquitto.Mosquitto('rmqid-test')
In [ ]:
client.connect('localhost')
In [ ]:
client.publish('mqtt/example', 'hello world from MQTT via Python', 1)
In [ ]:
client.loop()
In [ ]:
client.disconnect()
client.loop()