coffeeordeath/influx_stats
1
0
Fork 0
Code Issues 1 Pull Requests Projects Releases Wiki Activity

Extend Data search to 90 days

Browse Source 
Add Winter value to the data selected and passed to index
This commit is contained in:
ahosking 2022-11-03 00:05:56 -04:00
parent e8b41b402e
commit 526e6d3439
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
influx_frontend.py
View File

@ -27,7 +27,7 @@ def success():
def main_page(): def main_page():
query_api = client.query_api() query_api = client.query_api()
query = 'from(bucket: "gas")\ query = 'from(bucket: "gas")\
|> range(start: -30d)\ |> range(start: -90d)\
|> filter(fn: (r) => r["_measurement"] == "2016_odyssey")\ |> filter(fn: (r) => r["_measurement"] == "2016_odyssey")\
|> filter(fn: (r) => r["_field"] == "odometer")\ |> filter(fn: (r) => r["_field"] == "odometer")\
|> sort(columns: ["_value"], desc: false)\ |> sort(columns: ["_value"], desc: false)\
@ -50,6 +50,10 @@ def main_page():
temp['fuelcost'] = record['fuelcost'] temp['fuelcost'] = record['fuelcost']
except KeyError: except KeyError:
pass pass
try:
temp['winter'] = record['winter']
except KeyError:
pass
results.append(temp) results.append(temp)
# .append((record.get_time(), record.get_field(), record.get_value())) # .append((record.get_time(), record.get_field(), record.get_value()))
newlist = sorted(results, key=itemgetter('time'), reverse=True) newlist = sorted(results, key=itemgetter('time'), reverse=True)