From 76878eb2972ad789c2eb7fe3f2eefa285b3e72d6 Mon Sep 17 00:00:00 2001 From: "Sridhar K. N. Rao" Date: Wed, 28 Apr 2021 18:39:15 +0530 Subject: [WIP] - Reporting support for Openstack and K8S Test Runs. This patch adds support for generating report when tests are run for K8S and openstack. Added cloud-information gathering tool. Move the tool to report folder. Call the save cloud information from vsperf. Fixed issues reported by Al. Additional fixes. JIRA: VINEPERF-644 Signed-off-by: Sridhar K. N. Rao Change-Id: I4aea2e52a4c6700f80624f3e1828b74a108e03ba --- tools/report/cloudinfo.py | 104 ++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 104 insertions(+) create mode 100644 tools/report/cloudinfo.py (limited to 'tools/report/cloudinfo.py') diff --git a/tools/report/cloudinfo.py b/tools/report/cloudinfo.py new file mode 100644 index 00000000..41faac0b --- /dev/null +++ b/tools/report/cloudinfo.py @@ -0,0 +1,104 @@ +# Copyright 2021 Spirent Communications. +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. + +""" +Get Cloud information and save it a file +""" + +import os +import json +from kubernetes import client, config +from kubernetes.client.rest import ApiException +from conf import settings +from tools.os_deploy_tgen.utilities import utils +from tools.os_deploy_tgen.osclients import openstack + +def save_kubernetes_info(): + """ + Save Kubernetes Cluster Info + """ + config.load_kube_config(settings.getValue('K8S_CONFIG_FILEPATH')) + with open(os.path.join(settings.getValue('RESULTS_PATH'), + 'cloud_info.txt'), 'a+') as outf: + api = client.CoreV1Api() + try: + node_info = api.list_node() + except ApiException as err: + raise Exception from err + for ni_item in node_info.items: + outf.write("\n ******************************************** \n") + outf.write("\n System Information \n") + sinfo = {'Architecture': ni_item.status.node_info.architecture, + 'Container Runtime Version':ni_item.status.node_info.container_runtime_version, + 'kernel version':ni_item.status.node_info.kernel_version, + 'Kube Proxy Version':ni_item.status.node_info.kube_proxy_version, + 'Kubelet Version':ni_item.status.node_info.kubelet_version, + 'Operating System':ni_item.status.node_info.operating_system, + 'OS Image':ni_item.status.node_info.os_image} + json.dump(sinfo, outf, indent=4) + outf.write("\n List of Addresses \n") + for addrs in ni_item.status.addresses: + entry = {'address': addrs.address, 'type': addrs.type} + json.dump(entry, outf, indent=4) + outf.write("\n Allocatable Resources \n") + json.dump(ni_item.status.allocatable, outf, indent=4) + outf.write("\n Available Resources \n") + json.dump(ni_item.status.capacity, outf, indent=4) + api = client.VersionApi() + try: + version_info = api.get_code() + except ApiException as err: + raise Exception from err + outf.write("\n Version Information \n") + vinfo = {'git_commit': version_info.git_commit, 'git_version': version_info.git_version, + 'platform': version_info.platform, 'go_version': version_info.go_version} + json.dump(vinfo, outf, indent=4) + +def save_openstack_info(): + """ + Save Openstack Info + """ + osclient = openstack.OpenStackClient(utils.pack_openstack_params()) + hypervisors = osclient.conn.list_hypervisors() + with open(os.path.join(settings.getValue('RESULTS_PATH'), + 'cloud_info.txt'), 'a+') as outf: + for hypervisor in hypervisors: + outf.write("\n ***************************************** \n") + outf.write(f"Hypervisor status: {hypervisor.status} \n") + outf.write(f"Hypervisor type: {hypervisor.hypervisor_type} \n") + outf.write(f"Hypervisor CPU-Arch: {hypervisor.cpu_info['arch']} \n") + outf.write(f"Hypervisor CPU-model: {hypervisor.cpu_info['model']} \n") + outf.write(f"Hypervisor CPU-vendor: {hypervisor.cpu_info['vendor']} \n") + outf.write(f"Hypervisor CPU-topology: {hypervisor.cpu_info['topology']} \n") + outf.write(f"Hypervisor id: {hypervisor.id} \n") + outf.write(f"Hypervisor state: {hypervisor.state} \n") + outf.write(f"Hypervisor host IP: {hypervisor.host_ip} \n") + outf.write(f"Hypervisor running VMs: {hypervisor.running_vms} \n") + outf.write(f"Hyperviror hostname: {hypervisor.name} \n") + outf.write("\n ***************************************** \n") + version_data = osclient.keystone_session.get_all_version_data() + json.dump(version_data, outf, indent=2) + +def save_cloud_info(): + """ + Save Cloud Information + """ + if settings.getValue('K8S'): + save_kubernetes_info() + elif settings.getValue('OPENSTACK'): + save_openstack_info() + else: + print("Unsupported Cloud") + return -1 + return 0 -- cgit 1.2.3-korg