From b3c9dda57fa913cd2ac75a8c70ff7679046852a0 Mon Sep 17 00:00:00 2001 From: cybermaggedon Date: Sat, 3 May 2025 10:45:42 +0100 Subject: [PATCH] Fix broken build (#359) --- .../scripts/tg-show-processor-state | 55 +++++++++++++++++++ 1 file changed, 55 insertions(+) create mode 100755 trustgraph-cli/scripts/tg-show-processor-state diff --git a/trustgraph-cli/scripts/tg-show-processor-state b/trustgraph-cli/scripts/tg-show-processor-state new file mode 100755 index 00000000..7f142174 --- /dev/null +++ b/trustgraph-cli/scripts/tg-show-processor-state @@ -0,0 +1,55 @@ +#!/usr/bin/env python3 + +""" +Dump out TrustGraph processor states. +""" + +import requests +import argparse + +default_metrics_url = "http://localhost:8088/api/metrics" + +def dump_status(url): + + url = f"{url}/query?query=processor_info" + + resp = requests.get(url) + + obj = resp.json() + + tbl = [ + [ + m["metric"]["job"], + "\U0001f49a" + ] + for m in obj["data"]["result"] + ] + + for row in tbl: + print(f" {row[0]:30} {row[1]}") + +def main(): + + parser = argparse.ArgumentParser( + prog='tg-processor-state', + description=__doc__, + ) + + parser.add_argument( + '-m', '--metrics-url', + default=default_metrics_url, + help=f'Metrics URL (default: {default_metrics_url})', + ) + + args = parser.parse_args() + + try: + + dump_status(args.metrics_url) + + except Exception as e: + + print("Exception:", e, flush=True) + +main() +