Import contacts from a CSV in Google Drive into Notion

import csv, io, time
from google.oauth2.credentials import Credentials
from googleapiclient.discovery import build
from clickruntime import on_trigger, credentials, http, state, report_fetched

FOLDER_ID, DB = "your-folder-id", "your-database-id"

@on_trigger
def run(event):
    drive = build("drive", "v3", credentials=Credentials(credentials.connection("google", "work")), cache_discovery=False)
    done = set(state.get("done") or [])
    files = [f for f in drive.files().list(q=f"'{FOLDER_ID}' in parents and mimeType='text/csv' and trashed=false").execute().get("files", []) if f["id"] not in done]
    report_fetched(len(files))
    if not files:
        return {"summary": "Nothing new"}
    nh = {"Authorization": f"Bearer {credentials.connection('notion', 'work')}", "Notion-Version": "2022-06-28"}
    added = 0
    for f in files:
        for row in csv.DictReader(io.StringIO(drive.files().get_media(fileId=f["id"]).execute().decode("utf-8-sig"))):
            email = (row.get("email") or row.get("Email") or "").strip().lower()
            if not email:
                continue
            q = {"filter": {"property": "Email", "email": {"equals": email}}}
            if http.post(f"https://api.notion.com/v1/databases/{DB}/query", headers=nh, json=q).json()["results"]:
                continue
            http.post("https://api.notion.com/v1/pages", headers=nh, json={"parent": {"database_id": DB}, "properties": {
                "Name": {"title": [{"text": {"content": row.get("name") or email}}]}, "Email": {"email": email}}})
            added += 1
            time.sleep(0.35)
        done.add(f["id"])
    state.set("done", list(done))
    return {"files": len(files), "added": added}