Get a weekly website report in Telegram

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

CHAT_ID = "123456789"

def tg(method, **params):
    r = http.post(f"https://api.telegram.org/bot{credentials.secret('TELEGRAM_BOT_TOKEN')}/{method}", json=params)
    return r.raise_for_status() or r.json()["result"]

PROPERTY = "123456789"

def ga(body):
    url = f"https://analyticsdata.googleapis.com/v1beta/properties/{PROPERTY}:runReport"
    return http.post(url, headers={"Authorization": f"Bearer {credentials.connection('google', 'work')}"}, json=body).json().get("rows", [])

WEEKS = [{"startDate": "7daysAgo", "endDate": "yesterday"}, {"startDate": "14daysAgo", "endDate": "8daysAgo"}]

def top(dim):
    rows = ga({"dateRanges": WEEKS, "dimensions": [{"name": dim}], "metrics": [{"name": "sessions"}],
               "orderBys": [{"metric": {"metricName": "sessions"}, "desc": True}], "limit": 10})
    return "\n".join(f"{r['dimensionValues'][0]['value']} [{r['dimensionValues'][1]['value']}]: {r['metricValues'][0]['value']}" for r in rows)

@on_trigger
def run(event):
    totals = ga({"dateRanges": WEEKS, "metrics": [{"name": "totalUsers"}, {"name": "sessions"}]})
    data = "Totals (users, sessions):\n" + "\n".join(", ".join(v["value"] for v in r["metricValues"]) for r in totals)
    data += f"\n\nSources:\n{top('sessionSource')}\n\nPages:\n{top('pagePath')}"
    report = ai.generate(data, system="date_range_0 is last week, date_range_1 the week before. Write a 8-line Telegram report: "
                         "totals with % change, top movers among sources and pages, one suggestion.", max_output_tokens=400).text
    tg("sendMessage", chat_id=CHAT_ID, text=report)
    notify.email_me("Website last week", report)
    return {"sent": True}