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