vmware api开发之克隆虚拟机

from pyVmomi import vim
from pyVim.connect import SmartConnect, Disconnect
from celery import Celery
from celery import platforms
import atexit
import argparse
import getpass
import ssl
import random
import cgi, cgitb
celery = Celery('tasks', broker='redis://:########redis连接信息/0')
platforms.C_FORCE_ROOT = True
def action(num,flavor,templateid):  #主函数 被Celery调用 
    hardwareconfiglist={1:[2,8*1024],2:[4,16*1024],3:[8,32*1024]}
    cpunum=hardwareconfiglist[int(flavor)][0]
    memsize=hardwareconfiglist[int(flavor)][1]
    si = None
    context = ssl.SSLContext(ssl.PROTOCOL_TLSv1)
    context.verify_mode = ssl.CERT_NONE
    si = SmartConnect(host="###########",
                     user="##################",
                     pwd="############",
                     port=443,
                     sslContext=context)
    atexit.register(Disconnect, si)
    content = si.RetrieveContent()
    template = None
    template = templates[str(templateid)]
    template = get_obj(content, [vim.VirtualMachine], template)
    for i in range(0,int(num)):
        clone_vm(
            content, template, si,
            "", "",
            "存储名字", '集群名字 ',
            "", False,cpunum,memsize)
def get_obj(content, vimtype, name): #把克隆源的虚拟机实例化
    obj = None
    container = content.viewManager.CreateContainerView(
        content.rootFolder, vimtype, True)
    for c in container.view:
        if name:
            if c.name == name:
                obj = c
                break
        else:
            obj = c
            break
    return obj
def clone_vm(   #克隆虚拟机，克隆出来的虚拟机名字是随机，
        content, template,  si,
        datacenter_name, vm_folder, datastore_name,
        cluster_name, resource_pool, power_on,cpunum,memsize):
    datacenter = get_obj(content, [vim.Datacenter], datacenter_name)
    if vm_folder:
        destfolder = get_obj(content, [vim.Folder], vm_folder)
    else:
        destfolder = datacenter.vmFolder
    if datastore_name:
        datastore = get_obj(content, [vim.Datastore], datastore_name)
    else:
        datastore = get_obj(
            content, [vim.Datastore], template.datastore[0].info.name)
    # if None, get the first one
    cluster = get_obj(content, [vim.ClusterComputeResource], cluster_name)
    if resource_pool:
        resource_pool = get_obj(content, [vim.ResourcePool], resource_pool)
    else:
        resource_pool = cluster.resourcePool
    relospec = vim.vm.RelocateSpec()
    relospec.datastore = datastore
    relospec.pool = resource_pool
    clonespec = vim.vm.CloneSpec()
    clonespec.location = relospec
    clonespec.powerOn = power_on
    randomname=get_hostname()
    task = template.Clone(folder=destfolder, name=randomname, spec=clonespec)
    wait_for_task(task)
    vm = get_obj(content, [vim.VirtualMachine], randomname)
    spec = vim.vm.ConfigSpec()
    spec.numCPUs=cpunum
    spec.memoryMB=memsize
    vm.ReconfigVM_Task(spec=spec) #设置克隆好的虚拟机的cpu 和 内存
    vm.CreateSnapshot("fromstart","this created when it is been cloned by system",False,False) #克隆好了创建一个快照，以便实现重装系统的功能
    vm.PowerOn()