Monitors API Reference

from exa_py import Exa
import os, time
exa = Exa(api_key=os.getenv("EXA_API_KEY"))
# 1. Create monitor
monitor = exa.monitors.create(params={
    "search": {
        "query": "AI startups that raised Series A funding",
        "numResults": 10
    },
    "webhook": {
        "url": "https://example.com/webhook"
    }
})
# Store the webhook secret for signature verification — only returned on creation
# See: Webhook Signature Verification section
print(monitor.webhook_secret)
# 2. Trigger a run and poll for results
exa.monitors.trigger(monitor.id)
while True:
    runs = exa.monitors.runs.list(monitor.id)
    latest = runs.data[0]
    if latest.status in ("completed", "failed"):
        break
    time.sleep(2)
# 3. Print results
if latest.status == "completed":
    run = exa.monitors.runs.get(monitor.id, latest.id)
    if run.output and run.output.results:
        for result in run.output.results:
            print(f"- {result['title']}: {result['url']}")

import Exa from "exa-js";
const exa = new Exa(process.env.EXA_API_KEY);
// 1. Create monitor
const monitor = await exa.monitors.create({
  search: {
    query: "AI startups that raised Series A funding",
    numResults: 10
  },
  webhook: {
    url: "https://example.com/webhook"
  }
});
// Store the webhook secret for signature verification — only returned on creation
// See: Webhook Signature Verification section
console.log(monitor.webhookSecret);
// 2. Trigger a run and poll for results
await exa.monitors.trigger(monitor.id);
let latest;
while (true) {
  const runs = await exa.monitors.runs.list(monitor.id);
  latest = runs.data[0];
  if (latest.status === "completed" || latest.status === "failed") break;
  await new Promise(r => setTimeout(r, 2000));
}
// 3. Print results
if (latest.status === "completed" && latest.output) {
  const run = await exa.monitors.runs.get(monitor.id, latest.id);
  for (const result of run.output.results) {
    console.log(`- ${result.title}: ${result.url}`);
  }
}

# 1. Create monitor
curl -X POST "https://api.exa.ai/monitors" \
  -H "Content-Type: application/json" \
  -H "x-api-key: $EXA_API_KEY" \
  -d '{
    "search": {
      "query": "AI startups that raised Series A funding",
      "numResults": 10
    },
    "webhook": {
      "url": "https://example.com/webhook"
    }
  }'
# 2. Trigger a run (replace MONITOR_ID with the id from the create response)
curl -X POST "https://api.exa.ai/monitors/{MONITOR_ID}/trigger" \
  -H "x-api-key: $EXA_API_KEY"
# 3. List runs to check status
curl "https://api.exa.ai/monitors/{MONITOR_ID}/runs" \
  -H "x-api-key: $EXA_API_KEY"

import hmac
import hashlib
def verify_webhook(payload: bytes, header: str, secret: str) -> bool:
    parts = dict(part.split("=", 1) for part in header.split(","))
    timestamp = parts["t"]
    signature = parts["v1"]
    signed_payload = f"{timestamp}.{payload.decode()}"
    expected = hmac.new(
        secret.encode(), signed_payload.encode(), hashlib.sha256
    ).hexdigest()
    return hmac.compare_digest(expected, signature)

import crypto from "crypto";
function verifyWebhook(payload, header, secret) {
  const parts = Object.fromEntries(
    header.split(",").map(p => p.split("=", 2))
  );
  const signedPayload = `${parts.t}.${payload}`;
  const expected = crypto
    .createHmac("sha256", secret)
    .update(signedPayload)
    .digest("hex");
  const a = Buffer.from(expected);
  const b = Buffer.from(parts.v1 || "");
  if (a.length !== b.length) return false;
  return crypto.timingSafeEqual(a, b);
}

# Iterate through all monitors
for monitor in exa.monitors.list_all(status="active"):
    print(monitor.id)
# Collect all monitors into a list
all_monitors = exa.monitors.get_all(status="active")
# Iterate through all runs for a monitor
for run in exa.monitors.runs.list_all(monitor_id):
    print(run.id, run.status)
# Collect all runs into a list
all_runs = exa.monitors.runs.get_all(monitor_id)

// Iterate through all monitors (async generator)
for await (const monitor of exa.monitors.listAll({ status: "active" })) {
  console.log(monitor.id);
}
// Collect all monitors into an array
const allMonitors = await exa.monitors.getAll({ status: "active" });
// Iterate through all runs for a monitor
for await (const run of exa.monitors.runs.listAll(monitorId)) {
  console.log(run.id, run.status);
}
// Collect all runs into an array
const allRuns = await exa.monitors.runs.getAll(monitorId);

from exa_py import Exa
import os, time
exa = Exa(api_key=os.getenv("EXA_API_KEY"))
# 1. Create
monitor = exa.monitors.create(params={
    "name": "Funding Tracker",
    "search": {
        "query": "AI startups that raised Series A funding",
        "numResults": 10,
        "contents": {
            "highlights": True
        }
    },
    "trigger": {
        "type": "interval",
        "period": "7d"
    },
    "webhook": {
        "url": "https://example.com/webhook",
        "events": ["monitor.run.completed"]
    }
})
print(f"Created: {monitor.id}")
print(f"Secret: {monitor.webhook_secret}")  # Store this!
# 2. Trigger a test run
exa.monitors.trigger(monitor.id)
# 3. Poll for completion
while True:
    runs = exa.monitors.runs.list(monitor.id)
    latest = runs.data[0]
    if latest.status in ("completed", "failed"):
        break
    time.sleep(2)
# 4. Fetch results
if latest.status == "completed":
    run = exa.monitors.runs.get(monitor.id, latest.id)
    if run.output and run.output.results:
        for result in run.output.results:
            print(f"- {result['title']}: {result['url']}")
else:
    print(f"Failed: {latest.fail_reason}")
# 5. Pause when not needed
exa.monitors.update(monitor.id, params={"status": "paused"})
# 6. Delete when done
exa.monitors.delete(monitor.id)

import Exa from "exa-js";
const exa = new Exa(process.env.EXA_API_KEY);
// 1. Create
const monitor = await exa.monitors.create({
  name: "Funding Tracker",
  search: {
    query: "AI startups that raised Series A funding",
    numResults: 10,
    contents: {
      highlights: true
    }
  },
  trigger: {
    type: "interval",
    period: "7d"
  },
  webhook: {
    url: "https://example.com/webhook",
    events: ["monitor.run.completed"]
  }
});
console.log(`Created: ${monitor.id}`);
console.log(`Secret: ${monitor.webhookSecret}`); // Store this!
// 2. Trigger a test run
await exa.monitors.trigger(monitor.id);
// 3. Poll for completion
let latest;
while (true) {
  const runs = await exa.monitors.runs.list(monitor.id);
  latest = runs.data[0];
  if (latest.status === "completed" || latest.status === "failed") break;
  await new Promise(r => setTimeout(r, 2000));
}
// 4. Fetch results
if (latest.status === "completed") {
  const run = await exa.monitors.runs.get(monitor.id, latest.id);
  if (run.output?.results) {
    for (const result of run.output.results) {
      console.log(`- ${result.title}: ${result.url}`);
    }
  }
} else {
  console.log(`Failed: ${latest.failReason}`);
}
// 5. Pause when not needed
await exa.monitors.update(monitor.id, { status: "paused" });
// 6. Delete when done
await exa.monitors.delete(monitor.id);