Log daily GA4 traffic by source to Google Sheets

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

PROPERTY = "123456789"
SHEET_ID = "your-spreadsheet-id"
METRICS = ["sessions", "totalUsers", "engagedSessions", "keyEvents"]

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

@on_trigger
def run(event):
    day = (date.today() - timedelta(days=1)).isoformat()
    rows = ga({"dateRanges": [{"startDate": day, "endDate": day}], "dimensions": [{"name": "sessionSourceMedium"}],
               "metrics": [{"name": m} for m in METRICS], "orderBys": [{"metric": {"metricName": "sessions"}, "desc": True}],
               "limit": 100})
    values = [[day, r["dimensionValues"][0]["value"]] + [round(float(v["value"]), 2) for v in r["metricValues"]] for r in rows]
    if values:
        build("sheets", "v4", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False) \
            .spreadsheets().values().append(spreadsheetId=SHEET_ID, range="Traffic!A:F", valueInputOption="RAW",
                                            body={"values": values}).execute()
    return {"date": day, "sources": len(values)}