API概要

# タスクを送信
curl -X POST http://localhost:8080/api/v1/tasks \
  -H "Content-Type: application/json" \
  -d '{"query": "感情分析: Shannonは AI をシンプルにする"}'

# レスポンス
{
  "task_id": "task-dev-1234567890",
  "status": "submitted",
  "created_at": "2025-01-20T10:00:00Z"
}

# リアルタイムイベントをストリーム
curl -N "http://localhost:8080/api/v1/stream/sse?workflow_id=task-dev-1234567890"

curl -H "X-API-Key: sk_test_123456" \
  http://localhost:8080/api/v1/tasks

{
  "task_id": "task-dev-1234567890",
  "status": "COMPLETED",
  "result": "感情: ポジティブ"
}

{
  "error": "Task not found"
}

{
  "query": "Q2はどうですか？",
  "session_id": "user-123-analytics"
}

import requests

r = requests.get(
    f"http://localhost:8080/api/v1/stream/sse?workflow_id={task_id}",
    stream=True
)

for line in r.iter_lines():
    if line:
        event = parse_sse(line)
        print(event['type'])

import time

def submit_with_retry(query, max_retries=3):
    for attempt in range(max_retries):
        response = requests.post(url, json={"query": query})

        if response.status_code == 429:
            retry_after = int(response.headers.get("Retry-After", 60))
            time.sleep(retry_after)
            continue

        return response

curl -X POST http://localhost:8080/api/v1/tasks \
  -H "Idempotency-Key: $(uuidgen)" \
  -d '{"query": "一度だけ処理"}'