Batches

# 1. Upload
curl https://app.syntic.ai/v1/files -H "Authorization: Bearer $SYNTIC_API_KEY" \
  -F purpose=batch -F file=@tickets.jsonl
 
# 2. Create
curl https://app.syntic.ai/v1/batches \
  -H "Authorization: Bearer $SYNTIC_API_KEY" -H "Content-Type: application/json" \
  -d '{"input_file_id":"file_01JBXF1Z","completion_window":"24h","metadata":{"job":"october-tickets"}}'
 
# 3. Check
curl https://app.syntic.ai/v1/batches/batch_01JBXF3P8K -H "Authorization: Bearer $SYNTIC_API_KEY"
 
# 4. Download
curl https://app.syntic.ai/v1/files/file_01JBXG7Q/content -H "Authorization: Bearer $SYNTIC_API_KEY" -o results.jsonl

const H = { Authorization: `Bearer ${process.env.SYNTIC_API_KEY}`, 'Content-Type': 'application/json' }
const base = 'https://app.syntic.ai/v1'
 
const batch = await (await fetch(`${base}/batches`, {
  method: 'POST',
  headers: H,
  body: JSON.stringify({
    requests: tickets.map(t => ({
      custom_id: t.id,
      endpoint: '/v1/chat/completions',
      body: { model: 'Amara Quick', max_tokens: 20, messages: [{ role: 'user', content: `Label this ticket: ${t.text}` }] },
    })),
  }),
})).json()
 
let b = batch
while (!['completed', 'expired', 'canceled', 'failed'].includes(b.status)) {
  await new Promise(r => setTimeout(r, 60_000))
  b = await (await fetch(`${base}/batches/${b.id}`, { headers: H })).json()
}
const text = await (await fetch(`${base}/files/${b.output_file_id}/content`, { headers: H })).text()
const results = text.trim().split('\n').map(line => JSON.parse(line))

import json, os, time, requests
 
base = "https://app.syntic.ai/v1"
h = {"Authorization": f"Bearer {os.environ['SYNTIC_API_KEY']}"}
 
with open("tickets.jsonl", "rb") as f:
    file_id = requests.post(f"{base}/files", headers=h, data={"purpose": "batch"},
                            files={"file": ("tickets.jsonl", f)}).json()["id"]
 
batch = requests.post(f"{base}/batches", headers=h,
                      json={"input_file_id": file_id, "completion_window": "24h"}).json()
 
while batch["status"] not in ("completed", "expired", "canceled", "failed"):
    time.sleep(60)
    batch = requests.get(f"{base}/batches/{batch['id']}", headers=h).json()
 
out = requests.get(f"{base}/files/{batch['output_file_id']}/content", headers=h).text
results = {r["custom_id"]: r["result"] for r in map(json.loads, out.splitlines())}