Bulk Intelligence

curl -X POST "https://api.sixtyfour.ai/bulk-intelligence/people" \
  -H "x-api-key: YOUR_API_KEY" \
  -F "file=@leads.csv" \
  -F 'config={
    "struct": {
      "email": "The individual'\''s email address",
      "linkedin": "LinkedIn URL for the person",
      "title": "The individual'\''s job title"
    }
  }'

import json
import requests

config = {
    "struct": {
        "email": "The individual's email address",
        "linkedin": "LinkedIn URL for the person",
        "title": "The individual's job title"
    }
}

with open("leads.csv", "rb") as f:
    response = requests.post(
        "https://api.sixtyfour.ai/bulk-intelligence/people",
        headers={"x-api-key": "YOUR_API_KEY"},
        files={"file": ("leads.csv", f, "text/csv")},
        data={"config": json.dumps(config)}
    )

response.raise_for_status()
task_id = response.json()["task_id"]

import { readFile } from "node:fs/promises";

const form = new FormData();
form.append("file", new Blob([await readFile("leads.csv")], { type: "text/csv" }), "leads.csv");
form.append("config", JSON.stringify({
  struct: {
    email: "The individual's email address",
    linkedin: "LinkedIn URL for the person",
    title: "The individual's job title"
  }
}));

const response = await fetch("https://api.sixtyfour.ai/bulk-intelligence/people", {
  method: "POST",
  headers: { "x-api-key": "YOUR_API_KEY" },
  body: form
});

if (!response.ok) throw new Error(`Submission failed: ${response.status}`);
const { task_id } = await response.json();

# Check status
curl "https://api.sixtyfour.ai/job-status/TASK_ID" \
  -H "x-api-key: YOUR_API_KEY"

# When status is "completed", download the result (no redirects — pass your key directly)
curl -o enriched.csv \
  -H "x-api-key: YOUR_API_KEY" \
  "SIGNED_DOWNLOAD_URL"

import requests
import time

deadline = time.monotonic() + 2 * 60 * 60  # give up after 2 hours

while True:
    poll_resp = requests.get(
        f"https://api.sixtyfour.ai/job-status/{task_id}",
        headers={"x-api-key": "YOUR_API_KEY"}
    )
    poll_resp.raise_for_status()
    status = poll_resp.json()

    if status["status"] == "completed":
        # The final stage has the highest block_number. If you requested NDJSON,
        # CSV and NDJSON share that block_number — pick by filename extension.
        final_block = max(f["block_number"] or 0 for f in status["results"])
        suffix = ".csv"  # use ".ndjson" if you requested NDJSON output
        final = next(
            (f for f in status["results"]
             if (f["block_number"] or 0) == final_block and f["filename"].endswith(suffix)),
            None,
        )
        if final is None:
            raise RuntimeError(f"No {suffix} file in results")
        download = requests.get(
            final["download_url"],
            headers={"x-api-key": "YOUR_API_KEY"},
            # Downloads are served directly by api.sixtyfour.ai; never
            # forward your API key across a redirect.
            allow_redirects=False
        )
        if download.status_code != 200:
            raise RuntimeError(f"Download failed: {download.status_code}")
        with open(final["filename"], "wb") as out:
            out.write(download.content)
        break
    if status["status"] in ("failed", "cancelled", "terminated", "timed_out"):
        raise RuntimeError(f"Job {status['status']}: {status.get('error', 'Unknown error')}")
    if time.monotonic() > deadline:
        raise TimeoutError("Job didn't complete within 2 hours")

    time.sleep(30)

const deadline = Date.now() + 2 * 60 * 60 * 1000; // give up after 2 hours

while (true) {
  const pollResponse = await fetch(
    `https://api.sixtyfour.ai/job-status/${task_id}`,
    { headers: { "x-api-key": "YOUR_API_KEY" } }
  );
  if (!pollResponse.ok) throw new Error(`Status check failed: ${pollResponse.status}`);
  const status = await pollResponse.json();

  if (status.status === "completed") {
    // The final stage has the highest block_number. If you requested NDJSON,
    // CSV and NDJSON share that block_number — pick by filename extension.
    const finalBlock = Math.max(...status.results.map(f => f.block_number ?? 0));
    const suffix = ".csv"; // use ".ndjson" if you requested NDJSON output
    const final = status.results.find(
      f => (f.block_number ?? 0) === finalBlock && f.filename.endsWith(suffix)
    );
    if (!final) throw new Error(`No ${suffix} file in results`);
    // Downloads are served directly by api.sixtyfour.ai; redirect: "error"
    // ensures your API key is never forwarded across a redirect.
    const data = await fetch(final.download_url, {
      headers: { "x-api-key": "YOUR_API_KEY" },
      redirect: "error"
    });
    if (!data.ok) throw new Error(`Download failed: ${data.status}`);
    // write data to disk or stream it onward
    break;
  }
  if (["failed", "cancelled", "terminated", "timed_out"].includes(status.status)) {
    throw new Error(`Job ${status.status}: ${status.error || "Unknown error"}`);
  }
  if (Date.now() > deadline) {
    throw new Error("Job didn't complete within 2 hours");
  }
  await new Promise(r => setTimeout(r, 30000));
}