blob: 82fa5bdc3b01e99496d6ea3a21a732b5884c01b0 [file] [log] [blame]
peusterm72f09882018-05-15 17:10:27 +02001# Copyright (c) 2015 SONATA-NFV and Paderborn University
2# ALL RIGHTS RESERVED.
3#
4# Licensed under the Apache License, Version 2.0 (the "License");
5# you may not use this file except in compliance with the License.
6# You may obtain a copy of the License at
7#
8# http://www.apache.org/licenses/LICENSE-2.0
9#
10# Unless required by applicable law or agreed to in writing, software
11# distributed under the License is distributed on an "AS IS" BASIS,
12# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13# See the License for the specific language governing permissions and
14# limitations under the License.
15#
16# Neither the name of the SONATA-NFV, Paderborn University
17# nor the names of its contributors may be used to endorse or promote
18# products derived from this software without specific prior written
19# permission.
20#
21# This work has been performed in the framework of the SONATA project,
22# funded by the European Commission under Grant number 671517 through
23# the Horizon 2020 and 5G-PPP programmes. The authors would like to
24# acknowledge the contributions of their colleagues of the SONATA
25# partner consortium (www.sonata-nfv.eu).
stevenvanrossem1a6843a2016-05-19 12:19:36 +020026import requests
stevenvanrosseme131bf52016-07-14 11:42:09 +020027
stevenvanrossem2fdfbf42016-05-13 15:08:47 +020028
stevenvanrossem48db0512016-05-18 15:43:24 +020029# set this to localhost for now
30# this is correct for son-emu started outside of a container or as a container with net=host
peusterm72f09882018-05-15 17:10:27 +020031# TODO if prometheus sdk DB is started outside of emulator, place these
32# globals in an external SDK config file?
stevenvanrosseme131bf52016-07-14 11:42:09 +020033prometheus_ip = 'localhost'
34# when sdk is started with docker-compose, we could use
35# prometheus_ip = 'prometheus'
stevenvanrossem2fdfbf42016-05-13 15:08:47 +020036prometheus_port = '9090'
37prometheus_REST_api = 'http://{0}:{1}'.format(prometheus_ip, prometheus_port)
38
39
40def query_Prometheus(query):
41 url = prometheus_REST_api + '/' + 'api/v1/query?query=' + query
42 # logging.info('query:{0}'.format(url))
stevenvanrossem1a6843a2016-05-19 12:19:36 +020043 req = requests.get(url)
stevenvanrossem1a6843a2016-05-19 12:19:36 +020044 ret = req.json()
stevenvanrossem2fdfbf42016-05-13 15:08:47 +020045 if ret['status'] == 'success':
46 # logging.info('return:{0}'.format(ret))
47 try:
48 ret = ret['data']['result'][0]['value']
peusterm72f09882018-05-15 17:10:27 +020049 except BaseException:
stevenvanrossem2fdfbf42016-05-13 15:08:47 +020050 ret = None
51 else:
52 ret = None
peusterm72f09882018-05-15 17:10:27 +020053 return ret