v1.3.py 文件源码

def analyseWarn(name,qname,topk=5):
    client = DataFrameClient(host='127.0.0.1', port=8086, username='root', password='root', database='testdb')
    query_positive = 'select * from ganglia where '+qname+' >0 ORDER BY time DESC limit 10'#??10??????
    query_negative = 'select * from ganglia where '+qname+' <0 ORDER BY time DESC limit 5'#????warnfactor??

    data_p = client.query(query_positive, chunked=False)
    data_positive = data_p['ganglia']
    normalSample = data_positive[name]#??????

    data_n = client.query(query_negative, chunked=False)
    data_negative = data_n['ganglia']
    anamolySample = data_negative[name]#??????
    return analyseReasonWithTreeBaesd(anamolySample, normalSample, name)