Experimenting

Author: rcastley

workshop/demo-client/app.py

@@ -2,6 +2,9 @@
 import streamlit as st  # type: ignore
 from datetime import datetime
 import pandas as pd
+import json
+from os import path
+import yaml
 
 year = datetime.now().year
 
@@ -28,7 +31,8 @@
 
 with st.form("demo_form") as form:
     host = st.text_input("Host", placeholder="hostname")
-    query = st.selectbox("Query", ("pods", "health"))
+    port = st.text_input("Port", placeholder="8083", value="8083")
+    query = st.selectbox("Query", ("pods", "health", "Deploy Online Boutique"))
     submit_button = st.form_submit_button(label="Submit")
 
     if submit_button:
@@ -40,9 +44,14 @@
         "TBD."
     )
 else:
-    response = requests.get(f"{host}:5001/{query}")
+    
     if query == "pods":
+        response = requests.get(f"http://{host}:{port}/{query}")
         df = pd.DataFrame.from_dict(response.json())
         st.dataframe(df)
     elif query == "health":
+        response = requests.get(f"http://{host}:{port}/{query}")
         st.write(response.text)
+    elif query == "Deploy Online Boutique":
+        response = requests.get(f"http://{host}:{port}/apply_deployment")
+        st.write(response.json())

workshop/demo-client/requirements.txt

@@ -1,2 +1,3 @@
 streamlit
 watchdog
+pyyaml

workshop/demo-server/app.py

@@ -1,4 +1,4 @@
-from kubernetes import client, config
+from kubernetes import client, config, utils
 from flask import Flask, json, jsonify, request
 from os import path
 import yaml
@@ -10,7 +10,7 @@
 
 core_v1 = client.CoreV1Api()
 apps_v1 = client.AppsV1Api()
-
+api = client.ApiClient()
 
 @app.route('/pods', methods=['GET'])
 def get_pods():
@@ -30,23 +30,21 @@ def health():
     return "OK"
 
 
-@app.route('/apply_deployment', methods=['GET'])
+@app.route('/apply_deployment', methods=['POST'])
 def deployment():
-    filename = request.args.get('type', default = 'deployment.yaml', type = str)
-    namespace = request.args.get('namespace', default = 'default', type = str)
-    with open(path.join(path.dirname(__file__), filename)) as f:
-        deployment = yaml.safe_load(f)
-        resp = apps_v1.create_namespaced_deployment(
-            body=deployment, namespace=namespace, _preload_content=False)
-        return resp.json() 
-
+        deployment = "deployment.yaml"
+        #resp = apps_v1.create_namespaced_deployment(
+        #    body=deployment, namespace=namespace, _preload_content=False)
+        resp = utils.create_from_yaml(api, deployment, namespace="default")
+        print(resp)
+        return "200"
 
 @app.route('/delete_deployment', methods=['GET'])
 def delete_deployment():
     filename = request.args.get('type', default = 'deployment.yaml', type = str)
     namespace = request.args.get('namespace', default = 'default', type = str)
     resp = apps_v1.delete_namespaced_deployment(name="nginx-deployment", namespace=namespace, _preload_content=False)
-    return resp.json()
+    return resp
 
 if __name__ == '__main__':
-   app.run(host="0.0.0.0", port=5001, debug=True)
+   app.run(host="0.0.0.0", port=8083, debug=True)