more png

deployment/deploy-yml.tmpl

@@ -1,27 +1,27 @@
 apiVersion: apps/v1
 kind: Deployment
 metadata:
-  name: pv-stats
+  name: numbers
   labels:
-    app: pv-stats
+    app: numbers
   annotations:
-    secret.reloader.stakater.com/reload: pv-stats
+    secret.reloader.stakater.com/reload: numbers
 spec:
   replicas: 1
   selector:
     matchLabels:
-      app: pv-stats
+      app: numbers
   template:
     metadata:
       labels:
-        app: pv-stats
+        app: numbers
     spec:
       containers:
-        - name: pv-stats
+        - name: numbers
           image: %IMAGE%
           envFrom:
             - secretRef: 
-                name: pv-stats
+                name: numbers
           ports:
             - containerPort: 8080
               protocol: TCP
@@ -29,11 +29,11 @@ spec:
 apiVersion: v1
 kind: Service
 metadata:
-  name: pv-stats
+  name: numbers
 spec:
   type: ClusterIP
   selector:
-    app: pv-stats
+    app: numbers
   ports:
     - name: http
       targetPort: 8080
@@ -42,7 +42,7 @@ spec:
 apiVersion: networking.k8s.io/v1
 kind: Ingress
 metadata:
-  name: pv-stats
+  name: numbers
   annotations:
     cert-manager.io/cluster-issuer: letsencrypt-production-http
 spec:
@@ -58,7 +58,7 @@ spec:
             pathType: Prefix
             backend:
               service:
-                name: pv-stats
+                name: numbers
                 port:
                   number: 80
 

deployment/deploy.sh

@@ -25,7 +25,7 @@ kubectl create namespace $NAMESPACE \
 # rm $SECRETS_FILE
 eval "`cat secrets.asc | /usr/local/bin/decrypt-secrets.sh`"
 
-kubectl create secret generic pv-stats \
+kubectl create secret generic numbers \
   --dry-run=client \
   -o yaml \
   --save-config \

src/ntp_routes.py

@@ -3,6 +3,7 @@ from loguru import logger
 import json
 import plotly.express as px
 import plotly.graph_objects as po
+import matplotlib.pyplot as plt
 import pandas as pd
 import psycopg
 import sqlalchemy
@@ -118,3 +119,45 @@ def ntpserver():
             dbh.close()
 
 
+def get_dataframe():
+
+@app.route('/plot.png')
+def plot_png():
+    dbh = psycopg.connect()
+    engine = sqlalchemy.create_engine("postgresql+psycopg://", creator=lambda: dbh)
+    query = """
+      select   time_bucket('5 minutes', time) as bucket,
+        device,
+        avg(cast(values->'rootdisp'->>'value'  as float)) as rootdisp,
+        max(cast(values->'stratum'->>'value'  as int)) as stratum
+      from measurements
+      where time >= date_trunc('day', now()) AND time < date_trunc('day', now()) + '1 day'::interval and
+        application = 'TSM' and attributes->>'Label' = 'david'
+      group by bucket, device
+      order by bucket, device
+    """
+    df = pd.read_sql(query, con=engine)
+
+    fig, ax1 = plt.subplots()
+
+    ax1.plot(df['bucket'], df['rootdisp'], 'r-', label='Root Dispersion')
+    ax1.set_xlabel('Time')
+    ax1.set_ylabel('Root Dispersion (ms)', color='r')
+    ax1.tick_params(axis='y', labelcolor='r')
+
+    ax2 = ax1.twinx()
+    ax2.plot(df['bucket'], df['stratum'], 'b-', label='Stratum')
+    ax2.set_ylabel('Stratum', color='b')
+    ax2.tick_params(axis='y', labelcolor='b')
+    ax2.set_yticks(range(int(df['stratum'].min()), int(df['stratum'].max()) + 1))
+
+    fig.suptitle('NTP Server Numbers')
+    fig.tight_layout()
+    
+    img_io = io.BytesIO()
+    plt.savefig(img_io, format='png')
+    img_io.seek(0)
+    plt.close(fig)
+    
+    return Response(img_io, mimetype='image/png')
+