Zabbix 监控ESXi服务器【非虚拟机】CPU 内存 硬盘 网络带宽

之前写过一个帖子，是如何完美监控ESXi节点的硬盘的，没想到效果那么好。最近好多朋友过来问面包肿么配置。说实话我也是太懒了，所以就把这个脚本优化了一下，一不小心没有刹住车，把CPU、内存、硬盘、网卡流量什么的都监控出来了，哦，对了，还有虚拟机在节点上占用的空间（主要是因为我使用的大多是本地的空间，然后没有一个完美的曲线展示是节点上哪个虚拟机增长量过快导致的本地空间耗费，对运维是有很大隐患的）。然后本来前天v2.0版都已经写好了，上线了！但是发现了一些性能上面的问题，最后没有发布。经过两天的奋笔疾书，终于最新版的v2.0诞生了，监控脚本内容介绍：

config.ini: 配置文件

cpu_mem_info.py: 取CPU值的脚本

get_disk_info.py: 取硬盘相关信息的脚本

main.py: 主的运行文件

traffic.py: 网络流量监控文件

vm_info.py: 虚拟机在节点占用空间获取脚本

zabbix_send.py: 向zabbix send数据的脚本

OK，介绍过脚本作用之后，开始来说一下肿么配置吧！主要是修改"config.ini":

上面是固定的格式:

[VCenter01]------> 主要是VC应用的别名，用于日志上面报错的时候好识别

host：VC的IP地址，格式：10.10.10.10

user:VC的用户名，格式：mianbao

password：VC用户的密码，格式：

注：上面的host、user、password这些项名是不能修改的！

你有几个VC就写几个上面的结构就行，zabbix我就不再多说了，切记 '[zabbix]'是不能修改的哦！

然后就是准备环境了，所需环境 Centos 或 Window都可以，这里只说一下Centos的环境准备方法，只需安装所需要的python以来模块，安装方法如下：

unzip pysphere-0.1.8.zip

cd pysphere-0.1.8

python setup.py install

OK，安装过程是不是简单的有点让人恐怖，接下来验证一下，所安装的环境是否OK：

如果没有报错，OK那就是安装完成了，然后把脚本下载之后放到一个目录里面，运行如下命令就可以收集监控项了：

python main.py

But,在爽之前别忘记了在zabbix上面还需要做相关的配置，主要分为两大块：

1.模板

2.host

1.模板已为大家准备好了，请下载导入即可：

zabbix 2.0 模板：

2.host大家可以通过两种方式添加，一种是自己手动添加，另外一种就是discovery。不会配置的小朋友们要认真做功课了~

一切配置停当，并且有数值了，那么在linux的crontab中添加如下定时任务即可：

*/5 * * * * /usr/bin/python /vmware/main.py

温馨提示：

初次使用脚本的友友们，请运行两次之后再去看数据！因为zabbix第一次会根据send过去的key去建立item，所以第一次会有一半是失败的，第二次就OK了！

附件上传不上来，我直接把代码公布出来吧！

Config.ini

[VCenter01]host=VCIP地址（ex:10.10.10.10）user=VC用户名password=VC用户密码[VCenter02]host=VCIP地址（ex:10.10.10.11）user=VC用户名password=VC用户密码[VCenter03]host=VCIP地址（ex:10.10.10.12）user=VC用户名password=VC用户密码[zabbix]host=Zabbix服务器地址port=10051

cpu_mem_info.py

#-*-coding:utf-8-*-'''@Createdon6月14日@author:MianBao@author_web:'''importcopyfrompysphereimportVIServer,VIPropertyfromzabbix_sendimportzabbix_senderdefgetNodeinfo(s,zabbix_info):properties=['summary.config.name','summary.quickStats.overallCpuUsage','summary.quickStats.overallMemoryUsage','summary.hardware.cpuMhz','summary.hardware.memorySize','summary.hardware.numCpuCores','summary.hardware.numCpuPkgs',]props=s._retrieve_properties_traversal(property_names=properties,obj_type="HostSystem")total={}foriteminprops:host=dict()forpinitem.PropSet:ifp.Name=='summary.config.name':host_name=p.Valifp.Name=='summary.quickStats.overallCpuUsage':cpu_use=p.Valifp.Name=='summary.quickStats.overallMemoryUsage':memroy_use=p.Valifp.Name=='summary.hardware.cpuMhz':cpu_hz=p.Valifp.Name=='summary.hardware.memorySize':memory_total=p.Valifp.Name=='summary.hardware.numCpuCores':cpu_core=p.Valifp.Name=='summary.hardware.numCpuPkgs':cpu_num=p.Valhost['cpu_use']=cpu_usehost['memory_use']=memroy_usehost['cpu_hz']=cpu_hz*cpu_corehost['memory_total']=memory_totalhost['cpu_core']=cpu_corehost['cpu_num']=cpu_numtotal[host_name]=hosthost=dict()#printtotalSendDataToZabbix(total,zabbix_info)defSendDataToZabbix(total,zabbix_info):forx,yintotal.items():value=dict()value['host']=xzabbix=zabbix_sender(**zabbix_info)value['key']='cpu.info'value['value']='{"data":[{"{#DATA}":"CPU"}]}'zabbix.adddata(**copy.deepcopy(value))value['key']='cpu.use.hz[CPU]'value['value']=y.get('cpu_use')zabbix.adddata(**copy.deepcopy(value))value['key']='cpu.physical.core[CPU]'value['value']=y.get('cpu_core')zabbix.adddata(**copy.deepcopy(value))value['key']='cpu.total.hz[CPU]'value['value']=y.get('cpu_hz')zabbix.adddata(**copy.deepcopy(value))value['key']='cpu.chacao.num[CPU]'value['value']=y.get('cpu_num')zabbix.adddata(**copy.deepcopy(value))value['key']='cpu.vcpu.num[CPU]'value['value']=y.get('cpu_num')*y.get('cpu_core')zabbix.adddata(**copy.deepcopy(value))response=zabbix.send()#print'memory----',responsezabbix_memory=zabbix_sender(**zabbix_info)value['key']='memory.info'value['value']='{"data":[{"{#DATA}":"MEMORY"}]}'zabbix_memory.adddata(**copy.deepcopy(value))value['key']='memory.use.mb[MEMORY]'value['value']=y.get('memory_use')*1024*1024zabbix_memory.adddata(**copy.deepcopy(value))value['key']='memory.total.bytes[MEMORY]'value['value']=y.get('memory_total')zabbix_memory.adddata(**copy.deepcopy(value))response=zabbix_memory.send()#print'cpu----',responsereturnresponse

get_disk_info.py:

#-*-coding:utf-8-*-'''@Createdon6月14日@author:MianBao@author_web:'''importosimportsslimportcopyimportjsonfrompysphereimportVIServer,VIPropertyfromzabbix_sendimportzabbix_senderimporttimedefHostSystem(s):properties=['summary.config.name','datastore',]props=s._retrieve_properties_traversal(property_names=properties,obj_type="HostSystem")host=dict()foriteminprops:forpinitem.PropSet:ifp.Name=='datastore':datastore_id=p.Val.ManagedObjectReferenceifp.Name=='summary.config.name':host_ip=p.Valforxindatastore_id:host[str(x)]=host_ipreturnhostdefDatatStore(s):properties=['summary.capacity','summary.freeSpace','summary.name','summary.uncommitted',]props=s._retrieve_properties_traversal(property_names=properties,obj_type="Datastore")host=dict()foriteminprops:disk=dict()forpinitem.PropSet:ifp.Name=='summary.capacity':total=p.Valifp.Name=='summary.freeSpace':free=p.Valifp.Name=='summary.name':name=p.Valifp.Name=='summary.uncommitted':uncommitted=p.Valdisk['total']=totaldisk['free']=freedisk['name']=name#disk['uncommitted']=uncommittedhost[name]=diskreturnhostdefGet_Datastore(s):returns.get_datastores()defMergeAndSend(s,zabbixs):host=HostSystem(s)disk=DatatStore(s)middle=Get_Datastore(s)hosts=dict()forM,Ninhost.items():X=middle.get(M)Y=disk.get(X)zabbix_send_content(N,Y,zabbixs)returnhostsdefzabbix_send_content(host,cont_dict,zabbixs):ifisinstance(cont_dict,dict):zabbix=zabbix_sender(**zabbixs)#thediscoveryrulesvalue=dict()value['host']=hostvalue['key']='vmware.disk.name'value['value']='{"data":[{"{#DATA}":"%s"}]}'%cont_dict.get('name')zabbix.adddata(**copy.deepcopy(value))value['key']='vmware.disk.free[%s]'%cont_dict.get('name')value['value']='%s'%cont_dict.get('free')zabbix.adddata(**copy.deepcopy(value))value['key']='vmware.disk.total[%s]'%cont_dict.get('name')value['value']='%s'%cont_dict.get('total')zabbix.adddata(**copy.deepcopy(value))response=zabbix.send()#print'disk----',responsereturnresponseif'__main__'==__name__:pass

main.py:

#-*-coding:utf-8-*-'''@Createdon.11.14@author:MianBao@author_web:'''importosimportsslimportloggingimportConfigParserimportthreadingimporttimefrompysphereimportVIServerfromget_disk_infoimportMergeAndSendfromcpu_mem_infoimportgetNodeinfofromvm_infoimportmainfromtrafficimportNetTrafficclassMianBao():def__init__(self):self.now_path=os.path.dirname(__file__)self.vcinfo=NonedefGetConfig(self):config=dict()config_items=['host','user','password']config_zabbix_items=['host','port']file=os.path.join(self.now_path,'config.ini')Cfile=ConfigParser.ConfigParser()Cfile.read(file)Cfile_zone=Cfile.sections()forCinCfile_zone:zone_config=dict()config_items=config_zabbix_itemsifC=='zabbix'else['host','user','password']try:forYinconfig_items:zone_config[Y]=Cfile.get(C,Y)exceptException,e:self.logs('configread',e.message)passconfig[C]=zone_configself.vcinfo=configdeflogs(self,where,log):log_name=os.path.join(self.now_path,'main.log')logger=logging.getLogger(where)logger.setLevel(logging.DEBUG)fh=logging.FileHandler(log_name)fh.setLevel(logging.DEBUG)formatter=logging.Formatter('%(asctime)s-%(filename)s:%(lineno)s-%(name)s-%(message)s')fh.setFormatter(formatter)logger.addHandler(fh)logger.debug(log)defConnect(self,zone,vc):#windowsneedimportthessltry:ssl._create_default_https_context=ssl._create_unverified_contextexceptException,e:passself.Server=VIServer()try:self.Server.connect(**vc)exceptException,e:self.logs('%sVC连接错误'%zone,e.message)returnself.Serverifself.Server.is_connected()else1defRun(self):self.GetConfig()ifself.vcinfoisnotNone:zabbix=self.vcinfo.get('zabbix',None)forzone,vcinself.vcinfo.items():ifzone!='zabbix'andzabbix!=None:S=self.Connect(zone,vc)try:MergeAndSend(S,zabbix)getNodeinfo(S,zabbix)main(S,zabbix)NetTraffic(S,zabbix)S.disconnect()exceptException,e:self.logs('%sVC连接错误'%zone,e.message)passif'__main__'==__name__:collor=MianBao()collor.Run()

traffic.py:

#-*-coding:utf-8-*-'''@Createdon.11.14@author:MianBao@author_web:'''importcopyfrompysphereimportVIServer,VIPropertyfromzabbix_sendimportzabbix_senderimporttimedefNetTraffic(s,zabbix_info):pm=s.get_performance_manager()get_key=['net.bytesTx','net.bytesRx']forx,yins.get_hosts().items():network_type=dict()forMinget_key:network_traffic=dict()start=time.clock()nettx_out=pm.get_entity_statistic(x,M)end=time.clock()fornettxtrafficinnettx_out:nettxinstance=dict((name,getattr(nettxtraffic,name))fornameindir(nettxtraffic)ifnotname.startswith('__'))ifnettxinstance['instance']!="":netname=nettxinstance['instance']nettxtraffic=nettxinstance['value']network_traffic[netname]=nettxtrafficnetwork_type[M]=network_traffic#print"trafficusetime:",end-startMergeNetName(network_type,y,zabbix_info)defMergeNetName(network_type,y,zabbix_info):ifisinstance(network_type,dict):form,ninnetwork_type.get('net.bytesTx').items():network_in=network_type.get('net.bytesRx').get(m)UpToZabbix(y,m,n,network_in,zabbix_info)defUpToZabbix(y,net_name,out,net_in,zabbix_info):zabbix_traffic=zabbix_sender(**zabbix_info)value=dict()value['host']=yvalue['key']='traffic.info'value['value']='{"data":[{"{#DATA}":"%s"}]}'%net_namezabbix_traffic.adddata(**copy.deepcopy(value))value['key']='.out.kb[%s]'%net_namevalue['value']=outzabbix_traffic.adddata(**copy.deepcopy(value))value['key']='.in.kb[%s]'%net_namevalue['value']=net_inzabbix_traffic.adddata(**copy.deepcopy(value))response=zabbix_traffic.send()#print'traffic----',response

vm_info.py:

#-*-coding:utf-8-*-'''@Createdon614@author:MianBao@author_web:'''importcopyimportsslfrompysphereimportVIServer,VIPropertyfromzabbix_sendimportzabbix_senderimporttimedefGetNodeInfo(Server):managed_object_types='VirtualMachine'properties=['summary.runtime.host','mitted','name',]props=Server._retrieve_properties_traversal(property_names=properties,obj_type=managed_object_types)vms=dict()foriteminprops:vm={}host_id=Noneforpinitem.PropSet:ifp.Name=='summary.runtime.host':ifvms.get(p.Val,None):host_id=p.Valvm[p.Name]=p.Valifhost_id:vms[host_id].append(vm)else:vms[vm['summary.runtime.host']]=[vm,]returnvmsdefGetHosts(s):hosts=s.get_hosts()returnhostsdefmain(s,zabbix_info):start=time.clock()hosts=GetHosts(s)vms=GetNodeInfo(s)forx,yinvms.items():forminy:response=SendData(x,m,hosts,zabbix_info)end=time.clock()#print'vmusetime:',end-startreturnresponsedefSendData(x,m,hosts,zabbix_info):zabbix_vm=zabbix_sender(**zabbix_info)value=dict()value['host']=hosts.get(x,None)value['key']='vmware.vm'vm_name=m.get('name')value['value']='{"data":[{"{#DATA}":"%s"}]}'%str(vm_name)zabbix_vm.adddata(**copy.deepcopy(value))forkey,valinm.items():ifkeynotin['summary.runtime.host','name',]:value['key']='%s[%s]'%(key,vm_name)value['value']=valzabbix_vm.adddata(**copy.deepcopy(value))response=zabbix_vm.send()returnresponse