目前正在使用prometheus对我们的openstack云环境进行监控，但过了半年测试环境的主机资源迟迟未到位，因此和基架沟通是否有传统环境的需求可以做，提到了cmdb和商业监控的替换。但基架又不想我们再到每台虚拟机上去安装agent，因此需要通过vSphere Web Service API抓取测试环境34台主机、1600台虚拟机的监控数据。

经过两个星期的研究，第一稿监控vmware vcenter的prometheus exporter开发完成，一次抓取1600多台主机、虚拟机的cpu mhz、mem mb、disk io、net io大概耗时在1分钟左右。

exporter使用go语言编写，使用vsphere的govmomi sdk。
sdk地址: https://github.com/vmware/govmomi
api文档: https://code.vmware.com/apis/42/vsphere#doc

监控效果图

使用go sdk获取连接

func Refresh_connect() {
	ctx,_ := context.WithCancel(context.Background())
	u,err := soap.ParseURL(cfg.Vsphere_url) # webservice地址，类似：https://10.50.82.155/sdk
	if err != nil {
		log.Fatal(err)
		return
	}
	u.User = url.UserPassword(cfg.Vsphere_user,cfg.Vsphere_passwd)
	c,err := govmomi.NewClient(ctx,u,true)
	if err != nil {
		log.Fatal(err)
	}
	connect = &Connect{
		connect: c,context: ctx,}
}

获取主机

func Get_hosts() ([]mo.HostSystem) {
	c := get_connect()
	client := c.connect
	m := view.NewManager(client.Client)
	v,err := m.CreateContainerView(c.context,client.ServiceContent.RootFolder,[]string{"HostSystem"},true)
	log_process("create container view ")
	if err != nil {
		log.Fatal(err)
	}
	var hss []mo.HostSystem
	err = v.Retrieve(c.context,[]string{"summary","vm","datastore"},&hss)
	if err != nil {
		log.Fatal(err)
	}
	log_process("retrieve host data ")
	return hss
}

获取主机信息

通过mo.HostSystem对象可以获取主机的cpu mhz速度、当前使用的mhz，最大内存、当前使用的内存信息，如果想要获取disk和net io，得通过查询监控数据才能获取。

host_cpu_speed := hs.Summary.Hardware.cpuMhz
cpu_capacity := float64(int64(hs.Summary.Hardware.cpuMhz) * int64(hs.Summary.Hardware.NumcpuCores))
cpu_usage := float64(hs.Summary.QuickStats.OverallcpuUsage)
mem_capacity := float64(hs.Summary.Hardware.MemorySize / (1024 * 1024))
mem_usage := float64(hs.Summary.QuickStats.OverallMemoryUsage)

获取主机磁盘空间使用情况

主机的磁盘信息主要是mo.Datastore对象，但hostSystem.Datastore获取到的是[]types.ManagedObjectReference，需要做一次转换

func Get_Host_disk_info(mos []types.ManagedObjectReference) (int64,int64,[]*DiskInfo) {
	c := get_connect()
	pc := property.DefaultCollector(c.connect.Client)
	dss := []mo.Datastore{}
	err := pc.Retrieve(c.context,mos,[]string{"summary"},&dss)
	if err != nil {
		log.Error("get host datastore info error ",err)
	}
	var (
		capacity  int64
		free      int64
		diskInfos []*DiskInfo
	)
	for _,ds := range dss {
		capacity += ds.Summary.Capacity
		free += ds.Summary.FreeSpace
		diskInfos = append(diskInfos,&DiskInfo{
			Capacity: ds.Summary.Capacity / utils.GB,Free:     ds.Summary.FreeSpace / utils.GB,Path:     ds.Summary.Name,})
	}
	return capacity / utils.GB,free / utils.GB,diskInfos
}