openstack/rally
Code Issues Proposed changes

Add display of atomic actions timer in CLI

Browse Source 
Added a prettytable that prints detailed information about the
execution time of each atomic action.

Implements: blueprint time-measuring-of-atomic-actions
(Part "II) CLI" of time-measuring-of-atomic-actions)

Change-Id: I1558d324a92063db3bd3d09d67b0635b93390107
This commit is contained in:
Pierre Padrixe 2014-01-31 15:53:48 +01:00
parent de636e7624
commit b5d24fb395
1 changed files with 21 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
rally/cmd/main.py
View File

@ -17,6 +17,7 @@
from __future__ import print_function from __future__ import print_function
import collections
import json import json
import os import os
import pprint import pprint
@ -228,6 +229,24 @@ class TaskCommands(object):
:param task_id: Task uuid :param task_id: Task uuid
Prints detailed information of task. Prints detailed information of task.
""" """
def _print_atomic_actions_time(raw):
atime_merged = []
for r in raw:
if 'atomic_actions_time' in r:
for a in r['atomic_actions_time']:
atime_merged.append(a)
times_by_action = collections.defaultdict(list)
for at in atime_merged:
times_by_action[at['action']].append(at['duration'])
if times_by_action:
atomic_action_table = prettytable.PrettyTable(
['action', 'max (sec)', 'avg (sec)', 'min (sec)'])
for k, v in times_by_action.iteritems():
atomic_action_table.add_row([k, max(v), sum(v) / len(v),
min(v)])
print(atomic_action_table)
print()
if task_id == "last": if task_id == "last":
task = db.task_get_detailed_last() task = db.task_get_detailed_last()
@ -258,10 +277,11 @@ class TaskCommands(object):
print(result["data"]["validation"]["exc_msg"]) print(result["data"]["validation"]["exc_msg"])
continue continue
_print_atomic_actions_time(result["data"]["raw"])
raw = result["data"]["raw"] raw = result["data"]["raw"]
times = map(lambda x: x['time'], times = map(lambda x: x['time'],
filter(lambda r: not r['error'], raw)) filter(lambda r: not r['error'], raw))
table = prettytable.PrettyTable(["max (sec)", "avg (sec)", table = prettytable.PrettyTable(["max (sec)", "avg (sec)",
"min (sec)", "success/total", "min (sec)", "success/total",
"total times"]) "total times"])