mqtt rpi.py

import time
import paho.mqtt.client as paho
broker="192.168.x.xxx" #IP of your Raspberry Pi
#define callback
def on_message(client, userdata, message):
    time.sleep(1)
    print("received message =",str(message.payload.decode("utf-8")))

client= paho.Client("client-001")
client.on_message=on_message

print("connecting to broker ",broker)
client.connect(broker)
print("subscribing ")
client.subscribe("nodemcu")
client.loop_forever()