query telemetry data works

Sunbrye Ly · Sunbrye Ly · commit 2d0474d37a4b · 2022-05-05T14:06:27.000-07:00
diff --git a/api/devices.py b/api/devices.py
@@ -178,6 +178,30 @@ def write_measurements(device_id):
     return None
 
 
+def get_measurements(device_id):
+    influxdb_client = InfluxDBClient(url=config.get('APP', 'INFLUX_URL'),
+                                     token=config.get('APP', 'INFLUX_TOKEN'),
+                                     org=config.get('APP', 'INFLUX_ORG'))
+
+    # Queries must be formatted with single and double quotes correctly
+    query_api = QueryApi(influxdb_client)
+    device_id = str(device_id)
+    device_filter = f'r.device == "{device_id}"'
+    flux_query = f'from(bucket: "{config.get("APP", "INFLUX_BUCKET")}") ' \
+                 f'|> range(start: 0) ' \
+                 f'|> filter(fn: (r) => r._measurement == "environment" and {device_filter}) ' \
+                 f'|> last()'
+
+    response = query_api.query(flux_query)
+
+    # iterate through the result(s)
+    results = []
+    for table in response:
+        results.append(table.records[0].values)
+
+    return results
+
+
 # Creates an authorization for a deviceId and writes it to a bucket
 def create_device(device_id) -> Authorization:
     device = get_device(device_id)
diff --git a/app.py b/app.py
@@ -85,3 +85,13 @@ def write():
         device_id = request.form.get('device_id_input', None)
         device_id = devices.write_measurements(device_id)
         return render_template('write.html', device_id=device_id)
+
+
+@app.route('/data', methods=['GET', 'POST'])
+def data():
+    if request.method == 'GET':
+        return render_template('data.html', data=None)
+    else:
+        device_id = request.form.get('device_id_input', None)
+        results = devices.get_measurements(device_id)
+        return render_template('data.html', data=results)
diff --git a/templates/base.html b/templates/base.html
@@ -33,6 +33,9 @@
                 <li>
                     <a class="nav-link" href="{{url_for('write')}}">Write</a>
                 </li>
+                <li>
+                    <a class="nav-link" href="{{url_for('data')}}">Data</a>
+                </li>
                 <li>
                     <a class="nav-link" href="{{url_for('help_page')}}">Help</a>
                 </li>
diff --git a/templates/data.html b/templates/data.html
@@ -0,0 +1,50 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <title>Data</title>
+</head>
+<body>
+{% extends 'base.html' %}
+{% block content %}
+
+
+
+{% if data is none %}
+    <div>
+    <form method="post" action="/data">
+        <div class="form-group">
+            <label for="deviceIdInput">IoT Device Name</label>
+            <input type="text" class="form-control" id="deviceIdInput" name="device_id_input">
+        </div>
+        <div class="form-group">
+            <input type="submit" class="btn btn-primary" name="set" value="Query Data">
+        </div>
+    </form>
+</div>
+{% else %}
+    <table id="data" class="table table-striped">
+        <thead>
+          <tr>
+            <th>Time</th>
+              <th>Device</th>
+            <th>Field</th>
+            <th>Value</th>
+          </tr>
+        </thead>
+        <tbody>
+          {% for result in data %}
+            <tr>
+              <td>{{ result._time }}</td>
+                <td>{{ result.device }}</td>
+              <td>{{ result._field }}</td>
+              <td>{{ result._value }}</td>
+            </tr>
+          {% endfor %}
+        </tbody>
+  </table>
+{% endif %}
+
+{% endblock %}
+</body>
+</html>
