|
|
|
@ -45,7 +45,9 @@ def rohdaten_laden(timestamp, stationsname):
|
|
|
|
|
zusatzwetterdaten_liste = []
|
|
|
|
|
for nr, datensatz in enumerate(query):
|
|
|
|
|
LOGGER.debug(f"Datensatz {nr + 1} von {gesamtzahl}")
|
|
|
|
|
rohdaten = {"ts": datensatz.date_time}
|
|
|
|
|
ts = datensatz.date_time
|
|
|
|
|
ts_with_tz = ts.replace(tzinfo=datetime.timezone.utc)
|
|
|
|
|
rohdaten = {"ts": ts_with_tz}
|
|
|
|
|
if datensatz.us_units == 1:
|
|
|
|
|
rohdaten["outtemp"] = mwu.temperaturumrechner(datensatz.out_temp)
|
|
|
|
|
rohdaten["inTemp"] = mwu.temperaturumrechner(datensatz.in_temp)
|
|
|
|
@ -120,12 +122,13 @@ def freigabe_setzen(zusatzwetterdaten_liste):
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
def main():
|
|
|
|
|
laufende_prozesse = check_process()
|
|
|
|
|
if laufende_prozesse > 1:
|
|
|
|
|
print("EXIT aufgrund laufender Prozesse")
|
|
|
|
|
sys.exit()
|
|
|
|
|
# Verzögerung aufgrund vom Cronjob, >>alle 5Minute, damit es nicht mit der Erstellung von Weewx kolidiert
|
|
|
|
|
time.sleep(CONFIG["weewx"]["sleeptime"])
|
|
|
|
|
if sys.platform == "linux":
|
|
|
|
|
laufende_prozesse = check_process()
|
|
|
|
|
if laufende_prozesse > 1:
|
|
|
|
|
print("EXIT aufgrund laufender Prozesse")
|
|
|
|
|
sys.exit()
|
|
|
|
|
# Verzögerung aufgrund vom Cronjob, >>alle 5Minute, damit es nicht mit der Erstellung von Weewx kolidiert
|
|
|
|
|
time.sleep(CONFIG["weewx"]["sleeptime"])
|
|
|
|
|
|
|
|
|
|
db_adapter = CONFIG["weewx"]["db"]
|
|
|
|
|
db = db_weewx.init_db(CONFIG["weewx"][db_adapter]["database"], db_adapter, CONFIG["weewx"].get(db_adapter))
|
|
|
|
|