Log daily website KPIs and get alerted when one drops

from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from datetime import date, timedelta
from clickruntime import on_trigger, http, credentials, ai, notify

def api(name, version):
    return build(name, version, credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)

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", [])

SHEET_ID = "your-spreadsheet-id"
METRICS = ["sessions", "conversions", "purchaseRevenue"]

@on_trigger
def run(event):
    r = ga({"dateRanges": [{"startDate": "yesterday", "endDate": "yesterday"}], "metrics": [{"name": m} for m in METRICS]})
    today, drops = [float(v["value"]) for v in r[0]["metricValues"]] if r else [0.0] * 3, []
    sheet = api("sheets", "v4").spreadsheets().values()
    past = sheet.get(spreadsheetId=SHEET_ID, range="KPIs!A2:D").execute().get("values", [])[-7:]
    sheet.append(spreadsheetId=SHEET_ID, range="KPIs!A:D", valueInputOption="RAW", body={"values": [[(date.today() - timedelta(days=1)).isoformat()] + today]}).execute()
    for i, name in enumerate(METRICS):
        if (avg := sum(float(row[i + 1]) for row in past) / len(past) if past else 0) and today[i] < avg * 0.75:
            drops.append(f"{name}: {today[i]:,.0f} vs 7-day average {avg:,.0f} ({(today[i] - avg) / avg * 100:.0f}%)")
    if not drops:
        return {"alerts": 0}
    text = "\n".join(drops)
    try: text += "\n\n" + ai.generate(text, system="Give the most likely reason for these drops in 2 sentences.", max_output_tokens=120).text
    except ai.AIError: pass
    notify.slack(f"📉 KPI drop yesterday\n{text}", channel="#marketing")
    notify.email_me("KPI drop yesterday", text)
    return {"alerts": len(drops)}