Arduino/esp8266/eproj2/ex2sub.py

import paho.mqtt.client as mqtt #import the client1
import time
def on_message(client, userdata, message):
    print("message received " ,str(message.payload.decode("utf-8")))
    print("message topic=",message.topic)
    print("message qos=",message.qos)
    print("message retain flag=",message.retain)
broker_address="192.168.1.153" 
#broker_address="iot.eclipse.org"
print("creating new instance")
client = mqtt.Client("ex2sub") #create new instance
print("connecting to broker")
client.connect(broker_address) #connect to broker
client.on_message=on_message
print("Subscribing to topic","sensor_data")
client.loop_start()
client.subscribe("sensor_data")
while 1:
	time.sleep(2)


#time.sleep(2) # wait
#client.loop_stop()