Shulou(Shulou.com)06/03 Report--

Realization idea

The api of zabbix is mainly used to obtain and process the data, and the implementation ideas are as follows:

Zabbix provides rich api, which can be used to obtain the host information of zabbix, the ID of monitoring items, the trend data and historical data of monitoring items. First, all the host information in the group is obtained according to the host group ID, including the host name and IP address cycle host ID. And then nest a request to obtain the monitoring item ID according to the key value of the monitoring item in the loop, according to the obtained monitoring item ID to obtain the historical data and trend data respectively, write the values of the historical data and trend data into a dictionary, and add all the dictionaries after the loop to the list and write the information in the list to the Excel. Time interval x = (datetime.datetime.now ()-datetime.timedelta (minutes=120)) .strftime ("% Y-%m-%d% H:%M:%S") y = (datetime.datetime.now ()) .strftime ("% Y-%m-%d% H:%M:%S") def timestamp (xMague y): p=time.strptime (x "% Y-%m-%d% H:%M:%S") starttime = str (int (time.mktime (p) q=time.strptime (y, "% Y-%m-%d% H:%M:%S") endtime= str (int (time.mktime (Q) return starttime,endtime obtains host information based on host group ID def get_hosts (groupids,auth): data = {"jsonrpc": "2.0" "method": "host.get", "params": {"output": ["name"], "groupids": groupids, "filter": {"status": "0"} "selectInterfaces": [ip "],}," auth ": auth, # theauth id is what auth script returns, remeber it is string" id ": 1} gethost=requests.post (url=ApiUrl,headers=header Json=data) return json.loads (gethost.content) ["result"] builds a loop based on the obtained host information Get the data of the host monitoring item and obtain the historical data host= [] print (hosts) for i in hosts: item1= [] item2= [] # print (I) dic1= {} for j in ['vfs.fs.size],' vm.history.size [total], 'system.cpu.num']: data= {"jsonrpc": "2.0" "method": "item.get", "params": {"output": ["itemid"], "search": {"key_": J} "hostids": I ['hostid']}, "auth": auth, "id": 1} getitem=requests.post (url=ApiUrl,headers=header,json=data) item=json.loads (getitem.content) [' result'] hisdata= {"jsonrpc": "2.0" "method": "history.get", "params": {"output": "extend", "time_from": timestamp [0], # "time_till": timestamp [1], "history": 0 "sortfield": "clock", "sortorder": "DESC", "itemids":'% s'% (item [0] ['itemid']), "limit": 1}, "auth": auth "id": 1} gethist=requests.post (url=ApiUrl,headers=header,json=hisdata) hist=json.loads (gethist.content) ['result'] item1.append (hist) get trend data for j in [' vfs.fs.size [Cruise used]', 'vm.roomy.sizeused]' 'system.cpu.load']: data= {"jsonrpc": "2.0"," method ":" item.get "," params ": {" output ": [" itemid "] "search": {"key_": J}, "hostids": I ['hostid']}, "auth": auth, "id": 1} getitem=requests.post (url=ApiUrl,headers=header) Json=data) item=json.loads (getitem.content) ['result'] trendata= {"jsonrpc": "jsonrpc", "method": "trend.get", "params": {"output": ["itemid", "value_max" "value_avg"], "time_from": timestamp [0], "time_till": timestamp [1], "itemids":'% s'% (item [0] ['itemid']) "limit": 1}, "auth": auth, "id": 1} gettrend=requests.post (url=ApiUrl,headers=header,json=trendata) trend=json.loads (gettrend.content) ['result'] item2.append (trend) to process the acquired data And exported to the csv file dic1 ['Hostname'] = I [' name'] dic1 ['IP'] = I [' interfaces'] [0] ['ip'] dic1 [' disk C:Total (B)'] = round (float (item1 [0] [0] ['value']) / 1024 disk C:Used 2) dic1 [' disk maximum C:Used (B)'] = round (float (item2 [0] [0] [0] ['value_max') ) dic1 ['memory Total (B)'] = round (float (item1 [1] [0] ['value']) / 1024 memory 3) dic1 [' memory maximum Used (B)'] = round (float (item2 [1] [0] ['value_max']) / 1024 memory 3) dic1 [' memory average used (B)'] = round (float (item2 [1] [0] ['value_]) Avg']) dic1 ['CPU load maximum'] = item2 [2] [0] ['value_max'] dic1 [' CPU load average'] = item2 [2] [0] ['value_avg'] dic1 [' CPU Kernel'] = item1 [2] [0] ['value'] x = time.localtime (int (item1 [2] [0] [' clock'])) Item1 [2] [0] ['clock'] = time.strftime ("% Y-%m-%d% H:%M:%S" X) dic1 ['clock'] = item1 [2] [0] [' clock'] host.append (dic1) print (item) print (host) return host def writecsv (getitem1): with open ('data.csv','w',encoding='utf-8-sig') as f: # f.write (codecs.BOM_UTF8) writer = csv.DictWriter (f) Csvheader) writer.writeheader () for row in getitem1: writer.writerow (row) is as follows:

The complete code can access the github address: "https://github.com/sunsharing-note/zabbix/blob/master/xunjian_auto.py"

Zabbix API address: https://www.zabbix.com/documentation/4.0/zh/manual/api/reference/history/get

Welcome to your personal account "Master Chen without Story"

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.