使用python管理VMware探索之旅(十)
- 2026-02-06 08:26:44
使用python管理VMware探索之旅(十)
本章内容为：Python编程篇—vCenter连接和主机加入 
vCenter连接 虽然上面多个篇幅介绍的ESXi的配置只针对主机网络配置和NTP配置，因为其它配置都是遵循相同的方法，所以就没有每一个配置都列举出来。 
加入主机 将ESXi主机加入vCenter管理主要需要以下几个步骤： 1. 连接vCenter 直接复用ESXi的连接函数即可。 2. 检查并创建数据中心 
探索之旅将分为两个主要篇章：
Home Lab搭建篇
记录整个环境的搭建过程，记录一些知识的细节。
Python编程篇
记录如何通过Python进行ESXi主机的自动配置。
1). Python编程篇—环境准备
2). Python编程篇—示例扩展
6). Python编程篇—vCenter连接和主机加入
本章内容主要信息如下：
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下多了很多容器：数据中心，集群，资源组等等。
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.rootFolderdcs = dc_folder.childEntityfor 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 = 443conn = 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+2] for i in range(0, len(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.inMaintenanceModeif 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 = Nonecontent = vc_connect.contentcontainer = content.viewManager.CreateContainerView(content.rootFolder, [vim.Datacenter], True)for dc in container.view:if dc.name == dc_name:vc_datacenter = dcbreakcontainer.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 = Truehost_spec.sslThumbprint = thumbprinthost_spec.hostName = hosthost_spec.password = esxi_passwordhost_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.resultelse: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 = Nonecontent = vc_connect.contentcontainer = content.viewManager.CreateContainerView(content.rootFolder, [vim.Datacenter], True)for dc in container.view:if dc.name == dc_name:vc_datacenter = dcbreakcontainer.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.resultelse: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 = hostesxi_user = usernameesxi_password = passwordesxi_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.inMaintenanceModeif 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 = Truehost_spec.sslThumbprint = thumbprinthost_spec.hostName = hosthost_spec.password = esxi_passwordhost_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. 集群创建
2. ESXi主机移入集群
本文来自网友投稿或网络内容，如有侵犯您的权益请联系我们删除，联系邮箱：wyl860211@qq.com 。
