diff options
author | Mark Beierl <mark.beierl@dell.com> | 2017-08-23 16:54:40 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@opnfv.org> | 2017-08-23 16:54:40 +0000 |
commit | b6abf16908da2c30878f0a0de0e3ef198b8f712f (patch) | |
tree | b9ea14463956b39b3a2e5110e0b5a88ac435ade4 /docker/storperf-master/storperf/db/graphite_db.py | |
parent | 6ca2c9387c41a5980af0f0d5aa1d24cd6c7fa94d (diff) | |
parent | fc7ec1c0c73d2ecc52035634c8dd0ae6647273b1 (diff) |
Merge "Graphite Standalone container"
Diffstat (limited to 'docker/storperf-master/storperf/db/graphite_db.py')
-rw-r--r-- | docker/storperf-master/storperf/db/graphite_db.py | 31 |
1 files changed, 21 insertions, 10 deletions
diff --git a/docker/storperf-master/storperf/db/graphite_db.py b/docker/storperf-master/storperf/db/graphite_db.py index c8a2d35..aa71855 100644 --- a/docker/storperf-master/storperf/db/graphite_db.py +++ b/docker/storperf-master/storperf/db/graphite_db.py @@ -9,33 +9,44 @@ import json import logging - import requests -from storperf.db.job_db import JobDB - class GraphiteDB(object): + graphite_host = "storperf-graphite" + graphite_port = 8080 + def __init__(self): - """ - """ - self._job_db = JobDB() self.logger = logging.getLogger(__name__) + def fetch_item(self, target): + + result = None + request = ("http://%s:%s/graphite/render/?format=json&target=%s" + % (self.graphite_host, self.graphite_port, target)) + self.logger.debug("Calling %s" % (request)) + + response = requests.get(request) + if (response.status_code == 200): + result = json.loads(response.content) + + return result + def fetch_series(self, workload, metric, io_type, time, duration): series = [] end = time start = end - duration - request = ("http://127.0.0.1:8000/render/?target=" + request = ("http://%s:%s/graphite/render/?target=" "averageSeries(%s.*.jobs.1.%s.%s)" "&format=json" "&from=%s" - "&until=%s" % - (workload, io_type, metric, - start, end)) + "&until=%s" + % (self.graphite_host, self.graphite_port, + workload, io_type, metric, + start, end)) self.logger.debug("Calling %s" % (request)) response = requests.get(request) |