# coding: utf-8

import sys
from influxdb import InfluxDBClient


#return value
#ret, result_array, message
def tsg_influxb_query(influxdb_client, sql_str):
    try:
        result = influxdb_client.query(sql_str)
    except Exception as e:
        return 1, {}, e
        
    return 0, result.get_points(), "succ"

#return value:
#ret, client, error_msg
def tsg_influxdb_init(arg_host,arg_port,arg_username,arg_password,arg_db):
    try:
        influxdb_client = InfluxDBClient(host=arg_host,port=arg_port,username=arg_username,password=arg_password,database=arg_db, timeout=3) 
    except Exception as e:
        print("InfluxDBClient error: %s" %(e))
        return 1, None, e
    
    return 0, influxdb_client, "succ"

if __name__ == '__main__':
    ret, influxdb_client, msg = tsg_influxdb_init('127.0.0.1', 8086, 'admin', 'tsg2019', 'tsg_stat')
    if ret != 0:
        sys.exit(1)
        
    ret, points,msg = tsg_influxb_query(influxdb_client, "select * from interface order by time desc limit 1")
    if ret == 0:
        print("--for xxx in points:-----------------")
        for point in points:
            print("--------%s, %s" %(point['PhyRXBits'], point['PhyRXMissed']))

    else:
        print("query error, %s" %(res))