Latest demo lab version

Author: numbersixnz

.gitignore

@@ -1,3 +1,4 @@
+venv/
 nutanix/
 
 *.pyc

config.py

@@ -1,4 +1,5 @@
 import os
 
+
 class Config(object):
-    SECRET_KEY = os.environ.get('SECRET_KEY') or 'some strong secret string'
+    SECRET_KEY = os.environ.get("SECRET_KEY") or "some strong secret string"

lab/__init__.py

@@ -3,45 +3,45 @@
 from flask import Flask
 from flask_assets import Environment, Bundle
 
-from .util import apiclient
 from config import Config
 
+
 def create_app(test_config=None):
     # create and configure the app
     app = Flask(__name__, instance_relative_config=True)
 
     assets = Environment(app)
 
     home_css = Bundle(
-        'css/lib/reset.css',
-        'css/lib/built-in.css',
-        'css/lib/jquery-ui-custom.css',
-        'css/lib/jq.gridster.css',
-        'css/lib/jq.jqplot.css',
-        'css/ntnx.css'
+        "css/lib/reset.css",
+        "css/lib/built-in.css",
+        "css/lib/jquery-ui-custom.css",
+        "css/lib/jq.gridster.css",
+        "css/lib/jq.jqplot.css",
+        "css/ntnx.css",
     )
     home_js = Bundle(
-            'js/lib/jquery-2.1.3.min.js',
-            'js/lib/classie.min.js',
-            'js/lib/ntnx-bootstrap.min.js',
-            'js/lib/modernizr.custom.min.js',
-            'js/lib/jquery.jqplot.min.js',
-            'js/lib/jqplot.logAxisRenderer.js',
-            'js/lib/jqplot.categoryAxisRenderer.js',
-            'js/lib/jqplot.canvasAxisLabelRenderer.js',
-            'js/lib/jqplot.canvasTextRenderer.js',
-            'js/lib/jquery.gridster.min.js',
-            'js/ntnx.js'
+        "js/lib/jquery-2.1.3.min.js",
+        "js/lib/classie.min.js",
+        "js/lib/ntnx-bootstrap.min.js",
+        "js/lib/modernizr.custom.min.js",
+        "js/lib/jquery.jqplot.min.js",
+        "js/lib/jqplot.logAxisRenderer.js",
+        "js/lib/jqplot.categoryAxisRenderer.js",
+        "js/lib/jqplot.canvasAxisLabelRenderer.js",
+        "js/lib/jqplot.canvasTextRenderer.js",
+        "js/lib/jquery.gridster.min.js",
+        "js/ntnx.js",
     )
 
-    assets.register('home_css',home_css)
-    assets.register('home_js',home_js)
+    assets.register("home_css", home_css)
+    assets.register("home_js", home_js)
 
     app.config.from_object(Config)
 
     if test_config is None:
         # load the instance config, if it exists, when not testing
-        app.config.from_pyfile('config.py', silent=True)
+        app.config.from_pyfile("config.py", silent=True)
     else:
         # load the test config if passed in
         app.config.from_mapping(test_config)
@@ -53,9 +53,11 @@ def create_app(test_config=None):
         pass
 
     from . import index
+
     app.register_blueprint(index.bp)
 
     from . import ajax
+
     app.register_blueprint(ajax.bp)
 
-    return app
+    return app

lab/ajax.py

@@ -1,20 +1,20 @@
 import os
 import json
 import base64
-import sys
 from datetime import datetime
 from datetime import timedelta
 import time
 import urllib3
 
 from flask import (
-    Blueprint, flash, g, redirect, render_template, request, session, url_for, jsonify
+    Blueprint,
+    request,
+    jsonify,
 )
-from werkzeug.security import check_password_hash, generate_password_hash
 
 from .util import apiclient
 
-bp = Blueprint('ajax', __name__, url_prefix='/ajax')
+bp = Blueprint("ajax", __name__, url_prefix="/ajax")
 
 """
 disable insecure connection warnings
@@ -23,68 +23,68 @@
 """
 urllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)
 
+
 """
 get the form POST data provided by the user
 """
+
+
 def get_form():
     global form_data
     global cvmAddress
     global username
     global password
+    global entity
     form_data = request.form
-    cvmAddress = form_data['_cvmAddress']
-    username = form_data['_username']
-    password = form_data['_password']
+    cvmAddress = form_data["_cvmAddress"]
+    username = form_data["_username"]
+    password = form_data["_password"]
+    entity = form_data["_entity"]
+
 
 """
 load the default layout at app startup
 """
-@bp.route('/load-layout',methods=['POST'])
+
+
+@bp.route("/load-layout", methods=["POST"])
 def load_layout():
     site_root = os.path.realpath(os.path.dirname(__file__))
-    layout_path = 'static/layouts'
-    dashboard_file = 'dashboard.json'
-    with open( f'{site_root}/{layout_path}/{dashboard_file}','r') as f:
+    layout_path = "static/layouts"
+    dashboard_file = "dashboard.json"
+    with open(f"{site_root}/{layout_path}/{dashboard_file}", "r") as f:
         raw_json = json.loads(f.read())
-        return base64.b64decode(raw_json['layout']).decode('utf-8')
+        return base64.b64decode(raw_json["layout"]).decode("utf-8")
 
-"""
-get some high level cluster info
-"""
-@bp.route('/cluster-info',methods=['POST'])
-def cluster_info():
-    # get the request's POST data
-    get_form()
-    client = apiclient.ApiClient('post', cvmAddress,'clusters/list','{"kind":"cluster"}',username,password)
-    results = client.get_info()
-    return jsonify(results)
 
 """
-get the vm count
+connect to prism central and collect details about a specific type of entity
 """
-@bp.route('/vm-info',methods=['GET','POST'])
-def vm_info():
-    # get the request's POST data
-    get_form()
-    client = apiclient.ApiClient('get', cvmAddress,'vms','',username,password,'v2.0')
-    results = client.get_info()
-    return jsonify(results)
 
-"""
-get the cluster's physical info e.g. # of hosts, host serial numbers
-"""
-@bp.route('/physical-info',methods=['POST'])
-def physical_info():
+
+@bp.route("/pc-list-entities", methods=["POST"])
+def pc_list_entities():
     # get the request's POST data
     get_form()
-    client = apiclient.ApiClient('get', cvmAddress,'hosts','',username,password,'v2.0')
+    client = apiclient.ApiClient(
+        method="post",
+        cluster_ip=cvmAddress,
+        request=f"{entity}s/list",
+        entity=entity,
+        body=f'{{"kind": "{entity}"}}',
+        username=username,
+        password=password,
+    )
     results = client.get_info()
     return jsonify(results)
 
+
 """
-get the cluster's storage performance
+get storage performance stats for the first storage container in a cluster
 """
-@bp.route('/storage-performance',methods=['POST'])
+
+
+@bp.route("/storage-performance", methods=["POST"])
 def storage_performance():
     # get the request's POST data
     get_form()
@@ -97,17 +97,49 @@ def storage_performance():
     endTime = round(time.mktime(endTime.timetuple()) * 1000 * 1000)
     startTime = round(time.mktime(startTime.timetuple()) * 1000 * 1000)
 
-    client = apiclient.ApiClient('get',cvmAddress,f'cluster/stats/?metrics=controller_avg_io_latency_usecs&startTimeInUsecs={startTime}&endTimeInUsecs={endTime}&intervalInSecs=30','',username,password,'v1','PrismGateway/services/rest')
-    results = client.get_info()
-    return jsonify(results)
+    # first, get the external IP address of the first cluster registered to this Prism Central instance
+    entity = "cluster"
+    client = apiclient.ApiClient(
+        method="post",
+        cluster_ip=cvmAddress,
+        request=f"{entity}s/list",
+        entity=entity,
+        body=f'{{"kind": "{entity}"}}',
+        username=username,
+        password=password,
+    )
+    cluster_ip = client.get_info()["entities"][0]["status"]["resources"]["network"][
+        "external_ip"
+    ]
 
-"""
-get the container info e.g. # of containers
-"""
-@bp.route('/container-info',methods=['POST'])
-def containers():
-    # get the request's POST data
-    get_form()
-    client = apiclient.ApiClient('get',cvmAddress,f'storage_containers','',username,password,'v2.0')
-    results = client.get_info()
-    return jsonify(results)
+    # next, get the UUID of the first storage container in the cluster found in our previous request
+    entity = "storage_containers"
+    client = apiclient.ApiClient(
+        method="get",
+        cluster_ip=cluster_ip,
+        request=entity,
+        entity="",
+        body="",
+        username=username,
+        password=password,
+        version="v2.0",
+    )
+    storage_container_uuid = client.get_info()["entities"][0]["id"]
+
+    # finally, get the performance stats for the storage container found in our previous request
+    entity = "storage_containers"
+    full_request = f"storage_containers/{storage_container_uuid}/stats/?metrics=controller_avg_io_latency_usecs&start_time_in_usecs={startTime}&end_time_in_usecs={endTime}"
+    client = apiclient.ApiClient(
+        method="get",
+        cluster_ip=cluster_ip,
+        request=full_request,
+        entity="",
+        body="",
+        username=username,
+        password=password,
+        version="v2.0",
+    )
+    stats = client.get_info()
+
+    # return the JSON array containing storage container performance info for the last 4 hours
+    return jsonify(stats)

lab/forms.py

@@ -1,12 +1,14 @@
 from flask_wtf import FlaskForm
-from wtforms import StringField, PasswordField, BooleanField, SubmitField
+from wtforms import StringField, PasswordField, SubmitField
 from wtforms.validators import DataRequired
 
 """
 The clusterForm class is used to identify the properties used when submitted cluster details
 """
+
+
 class clusterForm(FlaskForm):
-    cvmAddress = StringField('cvmAddress', validators=[DataRequired()])
-    username = StringField('username', validators=[DataRequired()])
-    password = PasswordField('password', validators=[DataRequired()])
-    submit = SubmitField('Go!', id="goButton")
+    cvmAddress = StringField("cvmAddress", validators=[DataRequired()])
+    username = StringField("username", validators=[DataRequired()])
+    password = PasswordField("password", validators=[DataRequired()])
+    submit = SubmitField("Go!", id="goButton")

lab/index.py

@@ -1,14 +1,15 @@
 from lab.forms import clusterForm
 
 from flask import (
-    Blueprint, flash, g, redirect, render_template, request, session, url_for
+    Blueprint,
+    render_template,
 )
-from werkzeug.security import check_password_hash, generate_password_hash
 
-bp = Blueprint('index', __name__, url_prefix='/')
+bp = Blueprint("index", __name__, url_prefix="/")
 
-@bp.route('/')
+
+@bp.route("/")
 def index():
     # make sure we are using the form that's been generated in forms.py
     form = clusterForm()
-    return render_template('index.html', form=form)
+    return render_template("index.html", form=form)