Golang govmomi фильтрует виртуальные машины по пулу ресурсов - PullRequest
Новая
       32

Golang govmomi фильтрует виртуальные машины по пулу ресурсов

1 голос
/ 09 июня 2019

В настоящее время у меня есть некоторый код go, чтобы вывести список имен виртуальных машин и пулов ресурсов с библиотекой govmomi.В выводе у меня есть какие-то идентификаторы пула ресурсов, а не реальные имена.Поэтому у меня есть два вопроса: 1. Существует ли простой и понятный способ фильтрации виртуальных машин по имени пула ресурсов, например, командой govc: 

govc find . -type m -resourcePool $(govc find -i . -name PoolName)

2.Есть ли способ поиска во всех контроллерах домена, без указания имен, поскольку я хочу создать процедуру поиска по множеству vSphere, у них разные имена контроллеров, но одинаковые пулы.Мой код: 

package main

import (
    "flag"
    "fmt"
    "net/url"
    "os"
    "sync"
    "github.com/vmware/govmomi"
    "github.com/vmware/govmomi/find"
    "github.com/vmware/govmomi/property"
    "github.com/vmware/govmomi/vim25/mo"
    "github.com/vmware/govmomi/vim25/types"
    "golang.org/x/net/context"
)

var vsphereUrl = "https://name:pass@vsphere/sdk"
var insecureFlag = false


func exit(err error) {
    fmt.Fprintf(os.Stderr, "Error: %s\n", err)
    os.Exit(1)
}


func main() {
    ctx, cancel := context.WithCancel(context.Background())
    defer cancel()
    flag.Parse()
    u, err := url.Parse(vsphereUrl)
    if err != nil {
        exit(err)
    }
    c, err := govmomi.NewClient(ctx, u, insecureFlag)
    if err != nil {
        exit(err)
    }
    f := find.NewFinder(c.Client, true)
    dcs := []string{"First-DC", "Second-DC"}
    var group sync.WaitGroup
    for _, dc := range dcs {
        group.Add(1)
        go func(ctx context.Context, dc string, f *find.Finder, c *govmomi.Client, group *sync.WaitGroup) {
            defer group.Done()
            dcObj, err := f.DatacenterOrDefault(ctx, dc)
            if err != nil {
                exit(err)
            }
            f.SetDatacenter(dcObj)
            vms, err := f.VirtualMachineList(ctx, "*")
            if err != nil {
                exit(err)
            }
            pc := property.DefaultCollector(c.Client)
            var refs []types.ManagedObjectReference
            for _, vm := range vms {
                refs = append(refs, vm.Reference())
            }
            var vmt []mo.VirtualMachine
            err = pc.Retrieve(ctx, refs, []string{"name", "resourcePool"}, &vmt)
            if err != nil {
                exit(err)
            }
            for _, vm := range vmt {
                fmt.Println(vm.Name, vm.ResourcePool)
            }
        }(ctx, dc, f, c, &group)
    }
    group.Wait()
    fmt.Println("Done.")
}

Токовый выход: 

SRVAP1027 ResourcePool:resgroup-3246
SRVAP1029 ResourcePool:resgroup-3246
SRVWE086 ResourcePool:resgroup-544
SRVDB087 ResourcePool:resgroup-3246
SRVAP1031 ResourcePool:resgroup-49
SRVAP1036 ResourcePool:resgroup-49
...