Catch campaigns that overspend

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

CUSTOMER_ID = "1234567890"

def gaql(query):
    headers = {"Authorization": f"Bearer {credentials.connection('google', 'ads')}",
               "developer-token": credentials.secret("GOOGLE_ADS_DEVELOPER_TOKEN")}
    batches = http.post(f"https://googleads.googleapis.com/v21/customers/{CUSTOMER_ID}/googleAds:searchStream",
                        headers=headers, json={"query": query}).json()
    return [row for b in batches for row in b.get("results", [])]


@on_trigger
def run(event):
    start, end = date.today() - timedelta(days=8), date.today() - timedelta(days=1)
    rows = gaql("SELECT campaign.name, segments.date, metrics.cost_micros FROM campaign "
                f"WHERE segments.date BETWEEN '{start}' AND '{end}'")
    spend = defaultdict(dict)
    for r in rows:
        spend[r["campaign"]["name"]][r["segments"]["date"]] = int(r["metrics"].get("costMicros", 0)) / 1e6
    alerts = []
    for name, days in spend.items():
        y = days.pop(str(end), 0)
        avg = sum(days.values()) / max(len(days), 1)
        if avg and y > avg * 1.5:
            alerts.append(f"{name}: ${y:,.2f} yesterday vs ${avg:,.2f}/day average")
    if alerts:
        notify.email_me("Google Ads spend spike", "\n".join(alerts))
    return {"alerts": len(alerts)}