python代码获取zabbix上机器磁盘使用率

1.需要先给机器打上标记os_type: Linux或者os_type: Windows
在这里插入图片描述
2.代码请求获取数据：

先装一下相关的数据包 pip install pyzabbix

from pyzabbix import ZabbixAPI
import requests
import urllib3
import concurrent.futuresclass ZabbixInfo():def __init__(self, zabbix_server, zabbix_user, zabbix_password):self.zabbix_server = zabbix_serverself.zabbix_user = zabbix_userself.zabbix_password = zabbix_passworddef get_hosts_disk_space_utilization(zabbix_info: ZabbixInfo):host_disks_data_list = []session = requests.Session()# 忽略 SSL 验证的设置session.verify = Falseurllib3.disable_warnings(urllib3.exceptions.InsecureRequestWarning)# 连接到 Zabbix APIzapi = ZabbixAPI(zabbix_info.zabbix_server, session=session)zapi.login(zabbix_info.zabbix_user, zabbix_info.zabbix_password)# 获取所有主机hosts = zapi.host.get(output=['hostid', 'name'], selectInterfaces=['interfaceid', 'ip'], selectTags='extend',selectParentTemplates=['templateid', 'name'])# 多线程处理获取数据功能with concurrent.futures.ThreadPoolExecutor() as executor:# 提交任务并获取 Future 对象futures = [executor.submit(get_host_disk_info, host, zapi)for host in hosts]# 收集所有返回值for future in concurrent.futures.as_completed(futures):host_disks_data_list.append(future.result())zapi.user.logout()return host_disks_data_listdef get_host_disk_info(host, zapi):hostid = host['hostid']# hostname = host['name']host_ip = host['interfaces'][0]['ip']host_disk_info_list = []tags = host.get('tags', [])os_type = 'Linux'# 默认是 Linux,获取机器的类型for tag in tags:if tag['tag'] == 'os_type' and tag['value'] == 'Windows':os_type = 'Windows'breakdiskset = set()# 获取机器的磁盘列表# lld_items = zapi.discoveryrule.get(#     hostids=hostid, search={'key_': 'vfs.fs.discovery'}, output=['itemid', 'name'])# for lld_item in lld_items:lld_results = zapi.item.get(hostids=hostid, output=['itemid', 'name', 'key_', 'lastvalue'])for result in lld_results:if 'vfs.fs.size' in result['key_']:fsname = result['key_'].split('[')[1].split(',')[0]# print(f"Host: {hostname} - OS: {os_type} - Filesystem: {fsname}")# 提取文件系统名称if 'Windows' == os_type or ('Linux' == os_type and str(fsname).startswith('/net') and str(fsname).endswith('/fs0')):diskset.add(fsname)# 多线程处理获取disk实际数据功能host_data_dict = {}with concurrent.futures.ThreadPoolExecutor() as executor:# 提交任务并获取 Future 对象futures = [executor.submit(do_get_disk_info, host_disk_info_list, disk, hostid, zapi) for disk in diskset]# 收集所有返回值for future in concurrent.futures.as_completed(futures):host_data_dict = {host_ip: future.result()}return host_data_dictdef do_get_disk_info(host_disk_info_list, disk, hostid, zapi):oid = 'vfs.fs.size[%s,pused]' % diskitems = zapi.item.get(hostids=hostid, search={'key_': oid}, output=['itemid', 'name', 'lastvalue'])if items:for item in items:# print(f"Host: {hostname} ({os_type}) - Item: {item['name']} - Last Value: {item['lastvalue']}")# print(#     f"Host: {hostname} ({os_type}) - {item['name']}: {item['lastvalue']}")host_disk_info_list.append({item['name']: item['lastvalue']})return host_disk_info_listif __name__ == "__main__":zabbix_info_list = []zabbix_disk_info_list = []zabbix_info_list.append(ZabbixInfo('http://xxxxxxxxxx',  'username', 'password'))zabbix_info_list.append(ZabbixInfo('http://xxxxxxxxxxxxxx',  'username', 'password'))for zabbix in zabbix_info_list:zabbix_disk_info_list.append(get_hosts_disk_space_utilization(zabbix))for item in zabbix_disk_info_list:print(item)