通过vsphere golang webservice sdk 获取vmware主机、虚拟机的监控数据【一】

一路向北的兔斯基 · · 2905 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

目前正在使用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{"HostSystem"}, []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
}

有疑问加站长微信联系(非本文作者)

本文来自:开源中国博客

感谢作者:一路向北的兔斯基

查看原文:通过vsphere golang webservice sdk 获取vmware主机、虚拟机的监控数据【一】

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

2905 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传