CRM-to-Persona Pipeline

import os, requests
from collections import defaultdict

SF   = os.environ["SALESFORCE_INSTANCE"]
SF_T = os.environ["SALESFORCE_ACCESS_TOKEN"]
MV_K = os.environ["MAVERA_API_KEY"]
SF_HEADERS = {"Authorization": f"Bearer {SF_T}"}
MV_HEADERS = {"Authorization": f"Bearer {MV_K}", "Content-Type": "application/json"}

soql = (
    "SELECT Name, Title, Industry, Description "
    "FROM Contact WHERE Industry = 'Technology'"
)
resp = requests.get(
    f"https://{SF}/services/data/v66.0/query",
    headers=SF_HEADERS,
    params={"q": soql},
)
resp.raise_for_status()
contacts = resp.json()["records"]

segments = defaultdict(list)
for c in contacts:
    key = (c.get("Title", "Unknown"), c.get("Industry", "Unknown"))
    segments[key].append(c)

created = []
for (title, industry), members in segments.items():
    if len(members) < 3:
        continue
    descs = [m.get("Description", "") for m in members if m.get("Description")]
    r = requests.post(
        "https://app.mavera.io/api/v1/personas",
        headers=MV_HEADERS,
        json={
            "name": f"{title} — {industry}",
            "description": (
                f"Derived from {len(members)} Salesforce contacts. "
                f"Role: {title}. Industry: {industry}. "
                f"Sample notes: {'; '.join(descs[:3])}"
            ),
        },
    )
    r.raise_for_status()
    created.append(r.json())

print(f"Created {len(created)} personas from {len(contacts)} contacts")