hofei
/
weewx_to_grafanaserver
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 1 Wiki Activity

set tz - rerduce read db datas weewx

Browse Source
master V2.0
Hofei90 2 years ago
parent db79d903aa
commit 2ebdd23bf1
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File

3
grafana_export.py
Unescape Escape View File

@ -36,7 +36,7 @@ def rohdaten_laden(timestamp, stationsname):
aufruf_wiederholen = False aufruf_wiederholen = False
LOGGER.debug("Lese WeeWx Datenbank") LOGGER.debug("Lese WeeWx Datenbank")
query = db_weewx.Archive.select().where(db_weewx.Archive.date_time > timestamp)\ query = db_weewx.Archive.select().where(db_weewx.Archive.date_time > timestamp)\
.order_by(db_weewx.Archive.date_time.asc()).limit(int(SENDELIMIT * 1.5)) .order_by(db_weewx.Archive.date_time.asc()).limit(int(SENDELIMIT + 2))
gesamtzahl = (len(query)) gesamtzahl = (len(query))
if gesamtzahl > SENDELIMIT: if gesamtzahl > SENDELIMIT:
gesamtzahl = SENDELIMIT gesamtzahl = SENDELIMIT
@ -144,6 +144,7 @@ def main():
letzter_ts_server = db_postgrest.hole_letzten_ts(url, letzter_ts_server = db_postgrest.hole_letzten_ts(url,
CONFIG["zieldb"]["postgrest"]["tablename_basiswetterdaten"], CONFIG["zieldb"]["postgrest"]["tablename_basiswetterdaten"],
headers, CONFIG["grafana"]["grafana_name"]) headers, CONFIG["grafana"]["grafana_name"])
letzter_ts_server = letzter_ts_server.replace(tzinfo=datetime.timezone.utc)
basiswetterdaten, zusatzwetterdaten, aufruf_wiederholen = rohdaten_laden(letzter_ts_server.timestamp(), basiswetterdaten, zusatzwetterdaten, aufruf_wiederholen = rohdaten_laden(letzter_ts_server.timestamp(),
CONFIG["grafana"]["grafana_name"]) CONFIG["grafana"]["grafana_name"])

Write Preview
Loading…
Cancel
Save