Compare commits

..

2 Commits

Author SHA1 Message Date
ahosking
d2bda44411 Make data unique and in order 2022-08-12 02:26:11 -04:00
ahosking
7d6bd7cc70 Put data into a table for viewing 2022-08-12 02:25:59 -04:00
2 changed files with 70 additions and 41 deletions

View File

@ -15,12 +15,14 @@ client = influxdb_client.InfluxDBClient(
url=config['DB_URL'], url=config['DB_URL'],
token=config['DB_TOKEN'], token=config['DB_TOKEN'],
org=config['DB_ORG'] org=config['DB_ORG']
) )
@app.route('/success') @app.route('/success')
def success(): def success():
return "Form success!" return "Form success!"
@app.route('/', methods=['GET', 'POST']) @app.route('/', methods=['GET', 'POST'])
def main_page(): def main_page():
query_api = client.query_api() query_api = client.query_api()
@ -29,13 +31,10 @@ def main_page():
|> 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)\
|> yield(name: "last")\
|> limit(n:10)' |> limit(n:10)'
result = query_api.query(org=config['DB_ORG'], query=query) result = query_api.query(org=config['DB_ORG'], query=query)
print()
print()
print(result)
print()
results = [] results = []
for table in result: for table in result:
for record in table.records: for record in table.records:
@ -46,15 +45,25 @@ def main_page():
temp['oilhealth'] = record['oilhealth'] temp['oilhealth'] = record['oilhealth']
except KeyError: except KeyError:
pass pass
try:
temp['fuel'] = record['fuel']
temp['fuelcost'] = record['fuelcost']
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()))
print(results)
print(len(results))
print()
newlist = sorted(results, key=itemgetter('time'), reverse=True) newlist = sorted(results, key=itemgetter('time'), reverse=True)
print(newlist) oldlist = newlist # temporary to strip the non-unique data
data= results newlist = []
return render_template('index.html', data=newlist) for value in oldlist:
if value in newlist:
continue
else:
newlist.append(value)
# print(newlist)
return render_template('index.html', data=newlist[:10])
@app.route('/add_time', methods=['POST', 'GET']) @app.route('/add_time', methods=['POST', 'GET'])
def add_time(): def add_time():
@ -69,7 +78,7 @@ def add_time():
if time == '': if time == '':
time = now time = now
odometer = request.form['odometer'] odometer = request.form['odometer']
oilhealth= request.form['oilhealth'] oilhealth = request.form['oilhealth']
if oilhealth != '': if oilhealth != '':
oilhealth = float(oilhealth) oilhealth = float(oilhealth)
fuel = request.form['fuel'] fuel = request.form['fuel']
@ -107,13 +116,12 @@ def add_time():
point = influxdb_client.Point("2016_odyssey").time(timestamp).tag("oilhealth", oilhealth)\ point = influxdb_client.Point("2016_odyssey").time(timestamp).tag("oilhealth", oilhealth)\
.tag("fuel", fuel).tag("fuelcost", fuelcost).tag("winter", winter).field("odometer", float(odometer)) .tag("fuel", fuel).tag("fuelcost", fuelcost).tag("winter", winter).field("odometer", float(odometer))
write_api.write(bucket="gas", org=config['DB_ORG'], record=point) write_api.write(bucket="gas", org=config['DB_ORG'], record=point)
print ("Submitting data to DB: {0}".format(json_body)) print("Submitting data to DB: {0}".format(json_body))
#client.write_points(json_body) # client.write_points(json_body)
return redirect(url_for('main_page')) return redirect(url_for('main_page'))
@app.route('/repeat_last_odometer/<odometer>') @app.route('/repeat_last_odometer/<odometer>')
def repeat_last_odometer(odometer): def repeat_last_odometer(odometer):
'''Retrieve the passed in odometer value and submit as a new entry''' '''Retrieve the passed in odometer value and submit as a new entry'''
@ -123,21 +131,26 @@ def repeat_last_odometer(odometer):
print("Putting %s to database for %s" % (odometer, timestamp)) print("Putting %s to database for %s" % (odometer, timestamp))
write_api = client.write_api(write_options=SYNCHRONOUS) write_api = client.write_api(write_options=SYNCHRONOUS)
point = influxdb_client.Point("2016_odyssey").time(timestamp).field("odometer", float(odometer)) point = influxdb_client.Point("2016_odyssey").time(
timestamp).field("odometer", float(odometer))
write_api.write(bucket="gas", org=config['DB_ORG'], record=point) write_api.write(bucket="gas", org=config['DB_ORG'], record=point)
return redirect(url_for('main_page')) return redirect(url_for('main_page'))
@app.route('/admin') @app.route('/admin')
def admin_index(): def admin_index():
return 'admin' return 'admin'
@app.route('/login') @app.route('/login')
def login(): def login():
pass pass
@app.route('/logout') @app.route('/logout')
def logout(): def logout():
pass pass
if __name__ == '__main__': if __name__ == '__main__':
app.run(debug=True, host='0.0.0.0', port='9001') app.run(debug=True, host='0.0.0.0', port='9001')

View File

@ -59,11 +59,27 @@
</form> </form>
<br> <br>
Last Mileage Last Mileage
<ul> <table class="table table-striped">
{% for point in data %} <thead>
<li> <tr>
{{ point['time'] }} = {{ point['odometer'] }}, {{point['oilhealth']}} <th scope="col">Odometer</th>
</li> <th scope="col">Time</th>
{% endfor %} <th scope="col">Oil</th>
<th scope="col">Litres</th>
<th scope="col">$/Litre</th>
</tr>
</thead>
<tbody>
{% for point in data %}
<tr>
<th scope="row">{{ point['odometer'] }}</th>
<td>{{ point['time'] }}</td>
<td>{{ point['oilhealth'] }}</td>
<td>{{ point['fuel'] }}</td>
<td>{{ point['fuelcost'] }}</td>
</tr>
{% endfor %}
</tbody>
</table>
{% endblock %} {% endblock %}
</ul>