#!/usr/bin/env python

# -*- coding: utf-8 -*-

"""

vSAN Management SDK sample retrieving

vSAN performance metrics https://dp-downloads.broadcom.com/api-content/apis/API_VMA_001/8.0U3/html/vim.cluster.VsanPerformanceManager.html#queryVsanPerf

Usage:

python vsan-perf-sample.py -s 192.168.30.3 \

-u 'administrator@vsphere.local' -p 'VMware1!' \

-c Supermicro-Cluster -e "virtual-machine:*"

"""

__author__ = 'VMware, Inc'

from pyVmomi import vim

from pyVim.connect import SmartConnect, Disconnect

import atexit

import argparse

import datetime

import getpass

import json

import random

import sys

import ssl

# import the VSAN API python bindings

import vsanmgmtObjects

import vsanapiutils

def GetArgs():

"""

Supports the command-line arguments listed below.

"""

parser = argparse.ArgumentParser(

description='Process args for VSAN SDK sample application')

parser.add_argument('-s', '--host', required=True, action='store',

help='Remote host to connect to')

parser.add_argument('-o', '--port', type=int, default=443, action='store',

help='Port to connect on')

parser.add_argument('-u', '--user', required=True, action='store',

help='User name to use when connecting to host')

parser.add_argument('-p', '--password', required=False, action='store',

help='Password to use when connecting to host')

parser.add_argument('-c', '--cluster', dest='clusterName', required=True,

action='store')

parser.add_argument('-e', '--entityRef', dest='entityRef', required=True,

action='store')

args = parser.parse_args()

return args

def get_obj(content, vim_type, name=None):

obj = None

container = content.viewManager.CreateContainerView(

content.rootFolder, vim_type, True)

if name:

for c in container.view:

if c.name == name:

obj = c

return obj

else:

return container.view

# Start program

def main():

args = GetArgs()

if args.password:

password = args.password

else:

password = getpass.getpass(prompt='Enter password for host %s and '

'user %s: ' % (args.host, args.user))

# For python 2.7.9 and later, the defaul SSL conext has more strict

# connection handshaking rule. We may need turn of the hostname checking

# and client side cert verification

context = None

if sys.version_info[:3] > (2, 7, 8):

context = ssl.create_default_context()

context.check_hostname = False

context.verify_mode = ssl.CERT_NONE

si = SmartConnect(host=args.host,

user=args.user,

pwd=password,

port=int(args.port),

sslContext=context)

atexit.register(Disconnect, si)

# for detecting whether the host is VC or ESXi

aboutInfo = si.content.about

if aboutInfo.apiType == 'VirtualCenter':

majorApiVersion = aboutInfo.apiVersion.split('.')[0]

if int(majorApiVersion) < 6:

print('The Virtual Center with version %s (lower than 6.0) \

is not supported.' % aboutInfo.apiVersion)

return -1

vcMos = vsanapiutils.GetVsanVcMos(si._stub, context=context)

vpm = vcMos['vsan-performance-manager']

cluster = get_obj(si.content,

[vim.ClusterComputeResource], args.clusterName)

if cluster is None:

print("Cluster %s is not found for %s" % (args.clusterName,

args.host))

return -1

endTime = datetime.datetime.utcnow()

startTime = endTime - datetime.timedelta(hours=1)

querySpec = vim.cluster.VsanPerfQuerySpec(

startTime = startTime,

endTime = endTime,

entityRefId = args.entityRef

)

results = vpm.VsanPerfQueryPerf(querySpecs=[querySpec],cluster=cluster)

print(results)

# Start program

if __name__ == "__main__":

main()