Monitor Endpoints

# --retry waits for Retry-After on 429 and 503 responses (curl 7.66 or later).
curl -X POST "https://api.sixtyfour.ai/monitors/MONITOR_ID/history-export" \
  -H "x-api-key: YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{"start": "2026-01-01T00:00:00Z", "end": "2026-03-31T23:59:59Z"}' \
  --retry 5 \
  -o monitor-history.zip

import time

import requests

for _ in range(5):
    response = requests.post(
        "https://api.sixtyfour.ai/monitors/MONITOR_ID/history-export",
        headers={"x-api-key": "YOUR_API_KEY"},
        json={"start": "2026-01-01T00:00:00Z", "end": "2026-03-31T23:59:59Z"},
    )
    if response.status_code not in (429, 503):
        break
    time.sleep(int(response.headers.get("Retry-After", "15")))
response.raise_for_status()
with open("monitor-history.zip", "wb") as f:
    f.write(response.content)

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

let response;
for (let attempt = 0; attempt < 5; attempt++) {
  response = await fetch(
    "https://api.sixtyfour.ai/monitors/MONITOR_ID/history-export",
    {
      method: "POST",
      headers: { "x-api-key": "YOUR_API_KEY", "Content-Type": "application/json" },
      body: JSON.stringify({ start: "2026-01-01T00:00:00Z", end: "2026-03-31T23:59:59Z" }),
    },
  );
  if (response.status !== 429 && response.status !== 503) break;
  const waitSeconds = Number(response.headers.get("Retry-After") ?? 15);
  await new Promise((resolve) => setTimeout(resolve, waitSeconds * 1000));
}
if (!response.ok) throw new Error(`Export failed: ${response.status}`);
await writeFile("monitor-history.zip", Buffer.from(await response.arrayBuffer()));

curl -X POST "https://api.sixtyfour.ai/monitors/upload" \
  -H "x-api-key: YOUR_API_KEY" \
  -F "file=@companies.csv" \
  -F 'config={"name": "Portfolio leadership", "key_columns": ["company_name", "domain"], "struct": {"ceo_name": "Full name of the current CEO"}, "frequency": "1d", "subject_type": "company"}'

curl "https://api.sixtyfour.ai/monitors/MONITOR_ID" \
  -H "x-api-key: YOUR_API_KEY"

import json
import time

import requests

API_KEY = "YOUR_API_KEY"
BASE_URL = "https://api.sixtyfour.ai"
headers = {"x-api-key": API_KEY}

config = {
    "name": "Portfolio leadership",
    "key_columns": ["company_name", "domain"],
    "struct": {"ceo_name": "Full name of the current CEO"},
    "frequency": "1d",
    "subject_type": "company",
}

with open("companies.csv", "rb") as f:
    response = requests.post(
        f"{BASE_URL}/monitors/upload",
        headers=headers,
        files={"file": ("companies.csv", f, "text/csv")},
        data={"config": json.dumps(config)},
    )
response.raise_for_status()
monitor = response.json()

while monitor["status"] == "starting":
    time.sleep(10)
    poll = requests.get(f"{BASE_URL}/monitors/{monitor['id']}", headers=headers)
    if poll.status_code in (429, 503):
        time.sleep(int(poll.headers.get("Retry-After", "10")))
        continue
    poll.raise_for_status()
    monitor = poll.json()

if monitor["status"] == "failed":
    raise RuntimeError(monitor["disabled_reason"])
print(monitor["status"], monitor["row_count"])

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

const API_KEY = "YOUR_API_KEY";
const BASE_URL = "https://api.sixtyfour.ai";
const headers = { "x-api-key": API_KEY };

const form = new FormData();
form.append(
  "file",
  new Blob([await readFile("companies.csv")], { type: "text/csv" }),
  "companies.csv",
);
form.append(
  "config",
  JSON.stringify({
    name: "Portfolio leadership",
    key_columns: ["company_name", "domain"],
    struct: { ceo_name: "Full name of the current CEO" },
    frequency: "1d",
    subject_type: "company",
  }),
);

const response = await fetch(`${BASE_URL}/monitors/upload`, {
  method: "POST",
  headers,
  body: form,
});
if (!response.ok) {
  throw new Error(`Failed to create monitor: ${await response.text()}`);
}
let monitor = await response.json();

while (monitor.status === "starting") {
  await new Promise((resolve) => setTimeout(resolve, 10000));
  const poll = await fetch(`${BASE_URL}/monitors/${monitor.id}`, { headers });
  if (poll.status === 429 || poll.status === 503) {
    const waitSeconds = Number(poll.headers.get("Retry-After") ?? 10);
    await new Promise((resolve) => setTimeout(resolve, waitSeconds * 1000));
    continue;
  }
  if (!poll.ok) {
    throw new Error(`Failed to read monitor: ${await poll.text()}`);
  }
  monitor = await poll.json();
}

if (monitor.status === "failed") {
  throw new Error(monitor.disabled_reason);
}
console.log(monitor.status, monitor.row_count);

curl -X POST "https://api.sixtyfour.ai/monitors" \
  -H "x-api-key: YOUR_API_KEY" \
  -H "Content-Type: application/json" \
  -d '{
    "name": "Portfolio leadership",
    "key_columns": ["company_name", "domain"],
    "rows": [
      {"company_name": "Acme Robotics", "domain": "acmerobotics.com", "ceo_name": "Dana Lee"}
    ],
    "struct": {"ceo_name": "Full name of the current CEO"},
    "frequency": "1d",
    "subject_type": "company"
  }'

curl "https://api.sixtyfour.ai/monitors/MONITOR_ID/rows" \
  -H "x-api-key: YOUR_API_KEY"

curl "https://api.sixtyfour.ai/monitors/MONITOR_ID/rows/ROW_ID/events?field=ceo_name" \
  -H "x-api-key: YOUR_API_KEY"

import requests

API_KEY = "YOUR_API_KEY"
BASE_URL = "https://api.sixtyfour.ai"
headers = {"x-api-key": API_KEY, "Content-Type": "application/json"}

response = requests.post(
    f"{BASE_URL}/monitors",
    headers=headers,
    json={
        "name": "Portfolio leadership",
        "key_columns": ["company_name", "domain"],
        "rows": [
            {"company_name": "Acme Robotics", "domain": "acmerobotics.com", "ceo_name": "Dana Lee"}
        ],
        "struct": {"ceo_name": "Full name of the current CEO"},
        "frequency": "1d",
        "subject_type": "company",
    },
)
response.raise_for_status()
monitor = response.json()

rows = requests.get(f"{BASE_URL}/monitors/{monitor['id']}/rows", headers=headers)
rows.raise_for_status()
row_id = rows.json()["rows"][0]["id"]

events = requests.get(
    f"{BASE_URL}/monitors/{monitor['id']}/rows/{row_id}/events",
    headers=headers,
    params={"field": "ceo_name"},
)
events.raise_for_status()
for event in events.json():
    print(event["event_type"], event["previous_value"], "->", event["current_value"])

const API_KEY = "YOUR_API_KEY";
const BASE_URL = "https://api.sixtyfour.ai";
const headers = { "x-api-key": API_KEY, "Content-Type": "application/json" };

const response = await fetch(`${BASE_URL}/monitors`, {
  method: "POST",
  headers,
  body: JSON.stringify({
    name: "Portfolio leadership",
    key_columns: ["company_name", "domain"],
    rows: [
      { company_name: "Acme Robotics", domain: "acmerobotics.com", ceo_name: "Dana Lee" },
    ],
    struct: { ceo_name: "Full name of the current CEO" },
    frequency: "1d",
    subject_type: "company",
  }),
});
if (!response.ok) {
  throw new Error(`Failed to create monitor: ${await response.text()}`);
}
const monitor = await response.json();

const rowsResponse = await fetch(`${BASE_URL}/monitors/${monitor.id}/rows`, {
  headers,
});
if (!rowsResponse.ok) {
  throw new Error(`Failed to read rows: ${await rowsResponse.text()}`);
}
const rowId = (await rowsResponse.json()).rows[0].id;

const eventsResponse = await fetch(
  `${BASE_URL}/monitors/${monitor.id}/rows/${rowId}/events?field=ceo_name`,
  { headers },
);
const events = await eventsResponse.json();
for (const event of events) {
  console.log(event.event_type, event.previous_value, "->", event.current_value);
}