mirror of
https://github.com/vmware/vsphere-automation-sdk-python.git
synced 2024-11-25 02:39:59 -05:00
123 lines
4.2 KiB
Python
123 lines
4.2 KiB
Python
#!/usr/bin/env python
|
|
"""
|
|
* *******************************************************
|
|
* Copyright (c) VMware, Inc. 2020. All Rights Reserved.
|
|
* SPDX-License-Identifier: MIT
|
|
* *******************************************************
|
|
*
|
|
* DISCLAIMER. THIS PROGRAM IS PROVIDED TO YOU "AS IS" WITHOUT
|
|
* WARRANTIES OR CONDITIONS OF ANY KIND, WHETHER ORAL OR WRITTEN,
|
|
* EXPRESS OR IMPLIED. THE AUTHOR SPECIFICALLY DISCLAIMS ANY IMPLIED
|
|
* WARRANTIES OR CONDITIONS OF MERCHANTABILITY, SATISFACTORY QUALITY,
|
|
* NON-INFRINGEMENT AND FITNESS FOR A PARTICULAR PURPOSE.
|
|
"""
|
|
|
|
__author__ = 'VMware, Inc.'
|
|
__vcenter_version__ = '7.0+'
|
|
|
|
import random
|
|
import time
|
|
|
|
from com.vmware.vstats_client import AcqSpecs, CidMid, RsrcId, Data
|
|
from vmware.vapi.vsphere.client import create_vsphere_client
|
|
|
|
from samples.vsphere.common import sample_util
|
|
from samples.vsphere.common.ssl_helper import get_unverified_session
|
|
from samples.vsphere.vcenter.hcl.utils import get_configuration
|
|
from samples.vsphere.vcenter.vstats.helpers.sample_cli import parser
|
|
|
|
|
|
class SampleQueryDataPoints(object):
|
|
"""
|
|
Description: Demonstrates end to end workflow of vSphere Stats.
|
|
Step 1: Creation of an Acquisition Specification.
|
|
Step 2: Query for data points filtered by cid.
|
|
Sample Prerequisites:
|
|
vCenter 7.0x with 7.0x ESXi hosts.
|
|
"""
|
|
|
|
def __init__(self):
|
|
args = sample_util.process_cli_args(parser.parse_args())
|
|
self.interval = int(args.interval)
|
|
self.expiration = int(args.expiration)
|
|
|
|
stub_config = get_configuration(
|
|
args.server, args.username, args.password,
|
|
args.skipverification)
|
|
self.acq_specs_client = AcqSpecs(stub_config)
|
|
self.data_client = Data(stub_config)
|
|
|
|
session = get_unverified_session() if args.skipverification else None
|
|
self.vsphere_client = create_vsphere_client(
|
|
server=args.server, username=args.username,
|
|
password=args.password, session=session)
|
|
|
|
def run(self):
|
|
cid = "disk.throughput.usage.VM"
|
|
wait_time = 30
|
|
vm_type = "VM"
|
|
memo = "user definition of acquisition spec"
|
|
|
|
cid_mid_obj = CidMid(cid=cid)
|
|
counter_spec_obj = self.acq_specs_client.CounterSpec(
|
|
cid_mid=cid_mid_obj)
|
|
|
|
# Choose a random VM from which stats data needs to be collected.
|
|
vm_list = self.vsphere_client.vcenter.VM.list()
|
|
vm_obj = random.choice(vm_list)
|
|
vm_id = vm_obj.vm
|
|
|
|
rsrc_obj = RsrcId(id_value=vm_id, type=vm_type)
|
|
|
|
# Create an Acquisition Specification for VM counter.
|
|
acq_spec_obj = self.acq_specs_client.CreateSpec(
|
|
counters=counter_spec_obj,
|
|
resources=[rsrc_obj],
|
|
interval=self.interval,
|
|
expiration=self.expiration,
|
|
memo_=memo
|
|
)
|
|
acq_spec_id = self.acq_specs_client.create(acq_spec_obj)
|
|
SampleQueryDataPoints.print_output(
|
|
"Acquisition Specification created with ID: " + acq_spec_id)
|
|
|
|
# Get the Acquisition Specification.
|
|
acq_spec_info = self.acq_specs_client.get(acq_spec_id)
|
|
SampleQueryDataPoints.print_output(
|
|
"Details of Acquisition Specification with ID " + acq_spec_id,
|
|
acq_spec_info)
|
|
|
|
# Wait for 30 seconds for data collection to happen.
|
|
time.sleep(wait_time)
|
|
|
|
# Query for data points filtered by cid.
|
|
filter_spec = self.data_client.FilterSpec(cid=cid)
|
|
data_points = self.data_client.query_data_points(filter=filter_spec)
|
|
SampleQueryDataPoints.print_output(
|
|
"Data Points collected", data_points)
|
|
|
|
# CleanUp.
|
|
# Delete the Acquisition Specification.
|
|
self.acq_specs_client.delete(acq_spec_id)
|
|
SampleQueryDataPoints.print_output(
|
|
"Acquisition Specification with ID: " + acq_spec_id +
|
|
" is deleted")
|
|
|
|
@staticmethod
|
|
def print_output(*argv):
|
|
print("------------------------------------")
|
|
for arg in argv:
|
|
print(arg)
|
|
|
|
|
|
def main():
|
|
"""
|
|
Entry point for the sample client.
|
|
"""
|
|
query_dp = SampleQueryDataPoints()
|
|
query_dp.run()
|
|
|
|
|
|
if __name__ == '__main__':
|
|
main()
|