vsphere golang sdk govmomi 使用指南

go get -u github.com/vmware/govmomi

<scheme>://<user>:<password>@<host>:<port>/<path>;<params>?<query>#<frag>

https://user:password@IP/sdk

u := &url.URL{
    Scheme: "https",
    Host:   ip,
    Path:   "/sdk",
}
u.User = url.UserPassword(user, password)

ctx := context.Background()
client, err := govmomi.NewClient(p.ctx, u, true)
if err != nil {
    panic(err)
}

package main


import (
    "context"
    "fmt"
	"github.com/vmware/govmomi"
	"net/url"
)


const (
	ip = ""
	user = ""
	password = ""
)


func main() {
	u := &url.URL{
		Scheme: "https",
		Host:   ip,
		Path:   "/sdk",
	}
	ctx := context.Background()
	u.User = url.UserPassword(user, password)
	client, err := govmomi.NewClient(ctx, u, true)
	if err != nil {
		panic(err)
	}
	fmt.Println(client)
}

go build github.com/vmware/govmomi/govc/

export GOVC_URL=""
export GOVC_USERNAME=""
export GOVC_PASSWORD=""
export GOVC_INSECURE="true"

./govc find  -type f

// 这里的 c 就是上面登录后 client 的 Client 属性
func findVMByName(ctx context.Context, c *vim25.Client, vmName string) {
	m := view.NewManager(c)


	v, err := m.CreateContainerView(ctx, c.ServiceContent.RootFolder, []string{"VirtualMachine"}, true)
	if err != nil {
		panic(err)
	}


	defer v.Destroy(ctx)


	// Retrieve summary property for all machines
	// Reference: http://pubs.vmware.com/vsphere-60/topic/com.vmware.wssdk.apiref.doc/vim.VirtualMachine.html
	var vms []mo.VirtualMachine
	err = v.Retrieve(ctx, []string{"VirtualMachine"}, []string{"summary"}, &vms)
	if err != nil {
		panic(err)
	}


	// Print summary per vm (see also: govc/vm/info.go)


	for _, vm := range vms {
		// 判断虚拟机名称是否相同，相同的话，vm 就是查找到主机
		if vm.Summary.Config.Name == vmName {
			fmt.Printf("%s: %s\n", vm.Summary.Config.Name, vm.Summary.Config.GuestFullName)
			break
		}
	}
}

func findVMByIP(ctx context.Context, c *vim25.Client, ip string) {
	searchIndex := object.NewSearchIndex(c)
	// nil 是数据中心，你如果要指定的话，需要构造数据中心的结构体，这里就不指定了
	// ip 是你虚拟机的 ip
	// true 的意思我没搞懂
	reference, err := searchIndex.FindByIp(ctx, nil, ip, true)
	// 之所以只对 reference 进行判断而非对 err 进行判断是因为这个库的 bug
	// 也不能说是 bug，我感觉是库的开发者有些瞎搞，挺随意的感觉
	// 就算没找到，它也不会有 err，但是 reference 一定为 nil，我之前就被坑了
	// 因此不要直接对 err 进行判断，后续的所有相关判断也都应该如此
	if reference == nil {
		panic("vm not found")
	}


	// 这类的查找的对象都是 object.Reference，你需要通过对应的方法将其转换为相应的对象
	// 比如虚拟机、文件夹、模板等~
	vm := object.NewVirtualMachine(c, reference.Reference())
	fmt.Println(vm)
}

func findVMByPath(ctx context.Context, c *vim25.Client, folderPath, vmName string) {
	searchIndex := object.NewSearchIndex(c)
	// 通过 path.Join 将文件夹路径和虚拟机名称拼接成完整的虚拟机路径
	reference, err := searchIndex.FindByInventoryPath(ctx, path.Join(folderPath, vmName))
	if reference == nil {
		panic("vm not found")
	}


	vm := object.NewVirtualMachine(c, reference.Reference())
	fmt.Println(vm)
}

func findVMByUuid(ctx context.Context, c *vim25.Client, uuid string) {
	searchIndex := object.NewSearchIndex(c)
	// 第一个 nil 指的是数据中心
	// true 和之前的 true 意义一样，只不过我不知道是什么意思
	// 最后一个 nil 我也不知道是啥意思
	reference, err := searchIndex.FindByUuid(ctx, nil, uuid, true, nil)
	if reference == nil {
		panic("vm not found")
	}


	vm := object.NewVirtualMachine(c, reference.Reference())
	fmt.Println(vm)
}

func vmConv(c *vim25.Client, mvm mo.VirtualMachine) {
	vm := object.NewVirtualMachine(c, mvm.Reference())
	fmt.Println(vm)
}

func x(ctx context.Context, vm *object.VirtualMachine, c *vim25.Client) {
	var mvm mo.VirtualMachine


	pc := property.DefaultCollector(c)
	// 如果想要全部属性，可以传一个空的字串切片
	err := pc.RetrieveOne(ctx, vm.Reference(), []string{"runtime.host", "config.uuid"}, &mvm)
}

func x(ctx context.Context, vm *object.VirtualMachine, c *vim25.Client) {
	var o mo.VirtualMachine
	if err := vm.Properties(ctx, vm.Reference(), []string{"config.uuid"}, &o); err != nil {
		panic(err)
	}
}

func vmShutdown(ctx context.Context, vm *object.VirtualMachine) {
	// 第一个返回值是 task，我认为没必要处理，如果你要处理的话可以接收后处理
	_, err := vm.PowerOff(ctx)
	if err != nil {
		panic(err)
	}
}

func vmDelete(ctx context.Context, vm *object.VirtualMachine) {
	// task 可以处理，也可以不处理
	task, err := vm.Destroy(ctx)
	if err != nil {
		panic(err)
	}
	if task.Wait(ctx) != nil {
		panic(err)
	}
}

func disconnectNic(ctx context.Context, vm *object.VirtualMachine) {
	devidelst, err := vm.Device(ctx)
	if err != nil {
		panic("获取虚拟机的设备列表失败，" + err.Error())
	}
	for _, device := range devidelst {
		switch device.(type) {
		case *types.VirtualVmxnet3:
			if devidelst.Disconnect(device) != nil {
				panic("断开网卡连接失败，" + err.Error())
			}
			if vm.EditDevice(p.ctx, device) != nil {
				panic("断开网卡连接失败，" + err.Error())
			}
		}
	}
}

// 先通过目标文件夹来找到其文件夹对象，然后将虚拟机移动到这个对象中
func vmMove(ctx context.Context, destDir string, c *vim25.Client,
		vm *object.VirtualMachine, searchIndex *object.SearchIndex) {
	reference, _ := searchIndex.FindByInventoryPath(ctx, destDir)
	if reference == nil {
		panic("目标目录 " + destDir + " 不存在")
	}


	folder := object.NewFolder(c, reference.Reference())
	task, err := folder.MoveInto(ctx, []types.ManagedObjectReference{vm.Reference()})
	if err != nil {
		panic(err)
	}
	if err := task.Wait(ctx); err != nil {
		panic(err)
	}
}