Print Summary

1"""Print a concise APM trace summary: services, slowest spans, errors.
2
3Usage:
4  python3 scripts/print_summary.py FILE
5
6Env vars:
7  MAX_LEN  — truncation limit for span names (default 100, 0 = unlimited)
8"""
9
10import os
11import sys
12
13from _common import SPAN_KIND, fmt_duration, is_root, load_trace_file, truncate
14
15
16max_len = int(os.environ.get("MAX_LEN", "100"))
17
18spans = load_trace_file(sys.argv[1])
19if not spans:
20    print("No spans in payload.", file=sys.stderr)
21    sys.exit(1)
22
23trace_id = spans[0].get("trace_id", "?")
24
25# Bucket spans by service and kind, find roots, slowest, errors.
26services = {}  # name -> count
27kinds = {}  # int -> count
28roots = []
29errors = []
30for span in spans:
31    svc = span.get("service_name", "?")
32    services[svc] = services.get(svc, 0) + 1
33    k = span.get("kind")
34    kinds[k] = kinds.get(k, 0) + 1
35    if is_root(span):
36        roots.append(span)
37    if span.get("status_code") == 2:
38        errors.append(span)
39
40slowest = sorted(spans, key=lambda s: int(s.get("duration_nano") or 0), reverse=True)[:5]
41
42print("=" * 80)
43print("APM TRACE SUMMARY")
44print("=" * 80)
45print(f"  Trace ID:    {trace_id}")
46print(f"  Span count:  {len(spans)}")
47print(f"  Services:    {', '.join(f'{n} ({c})' for n, c in sorted(services.items(), key=lambda x: -x[1]))}")
48print(f"  Span kinds:  {', '.join(f'{SPAN_KIND.get(k, k)}={c}' for k, c in sorted(kinds.items()))}")
49print(f"  Root spans:  {len(roots)}")
50print(f"  Errors:      {len(errors)}")
51
52if roots:
53    print()
54    print("--- ROOT SPAN(S) ---")
55    for r in roots:
56        name = truncate(r.get("name", "?"), max_len)
57        print(f"  [{r.get('service_name', '?')}] {name}  ({fmt_duration(r.get('duration_nano'))})")
58        print(f"    span_id={r.get('span_id', '?')}  ts={r.get('timestamp', '?')}")
59
60print()
61print("--- TOP-5 SLOWEST SPANS ---")
62for span in slowest:
63    name = truncate(span.get("name", "?"), max_len)
64    err = " [ERROR]" if span.get("status_code") == 2 else ""
65    print(f"  [{span.get('service_name', '?')}] {name}  ({fmt_duration(span.get('duration_nano'))}){err}")
66    print(f"    kind={SPAN_KIND.get(span.get('kind'), span.get('kind'))}  span_id={span.get('span_id', '?')}")
67
68if errors:
69    print()
70    print("!" * 80)
71    print(f"ERROR SPANS ({len(errors)})")
72    print("!" * 80)
73    for span in errors:
74        name = truncate(span.get("name", "?"), max_len)
75        print(f"  [{span.get('service_name', '?')}] {name}  ({fmt_duration(span.get('duration_nano'))})")
76        print(f"    kind={SPAN_KIND.get(span.get('kind'), span.get('kind'))}  span_id={span.get('span_id', '?')}  parent={span.get('parent_span_id', '?')}")
77    print()
78    print("Error detail (exception.message/type) is in each span's `attributes` map in the payload — read it off the error span.")