Çok sayıda kişi içe aktarma

curl -X POST https://kaisupport.com/api/v1/contacts/batch \
  -H "Authorization: Bearer $KAI_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "operations": [
      { "op": "upsert", "data": {
          "external_id": "DK-1042",
          "name": "Ayşe Yılmaz",
          "email": "ayse@example.com",
          "attributes": { "package": "Tam Destek" }
      }},
      { "op": "assign", "external_id": "DK-1043", "owner": "baran@example.com" },
      { "op": "delete", "external_id": "DK-0007" }
    ]
  }'

{
  "summary": { "total": 3, "created": 1, "updated": 0, "deleted": 1, "assigned": 1, "errors": 0 },
  "results": [
    { "index": 0, "op": "upsert", "status": "created", "id": "4f1d6f2a-..." },
    { "index": 1, "op": "assign", "status": "assigned", "id": "7d2b8e11-..." },
    { "index": 2, "op": "delete", "status": "deleted", "id": "8b2f1c40-..." }
  ]
}

{
  "index": 4,
  "op": "upsert",
  "status": "error",
  "error": {
    "type": "invalid_attributes",
    "message": "Some attributes could not be stored.",
    "details": [{ "key": "exam_year", "message": "expected a number" }]
  }
}

import itertools, requests

API = "https://kaisupport.com/api/v1"
HEADERS = {"Authorization": f"Bearer {KAI_API_KEY}"}

def batches(rows, size=1000):
    it = iter(rows)
    while chunk := list(itertools.islice(it, size)):
        yield chunk

failures = []
for chunk in batches(contacts):
    body = {"operations": [{"op": "upsert", "data": row} for row in chunk]}
    response = requests.post(f"{API}/contacts/batch", json=body, headers=HEADERS)
    response.raise_for_status()
    result = response.json()
    failures += [r for r in result["results"] if r["status"] == "error"]
    print(result["summary"])

print(f"{len(failures)} rows failed")