Python MQTT Pub/Sub

mqtt.py

import paho.mqtt.client as mqtt #pip install paho.mqtt

client = mqtt.Client()
client.username_pw_set(username="testuser",password="testpass")
client.connect("192.168.0.101", 1883)

# PUBLISH
client.publish("Topic", "hello server")

# SUBSCRIBE
def on_message(client, userdata, message):
    print("Message Recieved: " + message.payload.decode())

client.on_message = on_message
client.subscribe("test1", qos=1)

client.loop_forever()