diff options
author | Kerim Gokarslan <kgokarsl@cisco.com> | 2017-09-13 20:26:01 -0700 |
---|---|---|
committer | ahothan <ahothan@cisco.com> | 2017-10-20 00:37:13 -0700 |
commit | f6a699e63dae2bb5779bd757dc62217193139ad9 (patch) | |
tree | 3073883ca7a8a771daeebbfef7f89dcc9f6f2753 /nfvbench/nfvbench.py | |
parent | d6d77669fcb13c779d869929a95ec9e9474b3fcf (diff) |
NFVBENCH-25 Send run results to fluentd
Change-Id: I671a9297b90784bc30eee48ea9244a9c63a24e85
Signed-off-by: Kerim Gokarslan <kgokarsl@cisco.com>
Diffstat (limited to 'nfvbench/nfvbench.py')
-rw-r--r-- | nfvbench/nfvbench.py | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/nfvbench/nfvbench.py b/nfvbench/nfvbench.py index 67b953f..920838a 100644 --- a/nfvbench/nfvbench.py +++ b/nfvbench/nfvbench.py @@ -127,9 +127,13 @@ class NFVBench(object): 'error_message': message } - def print_summary(self, result): - """Print summary of the result""" - summary = NFVBenchSummarizer(result) + def prepare_summary(self, result): + """Prepares summary of the result to print and send it to logger (eg: fluentd)""" + sender = FluentLogHandler("resultnfvbench", + fluentd_ip=self.config.fluentd.ip, + fluentd_port=self.config.fluentd.port) \ + if self.config.fluentd.logging_tag else None + summary = NFVBenchSummarizer(result, sender) LOG.info(str(summary)) def save(self, result): @@ -453,7 +457,7 @@ def main(): if opts.summary: with open(opts.summary) as json_data: - print NFVBenchSummarizer(json.load(json_data)) + print NFVBenchSummarizer(json.load(json_data), None) sys.exit(0) # show default config in text/yaml format @@ -539,7 +543,7 @@ def main(): if 'result' in result and result['status']: nfvbench.save(result['result']) - nfvbench.print_summary(result['result']) + nfvbench.prepare_summary(result['result']) except Exception as exc: run_summary_required = True LOG.error({ |