See which Droplets are running hot each week

import time
from clickruntime import on_trigger, credentials, http, notify

DO = "https://api.digitalocean.com/v2"

def do(method, path, **kwargs):
    resp = http.request(method, f"{DO}{path}", headers={"Authorization": f"Bearer {credentials.secret('DIGITALOCEAN_TOKEN')}"}, **kwargs)
    resp.raise_for_status()
    return resp.json() if resp.content else {}

def series(metric, host, **extra):
    end = int(time.time())
    result = do("GET", f"/monitoring/metrics/droplet/{metric}", params={"host_id": host, "start": end - 7 * 86400, "end": end, **extra})
    return [[float(v) for _, v in r["values"]] for r in result["data"]["result"]]

def avg(xs):
    return sum(xs) / len(xs) if xs else 0

@on_trigger
def run(event):
    lines = []
    for d in do("GET", "/droplets", params={"per_page": 200})["droplets"]:
        host = d["id"]
        idle = sum(s[-1] - s[0] for s in series("cpu", host, mode="idle"))
        cpu = max(0.0, 100 * (1 - idle / (7 * 86400 * d["vcpus"])))
        mem = 100 * (1 - avg(series("memory_available", host)[0]) / avg(series("memory_total", host)[0]))
        disk = 100 * (1 - avg(series("filesystem_free", host)[0]) / avg(series("filesystem_size", host)[0]))
        flag = " (HIGH)" if max(cpu, mem, disk) > 80 else ""
        lines.append(f"{d['name']}{flag}: CPU {cpu:.0f}%, memory {mem:.0f}%, disk {disk:.0f}%")
    notify.email_me("Droplet resources last week", "\n".join(lines))
    return {"droplets": len(lines)}