Das deutsche Python-Forum

Code: Alles auswählen

def on_message(client, userdata, message):
  if topic == '/mach/was':
    if msg == 'NIX':
       print("ENDE")
        ... Publish eine Nachricht in ein topic ...
   if msg == 'START':
       ... oder wie kann ich das tun ...
 

Code: Alles auswählen

#!/usr/bin/python3.5

import paho.mqtt.client as mqtt
global runme

def on_connect( client, userdata, flags, rc):
    print ("Connected with Code :" +str(rc))
    # Subscribe Topic from here
    client.subscribe("/abstand/#")


def on_message(client, userdata, message):
 msg = str(message.payload.decode("utf-8"))
 topic = str(message.topic)
 global runme
 if topic == '/abstand/pumpe':
   if msg == 'STOP':
       print("STOPen")
       runme = 1
       #mqtt.publish("/wassertonne/relay/", "0") # Versuch geht nicht
   if msg == 'START':
       print("STARTEN")
       #client.publish("/wassertonne/relay/", "0", hostname="iot.eclipse.org") # Auch der Versuch mit .loop_forever()
       runme = 2
       

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

client.username_pw_set("agent", "geheim")
client.connect("localhost", 1883, 60)

# client.loop_forever() # war vorher...
client.loop_start()
time.sleep(1)
runme = 0
while True:
    if runme == 1:
        client.publish("/wassertonne/relay/", "0")
        client.publish("/abstand/set", "pumpoff")
        runme = 0
        
    if runme == 2:
        client.publish("/wassertonne/relay/", "1")
        client.publish("/abstand/set", "pumpan")
        runme = 0
        
    time.sleep(0.5)

client.loop_stop()
client.disconnect()

Code: Alles auswählen

if msg == 'STOP':
       print("STOPen")
       mqtt.publish("/wassertonne/relay/", "0")
       print("fertig")

Code: Alles auswählen

#!/usr/bin/env python3.5
import paho.mqtt.client as mqtt


def on_connect(client, _userdata, _flags, return_code):
    print("Connected with Code:", return_code)
    client.subscribe("/abstand/#")


def on_message(client, _userdata, message):
    if message.topic == "/abstand/pumpe":
        command = message.payload.decode("utf-8")
        if command == "STOP":
            print("STOPen")
            client.publish("/wassertonne/relay/", "0")
            client.publish("/abstand/set", "pumpoff")
        elif command == "START":
            print("STARTEN")
            client.publish("/wassertonne/relay/", "1")
            client.publish("/abstand/set", "pumpon")
        else:
            print("Unbekanntes Kommando {!r}!".format(command))


def main():
    client = mqtt.Client()
    client.on_connect = on_connect
    client.on_message = on_message
    client.username_pw_set("agent", "geheim")
    client.connect("localhost", 1883, 60)
    try:
        client.loop_forever()
    except KeyboardInterrupt:
        pass  # Ignored intentionally.
    finally:
        client.loop_stop()
        client.disconnect()


if __name__ == "__main__":
    main()

Code: Alles auswählen

if msg == 'START':
       print("STARTEN")   # Erscheint auf der console
       client.publish("/wassertonne/relay/", "0", hostname="mywatercli") # auch keine Meldung auf Server
       print("STARTEN")  # Erscheint NICHT auf der console