Compare commits
1 Commits
db79d903aa
..
master
| Author | SHA1 | Date | |
|---|---|---|---|
| 2ebdd23bf1 |
+2
-1
@@ -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"])
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user