blob: 8d87d8959e40d237f13da9e3c273cf36b1eee20f [file] [log] [blame]
stevenvanrossem2fdfbf42016-05-13 15:08:47 +02001"""
2Prometheus API helper functions
3(c) 2016 by Steven Van Rossem <steven.vanrossem@intec.ugent.be>
4"""
5
6import urllib2
7import ast
8
9prometheus_ip = '0.0.0.0'
10prometheus_port = '9090'
11prometheus_REST_api = 'http://{0}:{1}'.format(prometheus_ip, prometheus_port)
12
13
14def query_Prometheus(query):
15 url = prometheus_REST_api + '/' + 'api/v1/query?query=' + query
16 # logging.info('query:{0}'.format(url))
17 req = urllib2.Request(url)
18 ret = urllib2.urlopen(req).read()
19 ret = ast.literal_eval(ret)
20 if ret['status'] == 'success':
21 # logging.info('return:{0}'.format(ret))
22 try:
23 ret = ret['data']['result'][0]['value']
24 except:
25 ret = None
26 else:
27 ret = None
28 return ret