Get a weekly Cloudflare traffic report

from datetime import date, timedelta
from clickruntime import on_trigger, credentials, http, notify

CF = "https://api.cloudflare.com/client/v4"

def cf(path, **params):
    resp = http.get(f"{CF}{path}", params=params, headers={"Authorization": f"Bearer {credentials.secret('CLOUDFLARE_API_TOKEN')}"})
    resp.raise_for_status()
    return resp.json()["result"]

ZONES = ["example.com", "shop.example.com"]
QUERY = """query($zone: String!, $from: Date!, $to: Date!) { viewer { zones(filter: {zoneTag: $zone}) {
  httpRequests1dGroups(limit: 7, filter: {date_geq: $from, date_lt: $to}) { sum { requests bytes threats } } } } }"""

def week(zone_id, end):
    body = {"query": QUERY, "variables": {"zone": zone_id, "from": str(end - timedelta(days=7)), "to": str(end)}}
    resp = http.post(f"{CF}/graphql", json=body, headers={"Authorization": f"Bearer {credentials.secret('CLOUDFLARE_API_TOKEN')}"})
    days = resp.json()["data"]["viewer"]["zones"][0]["httpRequests1dGroups"]
    return {k: sum(d["sum"][k] for d in days) for k in ("requests", "bytes", "threats")}

@on_trigger
def run(event):
    today, lines = date.today(), []
    for name in ZONES:
        zone_id = cf("/zones", name=name)[0]["id"]
        cur, prev = week(zone_id, today), week(zone_id, today - timedelta(days=7))
        pct = lambda k: f"{(cur[k] - prev[k]) / prev[k] * 100:+.0f}%" if prev[k] else "n/a"
        lines.append(f"{name}: {cur['requests']:,} requests ({pct('requests')}), {cur['bytes'] / 1e9:.1f} GB ({pct('bytes')}), "
                     f"{cur['threats']:,} threats ({pct('threats')})")
    notify.email_me("Cloudflare traffic last week", "\n".join(lines))
    return {"zones": len(lines)}