Get a weekly email of new users by source

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

def amp(path, **params):
    auth = (credentials.secret("AMPLITUDE_API_KEY"), credentials.secret("AMPLITUDE_SECRET_KEY"))
    resp = http.get(f"https://amplitude.com/api/2/{path}", auth=auth, params=params)
    resp.raise_for_status()
    return resp.json()["data"]

def by_source(start, end):
    e = {"event_type": "_new", "group_by": [{"type": "user", "value": "utm_source"}]}
    data = amp("events/segmentation", e=json.dumps(e), start=start.strftime("%Y%m%d"),
               end=end.strftime("%Y%m%d"), m="uniques", i=7)
    return {label[1] if isinstance(label, list) else label: sum(series)
            for label, series in zip(data["seriesLabels"], data["series"])}

@on_trigger
def run(event):
    end = date.today() - timedelta(days=date.today().weekday() + 1)
    this, prev = by_source(end - timedelta(days=6), end), by_source(end - timedelta(days=13), end - timedelta(days=7))
    lines = [f"{src or '(none)'}: {n:,} ({n - prev.get(src, 0):+,})" for src, n in sorted(this.items(), key=lambda kv: -kv[1])]
    notify.email_me("New users by UTM source, last week", "\n".join(lines))
    return {"sources": len(lines)}