Get yesterday's campaign results each morning

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):
    rows = gaql("SELECT campaign.name, metrics.cost_micros, metrics.clicks, metrics.conversions "
                "FROM campaign WHERE segments.date DURING YESTERDAY")
    lines, total = [], 0
    for r in rows:
        m = r["metrics"]
        cost, conv = int(m.get("costMicros", 0)) / 1e6, float(m.get("conversions", 0))
        total += cost
        lines.append(f"{r['campaign']['name']}: ${cost:,.2f}, {m.get('clicks', 0)} clicks, {conv:.0f} conv"
                     + (f", ${cost / conv:,.2f}/conv" if conv else ""))
    notify.email_me(f"Google Ads yesterday: ${total:,.2f}", "\n".join(lines) or "No spend yesterday.")
    return {"spend": round(total, 2)}