订阅任务事件流（SSE）

import json, requests

API_KEY = "sk-..."
BASE = "https://core.cyberun.cloud/api/v1/r"

with requests.get(
    f"{BASE}/tasks/{task_id}/events",
    headers={"Authorization": f"Bearer {API_KEY}"},
    stream=True,
) as stream:
    event_type = None
    for line in stream.iter_lines(decode_unicode=True):
        if not line:
            continue
        if line.startswith("event:"):
            event_type = line[6:].strip()
        elif line.startswith("data:"):
            data = json.loads(line[5:].strip())
            if event_type == "progress":
                pct = int(data["progress"] * 100)
                print(f"{pct}% ({data['step_current']}/{data['step_total']})")
            elif event_type in ("completed", "failed", "cancelled"):
                print(event_type, data)
                break

const API_KEY = process.env.CYBERUN_KEY!;
const BASE = 'https://core.cyberun.cloud/api/v1/r';

const resp = await fetch(`${BASE}/tasks/${taskId}/events`, {
	headers: { Authorization: `Bearer ${API_KEY}` }
});

const reader = resp.body!.getReader();
const decoder = new TextDecoder();
let buffer = '';
let eventType = '';

while (true) {
	const { done, value } = await reader.read();
	if (done) break;
	buffer += decoder.decode(value, { stream: true });
	const lines = buffer.split('\n');
	buffer = lines.pop() ?? '';

	for (const line of lines) {
		if (line.startsWith('event:')) {
			eventType = line.slice(6).trim();
		} else if (line.startsWith('data:')) {
			const data = JSON.parse(line.slice(5).trim());
			if (eventType === 'progress') {
				console.log(`${Math.round(data.progress * 100)}%`);
			} else if (eventType === 'completed' || eventType === 'failed' || eventType === 'cancelled') {
				console.log(eventType, data);
				return;
			}
		}
	}
}