Script zum Auswerten und kombinieren von mqtt Daten

Ich habe nie richtig Programmieren gelernt, bin aber absolut in der Lage Beispielcode für meine Zwecke anzupassen. Ich habe schon ein wenig gegoogelt doch die Beispiele, die ich fand gingen nie über eine Ausgabe des abonnierte Topics/Payloads hinaus. Vielleicht könnt ihr mich ja in die richtige Richtung lootsen, gerne auch auf eine andere Website für Bash oder Python.

Ausgangslage:

Ich habe zwei Außenensoren für Temperatur und Luftfeuchtigkeit, wegen der Gegebenheiten hängt einer davon bis Mittags in der Sonne und der andere Sensor danach, was die ermittelten Daten leider unbrauchbar macht. Diese 433mHz Sensoren lasse ich mit rtl_433 und einem entsprechenden Funkempfänger am Pi auslesen und an mosquitto senden. Hier kommen von jedem Sensor etwa alle 30 Sekunden neue Werte.

Außerdem habe ich ein Python Script gefunden und auf Einzeltopics angepasst, mit dem ich Wetterdaten von openweathermap.org (OWM) für meinen Ort abrufe und ebenfalls nach mosquitto veröffentliche. Das läuft alle 2 Minuten per cron-job.

Was will ich tun?

Da OWM sicher keine Messstation in meinem Dorf hat, dürften die erhaltenen Daten irgendwie extrapoliert sein und auch meine Außensensoren sind nur für Consumer "Wetterstationen" gedacht, also auch nicht sonderlich genau. Deshalb möchte ich Mittelwerte bilden.

Ich möchte ein dauerhaft laufendes Script (Batch oder Python), das 6 topics abonniert. Jeweils temperature_C und humidity meiner beiden Sensoren und der OWM-Daten.

Immer wenn nun Daten von OWM eintreffen (alle 2 min) sollen die zuletzt empfangenen und gespeicherten Daten meiner Funksensoren kombiniert werden und als neues Topic an mqtt gehen. Also getrennt nach topic, wenn owm/temperature_C dann bilde Mittelwert der Temperaturen und wenn topic owm/humidity reinkommt dann Mittelwert der Luftfeuchten bilden.

05:30 - 12:00 -> (OWM + Sensor1) / 2
12:01 - 21:59 -> (OWM + Sensor2) / 2
22:00 - 05:29 -> (OWM + Sensor1 + Sensor2) / 3

Das ganze ich nicht wirklich wichtig oder nötig, ich würde gerne aber meine Skills etwas erweitern.

Danke sschuste für den Tipp. Für meine Zwecke scheint das aber übertrieben. Vielleicht schau ich mir das mal bei einem anderen, zukünftigen Projekt an.

Allerdings hatte ich gerade noch eine Idee, mit einem etwas pragmatischerem Ansatz. Da ich ohnehin zwei Raspis am start habe, habe ich einfach auf dem zweiten auch noch einen Broker aufgesetzt, der von rtl_433 Nachrichten mit Retain-Flag annimmt. Leider kann ich das bei rtl_433 nicht auf topics bzw Messageormat eingrenzen und man kann auch nur eine Pub-Verbindung mit dem selben Broker anlegen, deshalb zwei Broker.

Jetzt will ich dann am Ende meines vorhandenen Python-Scripts ein Bash-Script starten, welches dann je nach Zeit über mosquitto_sub -C 1 -t rtl/sensor1/temperature_C den letzten Wert abgreift und zusätzlich auch noch das topic rtl/sensor1/time überprüft, in dem der Zeitstempel der letzten Übertragung hinterlegt ist. -C 1 "wartet" auf nur eine Nachricht und beendet dann die Subscription, da ratain ja gecached wird, kommt die Antwort sofort.

Ich berichte dann nächste Woche

Läuft schon fast. Ich hab mein vorhandenes Python Skript, dass die Daten von OWM holt und nach mqtt schickt, erweitert. Allerdings sehr unfein über einen externen Aufruf des Linuxprogramms.

Kann mir bitte noch wer verraten, wie ich direkt in Python/paho.mqtt einen einmaligen Wert auslese, also das equivalent zum mosquitto_sub -C 1?

import os

sensor1t = "mosquitto_sub -h 192.168.xx.xx -N -C 1 -t rtl/20/55/time"
sensor1c = "mosquitto_sub -h 192.168.xx.xx -N -C 1 -t rtl/20/55/temperature_C"
sensor1h = "mosquitto_sub -h 192.168.xx.xx -N -C 1 -t rtl/20/55/humidity"

sensor2t = "mosquitto_sub -h 192.168.xx.xx -N -C 1 -t rtl/20/80/time"
sensor2c = "mosquitto_sub -h 192.168.xx.xx -N -C 1 -t rtl/20/80/temperature_C"
sensor2h = "mosquitto_sub -h 192.168.xx.xx -N -C 1 -t rtl/20/80/humidity"

s1t = int(os.popen(sensor1t).read())
s1c = float(os.popen(sensor1c).read())
s1h = int(os.popen(sensor1h).read())

s2t = int(os.popen(sensor2t).read())
s2c = float(os.popen(sensor2c).read())
s2h = int(os.popen(sensor2h).read()

und ja, ich weiß, das Python mit round() nicht immer korrekt kaufmännisch rundet, ist hierfür aber nicht wirklich relevant.