Python, mqtt

[fips49]

Hallo zusammen und ich hoffe ich bin da richtig,

eigentlich soll es eine Haussteuerung mit Raspberry und Arduino werden. Da MQTT bei der Haussteuerung immer wieder auftaucht habe ich mich entschlossen einen Raspberry3 (Bezeichnung Respi2) mit MQTT (Mosquitto) zu installieren. Häuft recht gut (wie soll es auch bei Linux anders sein).

Ein anderer Raspberry3 (Bezeichnung Respi1) der meinen Teich steuert liefert auch ständig (ca 4 Sekunden dürfte von Programmablauf so sein) auch die Temperatur von meinem Schwimmteicht. Kommt auch bei meinen Respi2 auch an.

Möchte nun den Wert bei einen anderen Resperry ZeroW (Bezeichnung Respi3) auf einem LCD display mit Datum und Uhrzeit (sollen ständig laufen) anzeigen lassen.

Das jetzige Programm:

# Python3
# Projekt Haussteuerung Fips
# Start 12.08.2017 update 17032018
# Auslesen Auslesen MQTT und anzeigen auf einem LCD 20x4 über i2c
#
import lcddriver
import time
import os, datetime
import paho.mqtt.client as paho
import decimal

lcd = lcddriver.lcd()
lcd.lcd_clear()

def on_connect(client, userdata, flags, rc):
        print("Connected with result code " + str(rc))
def on_subscribe(client, userdata, mid, granted_qos):
        print("Subscribed: "+str(mid)+" "+str(granted_qos))
def on_message(client, userdata, msg):
        temp=(msg.payload)
        print("marker2"+"temperatur :"+str(temp))
        print("marker6")
        datum = datetime.datetime.now().strftime("%d.%m.%y")
        uhrzeit = datetime.datetime.now().strftime("%H:%M:%S")
        cpu = str( float(os.popen('cat /sys/class/thermal/thermal_zone0/temp').read()) / 1000.0 ) + "°"
        lcd.lcd_display_string((" "+ datum +"  "+ uhrzeit), 1)
        lcd.lcd_display_string("Teichtemp.:"+str(temp), 2)
        lcd.lcd_display_string("CPU Temp.: "+cpu+" ", 3)
        print("datum/Zeit =:"+datum +" "+ uhrzeit)
        print("cpu Temp :"+ cpu)
#       print("marker8"+"temp :"+str(temp))
#       print("marker9"+"on_message :"+str(on_message))
#       print("marker10"+"subsribe"+str(on_subscribe))
client = paho.Client()
client.on_subscribe = on_subscribe
client.on_message = on_message
client.connect("192.168.1.67", 1883)
client.subscribe("peter_mqtt/temperatur/teich", qos=1)
client.loop_forever()

1. Problem ich bekomme immer nur den Wert vom Teich als b'11.437' kann den Sting aber leider nicht zuschneiden habe schon einiges versucht.

2. Problem wenn ich es so laufen lasse stockt natürlich die Uhrzeit und ich möchte natürlich den aktuellen Teichwert nur alle 10 Minuten neu bekommen.

habe es auch schon mit einer while(1): Schleife versucht Nach

def on_message(client, userdata, msg):
        temp=(msg.payload)

damit ich es alle 10 Minuten abfragen kann. Hat aber leiden nichts gebracht.

Hat wer eine Idee das ich den Wert alle 10 Minuten abfragen kann und als Variable bekomme und es bei bedarf als def Anweisung abfragen kann?

Möchte mich schon einmal für die Hilfe bedanken.

Liebe Grüße fips49

Mod-Edit by eric2905, Code-Tags eingefügt

[arteck]

kannst du bitte Programmcodes in richtige Code-Tags einpacken…