Back up your Salesforce records every week

import csv, io
from clickruntime import on_trigger, credentials, http, notify

INSTANCE = "https://yourcompany.my.salesforce.com"
QUERIES = {
    "Accounts": "SELECT Id, Name, Industry, Website, CreatedDate FROM Account",
    "Contacts": "SELECT Id, FirstName, LastName, Email, AccountId FROM Contact",
    "Opportunities": "SELECT Id, Name, StageName, Amount, CloseDate, AccountId FROM Opportunity",
}

@on_trigger
def run(event):
    headers = {"Authorization": f"Bearer {credentials.connection('salesforce', 'work')}"}
    counts = {}
    for name, soql in QUERIES.items():
        page = http.get(f"{INSTANCE}/services/data/v61.0/query", headers=headers, params={"q": soql}).json()
        rows = page["records"]
        while page.get("nextRecordsUrl"):
            page = http.get(INSTANCE + page["nextRecordsUrl"], headers=headers).json()
            rows += page["records"]
        out = io.StringIO()
        writer = csv.DictWriter(out, fieldnames=[f for f in rows[0] if f != "attributes"] if rows else ["Id"], extrasaction="ignore")
        writer.writeheader()
        writer.writerows(rows)
        notify.email_me(f"Salesforce backup: {name} ({len(rows)})", out.getvalue())
        counts[name] = len(rows)
    return counts