Workshop monitoring initial import

Author: rcastley

.gitignore

@@ -51,4 +51,6 @@ workshop/aws/ec2/terraform.tfvars.us1.1.pre copy.tfvars
 workshop/aws/ec2/*.conf
 workshop/aws/ec2/*.key
 workshop/aws/ec2/*.csv
-.idea/
+.idea/
+workshop/demo-client/venv/*
+workshop/demo-server/venv/*

workshop/demo-client/app.py

@@ -0,0 +1,48 @@
+import requests
+import streamlit as st  # type: ignore
+from datetime import datetime
+import pandas as pd
+
+year = datetime.now().year
+
+VERSION = "1.9.0"
+CAPTION = f"© {year} Splunk Inc. All rights reserved. **Version {VERSION}**"
+
+st.set_page_config(
+    page_title=f"Demo Client - Splunk",
+    page_icon=None,
+    layout="wide",
+    initial_sidebar_state="auto",
+)
+
+#st.image("images/splunk-logo-black-small.png")
+st.caption(CAPTION)
+
+if "auth_success" not in st.session_state:
+    st.session_state.auth_success = False
+
+st.session_state.valid_org = False
+
+if not "valid_inputs_received" in st.session_state:
+    st.session_state.valid_inputs_received = False
+
+with st.form("demo_form") as form:
+    host = st.text_input("Host", placeholder="hostname")
+    query = st.selectbox("Query", ("pods", "health"))
+    submit_button = st.form_submit_button(label="Submit")
+
+    if submit_button:
+        st.cache_data.clear()
+        st.session_state.valid_inputs_received = True
+
+if st.session_state.valid_inputs_received == False:
+    st.warning(
+        "TBD."
+    )
+else:
+    response = requests.get(f"{host}:5001/{query}")
+    if query == "pods":
+        df = pd.DataFrame.from_dict(response.json())
+        st.dataframe(df)
+    elif query == "health":
+        st.write(response.text)

workshop/demo-client/requirements.txt

@@ -0,0 +1,2 @@
+streamlit
+watchdog

workshop/demo-server/app.py

@@ -0,0 +1,52 @@
+from kubernetes import client, config
+from flask import Flask, json, jsonify, request
+from os import path
+import yaml
+import pandas as pd
+
+app = Flask(__name__)
+
+config.load_kube_config()
+
+core_v1 = client.CoreV1Api()
+apps_v1 = client.AppsV1Api()
+
+
+@app.route('/pods', methods=['GET'])
+def get_pods():
+    result = core_v1.list_pod_for_all_namespaces(_preload_content=False)
+    pods = json.loads(result.data)
+    df = pd.DataFrame(columns=["Namespace", "Name", "Status", "Pod IP"])
+
+    for r in pods['items']:
+        row = (r["metadata"]["namespace"], r["metadata"]["name"], r["status"]["phase"], r["status"]["podIP"])
+        df.loc[len(df)] = row
+
+    return df.to_dict(orient='records')
+
+
+@app.route('/health', methods=['GET'])
+def health():
+    return "OK"
+
+
+@app.route('/apply_deployment', methods=['GET'])
+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() 
+
+
+@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()
+
+if __name__ == '__main__':
+   app.run(host="0.0.0.0", port=5001, debug=True)

workshop/demo-server/requirements.txt

@@ -0,0 +1,3 @@
+flask
+kubernetes
+pandas