MQTT Subscriber Rpi

gistfile1.txt

sudo pip install paho-mqtt
sudo apt-get update




########### PYTHON 3 #############

from gpiozero import LED
from time import sleep
import paho.mqtt.client as mqtt
import sys

red=LED(22)
yellow=LED(27)
green=LED(17)


def on_connect(client, userdata, flags, rc):
        print("[STATUS] connected to broker "+str(rc))
        client.subscribe("bambootraffic")

def on_message(client, userdata, msg):
        payload = str(msg.payload)
        print("Payload is: "+ payload)

        if payload == "b'RED1'":
                red.on()

        if payload == "b'RED0'":
                red.off()

        if payload == "b'YELLOW1'":
                yellow.on()

        if payload == "b'YELLOW0'":
                yellow.off()

        if payload == "b'GREEN1'":
                green.on()

        if payload == "b'GREEN0'":
                green.off()
                

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.connect("iot.eclipse.org", 1883, 60)
client.loop_forever()