Task.py 文件源码

def kestel_info():
    MYSQL = Mysql.MYSQL(USER, PASSWORD, HOST, PORT, DB)
    cmd = "truncate table kestrel;"
    MYSQL.Run(cmd)
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    sock.connect(('172.16.16.50', 22222))
    INFOS = json.loads(sock.recv(86400))
    for key in INFOS:
        try:
            if 'kestrel_' in key:
                for ip_key in INFOS[key]:
                    if '172.16.' in ip_key:
                        ip = ip_key.split(':')[0]
                        ks = kestrel.Client(['%s:22133' % ip.strip()])
                        st = ks.stats()[1]['queues']
                        for k in st:
                            v = st[k]
                            data = (ip,'22133', str(k.replace("'", "")), str(v['items']))
                            cmd = "insert into kestrel (kestrel_ip,kestrel_port,kestrel_key,kestrel_num) values('%s',%s,'%s',%s);" % data
                            MYSQL.Run(cmd)
        except:
            continue