mrcharles
ba4463c4d0
kuma-inventory.py printed the junk url field (https://) instead of the hostname for ping monitors — hid ~100 monitors from FQDN matching. kuma-add-ping.py: idempotent ping-monitor adds (exists-check by name and target). Matrix published to Discourse t/309 (canonical, #343). Detail: https://projects.knownelement.com/issues/343
92 lines
3.1 KiB
Python
92 lines
3.1 KiB
Python
#!/usr/bin/env python3
|
|
"""kuma-inventory.py — read-only Uptime Kuma monitor inventory dump [#435]
|
|
|
|
Connects via the socket.io API (same pattern as kuma-fleet-sync.py) and
|
|
prints every monitor with id, type, parent (group), name, target, active
|
|
state. Read-only: emits nothing back to the server. Used to plan group
|
|
placement and coverage gaps; never mutates.
|
|
|
|
Env (from ~/.creds/uptime-kuma.env):
|
|
UPTIME_KUMA_URL, UPTIME_KUMA_TOKEN
|
|
|
|
Usage:
|
|
python3 kuma-inventory.py # TSV dump: id<TAB>parent<TAB>type<TAB>active<TAB>name<TAB>target
|
|
python3 kuma-inventory.py --summary # group counts + root-level offenders only
|
|
"""
|
|
import argparse
|
|
import os
|
|
import time
|
|
|
|
import socketio
|
|
|
|
|
|
def kuma_connect():
|
|
sio = socketio.Client(reconnection=False)
|
|
state = {}
|
|
|
|
@sio.on("monitorList")
|
|
def _ml(d):
|
|
state["ml"] = d
|
|
|
|
sio.connect(
|
|
os.environ["UPTIME_KUMA_URL"], transports=["websocket"], wait_timeout=30
|
|
)
|
|
r = sio.call("loginByToken", os.environ["UPTIME_KUMA_TOKEN"], timeout=30)
|
|
if not (isinstance(r, dict) and r.get("ok")):
|
|
raise SystemExit(f"login failed: {r}")
|
|
sio.emit("monitorList")
|
|
for _ in range(20):
|
|
if "ml" in state:
|
|
break
|
|
time.sleep(1)
|
|
return sio, state.get("ml", {})
|
|
|
|
|
|
def main():
|
|
ap = argparse.ArgumentParser()
|
|
ap.add_argument("--summary", action="store_true")
|
|
args = ap.parse_args()
|
|
|
|
sio, mons = kuma_connect()
|
|
try:
|
|
by_id = {str(m.get("id")): m for m in mons.values()}
|
|
|
|
def name_of(mid):
|
|
m = by_id.get(str(mid))
|
|
return (m.get("name") or "?") if m else f"id{mid}"
|
|
|
|
rows = []
|
|
for m in mons.values():
|
|
mid = m.get("id")
|
|
parent = m.get("parent") or m.get("parent_id") or ""
|
|
parent = name_of(parent) if parent not in ("", None) else "-"
|
|
mtype = m.get("type") or "?"
|
|
active = "on" if m.get("active", True) else "PAUSED"
|
|
name = (m.get("name") or "?").replace("\t", " ")
|
|
# hostname first: ping monitors carry a junk default url ("https://")
|
|
target = m.get("hostname") or m.get("url") or ""
|
|
target = str(target).replace("\t", " ")
|
|
rows.append((mid, parent, mtype, active, name, target))
|
|
rows.sort(key=lambda r: (r[1] == "-", r[1], r[4].lower()))
|
|
|
|
if args.summary:
|
|
groups = [r for r in rows if r[2] == "group"]
|
|
root = [r for r in rows if r[1] == "-" and r[2] != "group"]
|
|
print(f"total monitors: {len(rows)} groups: {len(groups)} root-level: {len(root)}")
|
|
print("\ngroups:")
|
|
for r in groups:
|
|
kids = sum(1 for x in rows if x[1] == r[4])
|
|
print(f" {r[4]} ({kids} children, id={r[0]})")
|
|
print("\nroot-level monitors (must move into groups):")
|
|
for r in root:
|
|
print(f" id={r[0]} [{r[2]}] {r[3]} {r[4]} {r[5]}")
|
|
else:
|
|
for r in rows:
|
|
print("\t".join(str(c) for c in r))
|
|
finally:
|
|
sio.disconnect()
|
|
|
|
|
|
if __name__ == "__main__":
|
|
main()
|