moodlights_on-full.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="172.18.16.25"
#broker_address="iot.eclipse.org"
print("creating new instance")
client = mqtt.Client("P1") #create new instance
client.on_message=on_message #attach function to callback
print("connecting to broker")
client.connect(broker_address) #connect to broker
client.loop_start() #start the loop
print("Subscribing to topic","moodlight/sonoff/cmnd/power")
client.subscribe("moodlight/sonoff/cmnd/power")
print("Publishing message to topic","moodlight/sonoff/cmnd/power")
client.publish("moodlight/sonoff/cmnd/power","on")
client.publish("moodlight/1/blue","1023")
client.publish("moodlight/2/blue","1023")
client.publish("moodlight/3/blue","1023")
client.publish("moodlight/4/blue","1023")
client.publish("moodlight/5/blue","1023")
client.publish("moodlight/6/blue","1023")

client.publish("moodlight/1/red","1023")
client.publish("moodlight/2/red","1023")
client.publish("moodlight/3/red","1023")
client.publish("moodlight/4/red","1023")
client.publish("moodlight/5/red","1023")
client.publish("moodlight/6/red","1023")

client.publish("moodlight/1/green","1023")
client.publish("moodlight/2/green","1023")
client.publish("moodlight/3/green","1023")
client.publish("moodlight/4/green","1023")
client.publish("moodlight/5/green","1023")
client.publish("moodlight/6/green","1023")
time.sleep(4) # wait
client.loop_stop() #stop the loop