kubestat.py 文件源码

def _query(query_str):
    url = 'http://{host}:{port}/query' \
        .format(host=settings.INFLUXDB_HOST,
                port=settings.INFLUXDB_PORT)
    params = {
        'q': query_str,
        'chunked': 'false',
        # 'epoch': 's',
        'db': settings.INFLUXDB_DATABASE,
        'u': settings.INFLUXDB_USER,
        'p': settings.INFLUXDB_PASSWORD
    }
    try:
        r = requests.get(
            url=url,
            params=params
        )
        return r.json()
    except requests.ConnectionError as e:
        raise InfluxDBConnectionError(e), None, sys.exc_info()[2]
    except ValueError as e:
        raise InfluxDBUnexpectedAnswer(e), None, sys.exc_info()[2]