面包ESXi 硬盘监控脚本使用方法详解

mianbao

上一个帖子是我草草写完的，所以里面还有很多地方不是很清楚，所以今天重新记录一下，其中配置的过程我这里就不再多说，请大家看上一个帖子：
【需VC】Zabbix 完美监控VMware ESXi 的硬盘 http://mianbao.cn.com/forum.php?mod=viewthread&tid=172&fromuid=1

请注意：因此脚本依赖pysphere模块，所以请至最后查看安装pysphere模块的方法！

上面的附件大家就不要下载了，里面的脚本是没有经过优化的，一会我会把优化过的脚本放出来，并说明详细的使用过程。主要优化了多VC的支持和脚本格式，脚本如下：

1. #-*- coding:utf-8 -*-
   
2. '''
   
3. @Created on 2016年6月14日
   
4. 
   
5. @author: MianBao
   
6. 
   
7. @author_web: Mianbao.cn.com
   
8. 
   
9. '''
   
10. import os
    
11. import ssl
    
12. import copy
    
13. import json
    
14. from pysphere import VIServer,VIProperty
    
15. from zabbix_send import zabbix_sender
    
16. 
    
17. 
    
18. 
    
19. def Connect(ip,user,pwd):
    
20.     # windows need import the ssl
    
21.     try:
    
22.         ssl._create_default_https_context = ssl._create_unverified_context
    
23.     except Exception,e:
    
24.         pass
    
25.    
    
26.     Server = VIServer()
    
27.     try:
    
28.         Server.connect(ip, user, pwd)
    
29.     except Exception,e:
    
30.         print e.message
    
31.     return Server if Server.is_connected() else  1
    
32. 
    
33. def GetNodeIdList(server):
    
34.     all_data_dict = dict()
    
35.     hosts = server.get_hosts()
    
36.     for disk_mor,disk_name in hosts.items():
    
37.         p = VIProperty(server, disk_mor)
    
38.         for ds in p.datastore:
    
39.             disk_name_value_list = all_data_dict.get(disk_name,None)
    
40.             if disk_name_value_list:
    
41.                 disk_name_value_list.append(ds._obj)
    
42.             else:
    
43.                 new = list()
    
44.                 new.append(ds._obj)
    
45.                 all_data_dict[disk_name] = new
    
46.     return all_data_dict
    
47.    
    
48. def GetNodeDiskUse(server):
    
49.     all_data_dict = dict()
    
50.     for ds_mor, name in server.get_datastores().items():
    
51.         props = VIProperty(server, ds_mor)
    
52.         new=dict()
    
53.         new['name'] = name
    
54.         new['total'] = props.summary.capacity
    
55.         new['free'] = props.summary.freeSpace
    
56.         new['datastore_id'] = ds_mor
    
57.         all_data_dict[ds_mor] = new
    
58.     return all_data_dict
    
59. 
    
60. def MergeIdUse(id_dict,use_dict,zabbix):
    
61.     if isinstance(id_dict, dict) and isinstance(use_dict, dict):
    
62.         for key,val in id_dict.items():
    
63.             for x in val:
    
64.                 id_use_dict = use_dict.get(x,None)
    
65.                 if id_use_dict:
    
66.                     id_use_dict['host'] = key
    
67.                     rs = zabbix_send_content(id_use_dict,zabbix)
    
68.                     print rs
    
69. 
    
70. def zabbix_send_content(cont_dict,zabbix):
    
71.     if isinstance(cont_dict, dict):
    
72.         zabbix=zabbix_sender(**zabbix)
    
73.         
    
74.         #the discovery rules
    
75.         value = dict()
    
76.         value['host'] = cont_dict.get('host')
    
77.         value['key'] = 'vmware.disk.name'
    
78.         value['value'] = '{"data":[{"{#DATA}":"%s"}]}' % cont_dict.get('name')
    
79.         zabbix.adddata(**copy.deepcopy(value))
    
80.         
    
81.         value['key'] = 'vmware.disk.free[%s]' % cont_dict.get('name')
    
82.         value['value'] = '%s' % cont_dict.get('free')
    
83.         zabbix.adddata(**copy.deepcopy(value))
    
84.         
    
85.         value['key'] = 'vmware.disk.total[%s]' % cont_dict.get('name')
    
86.         value['value'] = '%s' % cont_dict.get('total')
    
87.         zabbix.adddata(**copy.deepcopy(value))
    
88.         
    
89.         response=zabbix.send()
    
90.         return response
    
91. 
    
92. 
    
93. 
    
94. if '__main__' == __name__:
    
95.    
    
96.     vc_login_info = [
    
97.                      {'ip':'1.1.1.1','user':'zabbix','pwd':'mianbao.cn.com'},
    
98.                      {'ip':'2.2.2.2','user':'zabbix','pwd':'mianbao.cn.com'},
    
99.                     ]
    
100.    
     
101.     zabbix_info = {'host':'5.5.5.5','port':10050,}
     
102.    
     
103.     for vc_login in vc_login_info:
     
104.         server = Connect(**vc_login)
     
105.         node_data = GetNodeIdList(server)
     
106.         name_data = GetNodeDiskUse(server)
     
107.         node_disk = MergeIdUse(node_data, name_data,zabbix_info)
     
108.         server.disconnect()

复制代码

使用时请注意以下配置：
1.VC的配置，请给需监控的VC新增一个只读的用户（），并按照上面的格式填写。
2.zabbix_info里面的关于zabbix的设置，后面的端口一定不要用引号。
3.建议使用面包提供的模板，这样你就可以不用修改discovery的key和item的key直接就可以使用了。

接下来我们来看一下zabbix_sender这个脚本的内容：

1. #!/usr/bin/env python
   
2. #coding:utf-8
   
3. import struct
   
4. import json
   
5. import socket
   
6. 
   
7. 
   
8. 
   
9. class zabbix_sender:
   
10.    
    
11.     def __init__(self,host,port):
    
12.             self.zbx_server_host=host
    
13.             self.zbx_server_port=port
    
14.             self.zbx_header='ZBXD'
    
15.             self.zbx_protocols_version=1
    
16.             self.zbx_send_value={'request':'sender data','data':[]}
    
17. 
    
18.     def adddata(self,host,key,value):
    
19.             add_data={'host':host,'key':key,'value':value}
    
20.             self.zbx_send_value['data'].append(add_data)
    
21. 
    
22.     def makesenddata(self):
    
23.             zbx_send_json=json.dumps(self.zbx_send_value)
    
24.             zbx_send_json_len=len(zbx_send_json)
    
25.             self.zbx_send_data=struct.pack("<4sBq"+str(zbx_send_json_len)+"s",'ZBXD',1,zbx_send_json_len,zbx_send_json)
    
26.    
    
27.     def send(self):
    
28.             self.makesenddata()
    
29.             zbx_server_socket=socket.socket()
    
30.             zbx_server_socket.connect((self.zbx_server_host,self.zbx_server_port))
    
31.             zbx_server_write_df=zbx_server_socket.makefile('wb')
    
32.             zbx_server_write_df.write(self.zbx_send_data)
    
33.             zbx_server_write_df.close()
    
34.             zbx_server_read_df=zbx_server_socket.makefile('rb')
    
35.             zbx_response_package=zbx_server_read_df.read()
    
36.             zbx_server_read_df.close()
    
37.             zbx_response_data=struct.unpack("<4sBq"+str(len(zbx_response_package) - struct.calcsize("<4sBq"))+"s",zbx_response_package)
    
38.             return zbx_response_data[3]
    
39. 
    
40. if __name__ == '__main__':
    
41.     pass

复制代码

OK，两个脚本的内如上所示，如果按照上面的方法配置好了之后，然后添加定时任务：

1. */5 * * * * /usr/bin/python /usr/local/zabbix/script/get_disk_info.py

复制代码

然后手动的执行一下看看执行的输出：

1. {"response":"success","info":"processed: 3; failed: 0; total: 3; seconds spent: 0.003739"}

复制代码

请注意看上面的failed，如果为0的话，说明就全部执行成功了！
至此整个监控的配置过程已配置完毕了，如果还有什么问题请加面包群进行询问：

注：本群仅解答本站所提供的帖子的解决方法中的疑问，其他问题如有能力会尽量帮助。询问方法入下：
1.发送看到的帖子至群中，把你要询问的问题跟在帖子中，站长会亲自进行解答！（为了避免大家提共同的问题，形成一个沉淀，所以请大家尽量把问题以发帖子的形式发出来！）

mianbao

因脚本的监控需要一个pysphere的python模块，所以大家还需要安装一下，如果有pip的话直接使用pip安装即可：

1. pip install -U pysphere

复制代码

如果没有pip的话，也不用安装，我们就采用安装包的方式安装一下，安装方法如下：

1. unzip pysphere-0.1.8.zip
   
2. cd pysphere-0.1.8
   
3. python setup.py install

复制代码

安装包下载：
pysphere-0.1.8.zip (526.23 KB, 下载次数: 93)

2016-6-20 10:43 上传

点击文件名下载附件

mianbao

模板下载，内涵设置好的discovery rules

lht1111

goodgoodgood

asdfhxc

厉害！！！！！