Check for disapproved ads and weak keywords

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):
    ads_rows = gaql("SELECT ad_group_ad.ad.id, ad_group.name, ad_group_ad.policy_summary.approval_status "
                    "FROM ad_group_ad WHERE ad_group_ad.policy_summary.approval_status IN ('DISAPPROVED', 'APPROVED_LIMITED')")
    kw_rows = gaql("SELECT ad_group_criterion.keyword.text, ad_group.name, ad_group_criterion.quality_info.quality_score "
                   "FROM keyword_view WHERE ad_group_criterion.quality_info.quality_score <= 4 AND ad_group_criterion.status = 'ENABLED'")
    lines = [f"Ad {r['adGroupAd']['ad']['id']} in {r['adGroup']['name']}: {r['adGroupAd']['policySummary']['approvalStatus']}" for r in ads_rows]
    lines += [f"Keyword '{r['adGroupCriterion']['keyword']['text']}' in {r['adGroup']['name']}: quality score "
              f"{r['adGroupCriterion']['qualityInfo']['qualityScore']}" for r in kw_rows]
    if lines:
        notify.email_me(f"Google Ads health: {len(lines)} issues", "\n".join(lines))
    return {"issues": len(lines)}