Infrastructure/ansible
5
0
Fork 0
Code Issues Pull requests 3 Projects Releases Packages Wiki Activity Actions

logview: reformat output

Browse source 
Signed-off-by: Francois Andrieu <darknao@fedoraproject.org>
This commit is contained in:
Francois Andrieu 2020-08-16 22:37:49 +02:00
parent 71c8cedc00
commit 6d1d72ee20
1 changed files with 70 additions and 17 deletions
Download patch file Download diff file Expand all files Collapse all files

87
scripts/logview
View file

@ -1,4 +1,4 @@
#!/usr/bin/python3
#!/usr/bin/python
# vim: et ts=4 ai sw=4 sts=0
import sys
import json
@ -19,6 +19,34 @@ date_terms = {
"yesterday": lambda: date.today() - timedelta(1),
}
class bcolors:
BLUE = '\033[94m'
GREEN = '\033[92m'
WARNING = '\033[93m'
FAIL = '\033[91m'
ENDC = '\033[0m'
ERROR = '\033[41m'
WHITE = '\033[00m'
def format_state(category, txt=None):
if not txt:
txt = category
if category == "OK":
color_out = bcolors.GREEN + txt + bcolors.ENDC
elif category == "FAILED":
color_out = bcolors.FAIL + txt + bcolors.ENDC
elif category == "CHANGED":
color_out = bcolors.WARNING + txt + bcolors.ENDC
elif category == "SKIPPED":
color_out = bcolors.BLUE + txt + bcolors.ENDC
elif category == "UNREACHABLE":
color_out = bcolors.ERROR + txt + bcolors.ENDC
else:
color_out = bcolors.WHITE + txt + bcolors.ENDC
return color_out
def parse_info(infofile):
data = {}
with open(infofile) as f:
@ -53,12 +81,12 @@ def parse_args(args):
logview -s ANY -d yesterday -p mirrorlist # list all events from the mirrorlist playbook
"""
parser = OptionParser(usage=usage)
parser.add_option("-d", default='today', dest='datestr', help="time string of when you want logs")
parser.add_option("-p", default='*', dest='playbook', help="the playbook you want to look for")
parser.add_option("-H", default=[], dest='hostname', action='append', help="Limit to the specified hostname")
parser.add_option("-m", default=False, dest='message', action='store_true', help='Show tasks output')
parser.add_option("-v", default=False, dest='verbose', action='store_true', help='Verbose')
parser.add_option("-s", default=[], dest='search_terms', action='append', help="status to search for")
parser.add_option("-l", default=False, dest="list_pb", action='store_true', help="list playbooks for a specific date")
@ -83,7 +111,7 @@ def search_logs(opts, logfiles):
try:
with gzip.open(fn) as f:
f.read()
f.read()
open_f = gzip.open(fn, "rt")
except:
open_f = open(fn)
@ -93,40 +121,65 @@ def search_logs(opts, logfiles):
if len(things) < 5:
msg += "(logview error - unhandled line): %r\n" % line
continue
# See callback_plugins/logdetail.py for how these lines get created.
# MSG_FORMAT="%(now)s\t%(count)s\t%(category)s\t%(name)s\t%(data)s\n"
task_ts, count, category, name, data = things
if category in opts.search_terms or 'ANY' in opts.search_terms:
dur = None
slurp = json.loads(data)
if opts.profile:
st = slurp.get('task_start', 0)
end = slurp.get('task_end', 0)
if st and end:
dur = '%.2f' % (float(end) - float(st))
else:
dur = None
dur = '%.2fs' % (float(end) - float(st))
state = format_state(category)
c_hostname = format_state(category, hostname)
msg += '%s\t%s\t%s\t%s\t%s\t%s' % (
timestamp, hostname, task_ts, count, category, name)
if category == "STATS":
if type(slurp) == dict:
# ok=2 changed=0 unreachable=0 failed=1 skipped=0 rescued=0 ignored=0
name = 'o:%s c:%s u:%s f:%s s:%s r:%s i:%s' % (
slurp.get("ok", 0),
slurp.get("changed", 0),
slurp.get("unreachable", 0),
slurp.get("failures", 0),
slurp.get("skipped", 0),
slurp.get("rescued", 0),
slurp.get("ignored", 0))
if not name:
name = slurp.get("task_module")
msg += '{0: <10} {1: <30} {2: <22} {3: <4} {4: <25}'.format(
timestamp, c_hostname, task_ts, count, state)
if dur:
msg += ' {0: <8}'.format(dur,)
if name:
msg += ' %s' % (name,)
if not opts.verbose:
if type(slurp) == dict:
for term in ['task_userid', 'cmd']:
for term in ['cmd',]:
if term in slurp:
msg += '\t%s:%s' % (term, slurp.get(term, None))
if opts.profile and dur:
msg += '\t%s:%s' % ('dur', dur)
if opts.message:
for term in ['msg',]:
if term in slurp:
value = slurp.get(term, None).strip()
if value:
msg += '\n%s: %s\n' % (term, format_state(category, value))
msg += '\n'
else:
if opts.profile and dur:
msg += '\t%s:%s' % ('dur', dur)
msg += '\n'
msg += json.dumps(slurp, indent=4)
msg += '\n'
return msg