Das deutsche Python-Forum

Code: Alles auswählen

#!/usr/bin/env python3

import logging
import time
import paho.mqtt.client as mqtt
import sys
from gpiozero import LED
from gpiozero import Button

GPIO22 = LED(22)
GPIO10 = LED(10)
GPIO9 = LED(9)
GPIO11 = LED(11)
GPIO0 = LED(0)
GPIO6 = LED(6)
GPIO13 = LED(13)
GPIO16 = LED(16)
GPIO25 = LED(25)
GPIO24 = LED(24)
GPIO23 = LED(23)
GPIO15 = LED(15)
GPIO14 = LED(14)

TOPIC = "gpio/#"

broker_address="localhost"
port = 1883
client = mqtt.Client("GPIO")
username = 'username'
password = 'password'



def on_message(client, userdata, message):

	if "gpio/22/on" in (message.topic):
		GPIO22.on()
	if "gpio/22/off" in (message.topic):
		GPIO22.off()


	if "gpio/10/on" in (message.topic):
		GPIO10.on()
	if "gpio/10/off" in (message.topic):
		GPIO10.off()


	if "gpio/9/on" in (message.topic):
		GPIO9.on()
	if "gpio/9/off" in (message.topic):
		GPIO9.off()


	if "gpio/11/on" in (message.topic):
		GPIO11.on()
	if "gpio/11/off" in (message.topic):
		GPIO11.off()


	if "gpio/0/on" in (message.topic):
		GPIO0.on()
	if "gpio/0/off" in (message.topic):
		GPIO0.off()


	if "gpio/6/on" in (message.topic):
		GPIO6.on()
	if "gpio/6/off" in (message.topic):
		GPIO6.off()


	if "gpio/13/on" in (message.topic):
		GPIO13.on()
	if "gpio/13/off" in (message.topic):
		GPIO13.off()


	if "gpio/16/on" in (message.topic):
		GPIO16.on()
	if "gpio/16/off" in (message.topic):
		GPIO16.off()


	if "gpio/25/on" in (message.topic):
		GPIO25.on()
	if "gpio/25/off" in (message.topic):
		GPIO25.off()


	if "gpio/24/on" in (message.topic):
		GPIO24.on()
	if "gpio/24/off" in (message.topic):
		GPIO24.off()


	if "gpio/23/on" in (message.topic):
		GPIO23.on()
	if "gpio/23/off" in (message.topic):
		GPIO23.off()


	if "gpio/15/on" in (message.topic):
		GPIO15.on()
	if "gpio/15/off" in (message.topic):
		GPIO15.off()


	if "gpio/14/on" in (message.topic):
		GPIO14.on()
	if "gpio/14/off" in (message.topic):
		GPIO14.off()




def on_connect(client, userdata, flags, rc):
    print("Connected to MQTT Broker: " + broker_address)
    client.subscribe(TOPIC)

if __name__ == "__main__":
	client = mqtt.Client()
	client.on_connect = on_connect
	client.on_message = on_message
	client.username_pw_set(username, password)
	client.connect(broker_address, port)
	client.loop_forever()

Code: Alles auswählen

gpio/22/on
gpio/22/off

Code: Alles auswählen

gpio/22/on  wird zu 
gpio $1 $2   		womit ich dann statt hard codiert
GPIO22.on()  	schreibe vieleicht schreiben könnte
GPIO$1.$2()

Code: Alles auswählen

#!/usr/bin/env python3
import paho.mqtt.client as mqtt
from gpiozero import LED


TOPIC = "gpio/#"
BROKER_ADDRESS = "localhost"
BROKER_PORT = 1883
USERNAME = "username"
PASSWORD = "password"

ACTION_TEXT_TO_VALUE = {"on": 1, "off": 0}


def on_connect(client, _pin_number_to_led, _flags, _reason_code, _properties):
    print("Connected to MQTT Broker: " + client.host)
    client.subscribe(TOPIC)


def on_message(_client, pin_number_to_led, message):
    _, pin_number_text, action_text = message.topic.split("/")
    led = pin_number_to_led[int(pin_number_text)]
    led.value = ACTION_TEXT_TO_VALUE[action_text]


def main():
    client = mqtt.Client(
        mqtt.CallbackAPIVersion.VERSION2,
        userdata={
            pin_number: LED(pin_number)
            for pin_number in [0, 6, 9, 10, 11, 13, 14, 15, 16, 22, 23, 24, 25]
        },
    )
    client.on_connect = on_connect
    client.on_message = on_message
    client.username_pw_set(USERNAME, PASSWORD)
    client.connect(BROKER_ADDRESS, BROKER_PORT)
    client.loop_forever()


if __name__ == "__main__":
    main()