利用zabbix API 统计一段时间内监控项的均值和峰值

#coding:utf-8
#给定主机IP获取一段时间内cpu的均值和峰值并写入文件(txt，可以跑完后直接把后缀名改为csv以表格形式打开)；需要指定IP文件
import requests
import json
import csv
import time

def get_token():
    data = {
        "jsonrpc": "2.0",
        "method": "user.login",
        "params": {
            "user": username,
            "password": password
        },
        "id": 0
    }
    r = requests.get(zaurl, headers=header, data=json.dumps(data))
    auth = json.loads(r.text)
    return auth["result"]

def item_get(token, host, itemkey):
    data = {
        "jsonrpc": "2.0",
        "method": "item.get",
        "params": {
            "host": host,
            "search": {
                "key_": itemkey
            },
        },
        "auth": token,
        "id": 1
    }

    request = requests.post(zaurl, data=json.dumps(data), headers=header)
    dict = json.loads(request.content)
#    print(dict)
    return dict['result'][0]['itemid']

def getdata(token,itemid, start, stop):
    data = {
        "jsonrpc": "2.0",
        "method": "history.get",
        "params": {
            "output": "extend",
            "itemids": itemid,
            "history": 0,
            "time_from":start,
            "time_till":stop
        },
        "id": 2,
        "auth": token,

    }
    request = requests.post(zaurl, headers=header, data=json.dumps(data))
    dict = json.loads(request.content)
    print(dict)
    return dict['result']

def timecovert(stringtime):
    timeArray = time.strptime(stringtime, "%Y-%m-%d %H:%M:%S")
    timeStamp = int(time.mktime(timeArray))
    return timeStamp



if __name__ == "__main__":
    zaurl = "http://xx.xx.xx.xx/zabbix/api_jsonrpc.php"
    header = {"Content-Type": "application/json"}
    username = "xxxx"
    password = "xxxx"
    hostfile="ip.txt"
    token = get_token()
    starttime = "2019-10-27 00:00:00"
    stoptime = "2019-10-29 00:00:00"
    start = timecovert(starttime)
    stop = timecovert(stoptime)
#生成一个txt文件
    datafile = "D:生产工作IP\data.txt"
    fdata = open(datafile,'w')
    with open(hostfile, "r") as f:
        f1 = f.readlines()
        for ips in f1:
            host = ips.replace('
', '').strip()
            # 修改参数
#以下例子为cpu
            itemkey = "system.cpu.util[,user]"]"
            itemid = item_get(token, host, itemkey)
            data = getdata(token,itemid,start,stop)
            if data:
                valuelist = []
                for i in data:
                    valuelist.append(float(i["value"]))
                avge = sum(valuelist)/len(valuelist)
                max1 = max(valuelist)
                fdata.write(host + ',' + str(round(avge,2)) + ',' + str(round(max1,2)) + '
')
#                print (host, avge, max1)
            else:
                print (host)
    fdata.close()