当前位置:首页>python>使用python管理VMware探索之旅(十)

使用python管理VMware探索之旅(十)

  • 2026-09-05 17:11:31
使用python管理VMware探索之旅(十)

探索之旅将分为两个主要篇章:

  1. Home Lab搭建篇

    记录整个环境的搭建过程,记录一些知识的细节。

    1). Home Lab搭建篇--环境规划

    2). Home Lab搭建篇--AD以及vCenter安装

    3). Home Lab环境搭建—证书服务器安装(上)

    4). Home Lab环境搭建—证书服务器安装(下)

    5). Home Lab环境搭建--ADFS以及ESXi安装

  2. Python编程篇

    记录如何通过Python进行ESXi主机的自动配置。

    1). Python编程篇—环境准备

    2). Python编程篇—示例扩展

    3). Python编程篇—网络修改和函数创建

  3.  4). Python编程篇—主程序创建和函数调用

  4.  5).Python编程篇—主程序参数输入部分增强

  5.  6).  Python编程篇—vCenter连接和主机加入


本章内容为:Python编程篇—vCenter连接和主机加入

本章内容主要信息如下:

vCenter连接
虽然上面多个篇幅介绍的ESXi的配置只针对主机网络配置和NTP配置,因为其它配置都是遵循相同的方法,所以就没有每一个配置都列举出来。

ESXi配置完成后,需要将其加入vCenter,所以第一步就是连接vCenter。

1. 连接vCenter

vCenter的连接方式跟ESXi相同,同样使用smartconnect()函数进行连接,只是连接的主机换成vCenter即可。如果按照本系列文章前半部分的配置,vCenter已经是CA颁发的证书,那么可以不用加sslcontext参数。

基本的命令就是:

context = ssl._create_unverified_context()esxi_connect = SmartConnect(host=host, user=username, pwd=password, sslContext=context)

可以复用《Python编程篇—网络修改和函数创建》中描述的连接函数进行vCenter连接。连接结果如下:

2. vCenter的MOB(Management Object Browser)

vCenter的MOB访问方式跟ESXi的完全一样,访问地址为:http://vCenter_ip_or_fqdn/mob,只是vCenter的MOB网页是默认开启的,不像ESXi那样需要开启一个参数才行。vCenter的MOB网页打开如下:

所以对于vCenter的配置方法跟ESXi是完全一样的,只是vCenter下多了很多容器:数据中心,集群,资源组等等。

加入主机
将ESXi主机加入vCenter管理主要需要以下几个步骤:
1. 连接vCenter
直接复用ESXi的连接函数即可。
2. 检查并创建数据中心

Datacenter所在的配置位置为:

dc_folder = vc_connect.content.rootFolderdcs = dc_folder.childEntity

现有的配置信息:无任何数据中心存在。

用到的method为:CreateDatacenter()

根据vSphere Web Service API手册,链接:

https://developer.broadcom.com/xapis/vsphere-web-services-api/8.0u3/vim.Folder.html#createDatacenter

可以看到,参数只有一个,就是数据中心的名称(name),即需要配置的Data Object。如图:

这里创建之前需要检查数据中心是否已经存在,如果已经存在则直接跳过。

创建数据中心的函数代码为:

from fun_con_esx import connect_esxifrom pyVim.connect import Disconnectfrom pyVmomi import vim, vmodlimport maskpassdef datacenter_create(vc_connect,dc_name):    """    检查/创建数据中心    :param vc_connect: vCenter连接信息    :param dc_name: 数据中心名称    """    dc_list = []    dc_folder = vc_connect.content.rootFolder    dcs = dc_folder.childEntity    for dc in dcs:        if isinstance(dc, vim.Datacenter):            dc_list.append(dc.name.lower())    if dc_name.lower() in dc_list:         print(f"✅数据中心{dc_name}已经存在,无需创建")         return(f"数据中心{dc_name}已经存在,无需创建")    else:         try:             dc_folder.CreateDatacenter(name=dc_name)             print(f"名称为{dc_name}的数据中心已经成功创建")         except vim.fault.DuplicateName as error:             print(f"创建数据中心{dc_name}失败,数据中心重名,具体信息{error.msg}")         except vim.fault.InvalidName as error:             print(f"创建数据中心{dc_name}失败,名称无效,具体信息{error.msg}"         except vmodl.RuntimeFault as error:              print(f"创建数据中心{dc_name}失败,Runtime Fault,具体信息{error.msg}"if __name__ == "__main__":        print("开始执行")        vc_host= "lv8vcsa01.lab.local"        vc_user = "administrator@vsphere.local"        vc_password = maskpass.askpass(        "请输入vCenter主机的密码: ", mask="*"        )        dc_name = input("请输入数据中心的名称: ")        vc_connect = connect_esxi(host=vc_host,username=vc_user,password=vc_password)        print(f"vc已经连接{vc_host}")        datacenter_create(vc_connect,dc_name)        Disconnect(vc_connect)

执行结果为:

3. 获取ESXi证书

这里不是VMware的API直接获取,需要使用socket和hashlib函数进行获取,函数代码如下:

import socketimport sslimport hashlibdef get_ssl_thumbprint(host):    """    获取ESXi主机的证书指纹    :param host: ESXi主机的IP地址或FQDN    """    port = 443    conn = socket.create_connection((host, port))    context = ssl._create_unverified_context()    sock = context.wrap_socket(conn, server_hostname=host)    der_cert = sock.getpeercert(binary_form=True)    thumb_sha1 = hashlib.sha1(der_cert).hexdigest().upper()    thumbprint = ":".join(thumb_sha1[i:i+2for i in range(0len(thumb_sha1), 2))    return thumbprintif __name__ == "__main__":    host = "192.168.50.171"    hostsslthumb = get_ssl_thumbprint(host)    print(f"ESXi主机{host}的证书指纹为:{hostsslthumb}")

执行结果如下:

4. 加入ESXi主机到数据中心

此步骤涉及4个过程,3个自行编写函数,概要如下:

1)连接ESXi主机

使用之前编写的连接函数fun_con_esx()即可。

2)主机进入维护模式

这里进行一个判断,如果没有在维护模式,则执行进入维护模式的操作。

进入维护模式的Managed Object为ESXi主机的位置:

host_info =  esxi_connect.content.rootFolder.childEntity[0].hostFolder.childEntity[0].host[0]

Method为:

EnterMaintenanceMode_Task()

Data Object参数为timeout,这里设置20秒

代码信息为:

    #将主机至于维护模式    host_info =  esxi_connect.content.rootFolder.childEntity[0].hostFolder.childEntity[0].host[0]    maintenance_status = host_info.runtime.inMaintenanceMode    if maintenance_status:         print(f"✅ESXi主机{host}已经处于维护模式,无需设置。")    else:         try:             host_info.EnterMaintenanceMode_Task(timeout=20)             print(f"✅ESXi主机{host}成功进入维护模式")         except vim.fault.InvalidState as e:             print(f"❌ESXi主机{host}进入维护模式错误:{e}")         except vmodl.RuntimeFault as e:             print(f"❌ESXi主机{host}进入维护模式错误:{e}"         except vim.fault.Timedout as e:             print(f"❌ESXi主机{host}进入维护模式超时:{e}"

3)主机加入数据中心

有2个函数需要注意:

获取ESXi证书信息的函数(上面已经写过)。

根据数据中心的名称获取数据中心在API中的位置的函数。函数的代码信息如下:

def get_datacenter(dc_name,vc_connect):    """获取指定名称的数据中心对象"""    vc_datacenter = None    content = vc_connect.content    container = content.viewManager.CreateContainerView(        content.rootFolder, [vim.Datacenter], True    )    for dc in container.view:        if dc.name == dc_name:            vc_datacenter = dc            break    container.Destroy()    return vc_datacenter

将主机加入数据中心时:

Managed Object为:上一步获取的数据中心在vCenter的位置

Method为:

AddStandaloneHost_Task()

Data Object:

按照vSphere Web Services API的手册,链接:

https://developer.broadcom.com/xapis/vsphere-web-services-api/8.0u3/vim.Folder.html#addStandaloneHost

可以看到主要为一个vim.host.ConnectSpec()类型的spec。spec的参数设置代码如下:

    vc_datacenter = get_datacenter(dc_name=dc_name,vc_connect=vc_connect)    thumbprint = get_ssl_thumbprint(host)    host_spec = vim.host.ConnectSpec()    host_spec.force = True    host_spec.sslThumbprint = thumbprint    host_spec.hostName = host    host_spec.password = esxi_password    host_spec.userName = esxi_user

添加主机到数据中心的执行方法如下:

task = vc_datacenter.hostFolder.AddStandaloneHost_Task(spec=host_spec,addConnected=True)

4)任务完成

因为整个任务返回是一个Task对象,所以如果需要看到结果,需要有一个函数查看task的进度。这里直接通过一个函数的形式来查看,函数代码如下:

#检查任务完成状态def wait_for_task(task_name,task, timeout=300):    start_time = time.time()    while task.info.state not in ['success''error']:        if time.time() - start_time > timeout:            raise TimeoutError(f"⏰ 任务超时({timeout}s)")        print(f"任务{task_name}等待中... 当前状态: {task.info.state}")        time.sleep(2)    if task.info.state == 'success':        print(f"✅ 任务{task_name}成功完成")        return task.info.result    else:        print(f"❌ 任务{task_name}失败: {task.info.error.msg if task.info.error else'未知错误'}")        raise task.info.error  # 抛出 VMware 错误对象

主体调用信息如下:

    task_name = "将主机加入数据中心"    wait_for_task(task_name,task)

至此加入数据中心的工作完成。执行结果信息如下:

执行前,vCenter中无任何信息:

执行程序时输出信息如下:

执行完成后,vCenter中信息如下:

至此,将主机加入数据中心的任务已经完成。原始代码如下:

from fun_con_esx import connect_esxifrom fun_datacenter_create import datacenter_createfrom pyVim.connect import SmartConnect, Disconnectfrom pyVmomi import vim, vmodlfrom fun_get_ssl_thinmbprint import get_ssl_thumbprintimport timeimport maskpassdef get_datacenter(dc_name,vc_connect):    """获取指定名称的数据中心对象"""    vc_datacenter = None    content = vc_connect.content    container = content.viewManager.CreateContainerView(        content.rootFolder, [vim.Datacenter], True    )    for dc in container.view:        if dc.name == dc_name:            vc_datacenter = dc            break    container.Destroy()    return vc_datacenter#检查任务完成状态def wait_for_task(task_name,task, timeout=300):    start_time = time.time()    while task.info.state not in ['success''error']:        if time.time() - start_time > timeout:            raise TimeoutError(f"⏰ 任务超时({timeout}s)")        print(f"任务{task_name}等待中... 当前状态: {task.info.state}")        time.sleep(2)    if task.info.state == 'success':        print(f"✅ 任务{task_name}成功完成")        return task.info.result    else:        print(f"❌ 任务{task_name}失败: {task.info.error.msg if task.info.error else'未知错误'}")        raise task.info.error  # 抛出 VMware 错误对象def add_host_to_datacenter(vc_connect,dc_name,host,username,password):    """    将ESXi主机加入到vCenter中的数据中心中    :param dc_name: 数据中心名称    :param host: esxi的FQDN    :param esxi_connect: ESXi的连接信息    """    #连接ESXi主机    esxi_host = host    esxi_user = username    esxi_password = password    esxi_connect = connect_esxi(esxi_host,esxi_user,esxi_password)    #将主机至于维护模式    host_info =  esxi_connect.content.rootFolder.childEntity[0].hostFolder.childEntity[0].host[0]    maintenance_status = host_info.runtime.inMaintenanceMode    if maintenance_status:         print(f"✅ESXi主机{host}已经处于维护模式,无需设置。")    else:         try:             host_info.EnterMaintenanceMode_Task(timeout=20)             print(f"✅ESXi主机{host}成功进入维护模式")         except vim.fault.InvalidState as e:             print(f"❌ESXi主机{host}进入维护模式错误:{e}")         except vmodl.RuntimeFault as e:             print(f"❌ESXi主机{host}进入维护模式错误:{e}"         except vim.fault.Timedout as e:             print(f"❌ESXi主机{host}进入维护模式超时:{e}"    #检查数据中心是否存在,如果不存在则创建    vc_datacenter = get_datacenter(dc_name=dc_name,vc_connect=vc_connect)    if vc_datacenter == None:        print(f"数据中心{dc_name}不存在,创建中...")        datacenter_create(vc_connect,dc_name)    #添加主机到数据中心内    vc_datacenter = get_datacenter(dc_name=dc_name,vc_connect=vc_connect)    thumbprint = get_ssl_thumbprint(host)    host_spec = vim.host.ConnectSpec()    host_spec.force = True    host_spec.sslThumbprint = thumbprint    host_spec.hostName = host    host_spec.password = esxi_password    host_spec.userName = esxi_user    #print(content.rootFolder)    task = vc_datacenter.hostFolder.AddStandaloneHost_Task(spec=host_spec,addConnected=True)    task_name = "将主机加入数据中心"    wait_for_task(task_name,task)    Disconnect(esxi_connect)if __name__ == "__main__":    print("开始执行")    vc_host= "lv8vcsa01.lab.local"    vc_user = "administrator@vsphere.local"    vc_password = maskpass.askpass(    "请输入vCenter主机的密码: ", mask="*"    )    dc_name = "lv8"    esxi_host = "lv8esx01.lab.local"    esxi_user = "root"    esxi_password = maskpass.askpass(        "请输入ESXi主机的密码: ", mask="*"    )    vc_connect = connect_esxi(host=vc_host,username=vc_user,password=vc_password)    print(f"vc已经连接{vc_host}")    add_host_to_datacenter(vc_connect,dc_name,esxi_host,esxi_user,esxi_password)    Disconnect(vc_connect)

下一章将开始:Python编程篇—集群创建和ESXi主机移入集群

主要内容包含:

  1. 1. 集群创建

  2. 2. ESXi主机移入集群

最新文章

随机文章