快速开始

import json, requests

API_KEY = "sk-..."
BASE = "https://core.cyberun.cloud/api/v1/r"
HEADERS = {"Authorization": f"Bearer {API_KEY}", "Content-Type": "application/json"}

# 1. 提交
run = requests.post(
    f"{BASE}/workflows/slug/text-to-image/run",
    headers=HEADERS,
    json={"parameters": {"prompt": "a sunset over mountains, 4k", "steps": 30}},
).json()
task_id = run["task_id"]
print("task:", task_id)

# 2. 订阅事件流
event_type = None
with requests.get(
    f"{BASE}/tasks/{task_id}/events",
    headers={"Authorization": f"Bearer {API_KEY}"},
    stream=True,
) as stream:
    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.get('step_current')}/{data.get('step_total')})")
            elif event_type in ("completed", "failed", "cancelled"):
                print(event_type)
                break

# 3. 取结果
result = requests.get(f"{BASE}/tasks/{task_id}/result", headers=HEADERS).json()
# `download_url` 是单个主输出（代理任务）。云端分发的任务改为填充
# `download_urls`，这是一个按输出标识符为键的映射。
urls = [result["download_url"]] if result.get("download_url") else list(result.get("download_urls", {}).values())
for i, url in enumerate(urls):
    with open(f"output_{i}.png", "wb") as f:
        f.write(requests.get(url).content)
    print(f"saved output_{i}.png")

# 1. 提交
TASK_ID=$(curl -s -X POST \
  -H "Authorization: Bearer sk-..." \
  -H "Content-Type: application/json" \
  -d '{"parameters":{"prompt":"a sunset over mountains, 4k","steps":30}}' \
  https://core.cyberun.cloud/api/v1/r/workflows/slug/text-to-image/run \
  | jq -r '.task_id')
echo "task: $TASK_ID"

# 2. 订阅事件流（看到 `completed` 后按 Ctrl+C）
curl -N -H "Authorization: Bearer sk-..." \
  https://core.cyberun.cloud/api/v1/r/tasks/$TASK_ID/events

# 3. 取结果
curl -s -H "Authorization: Bearer sk-..." \
  https://core.cyberun.cloud/api/v1/r/tasks/$TASK_ID/result | jq

const API_KEY = process.env.CYBERUN_KEY!;
const BASE = 'https://core.cyberun.cloud/api/v1/r';
const headers = {
	Authorization: `Bearer ${API_KEY}`,
	'Content-Type': 'application/json'
};

// 1. 提交
const run = await fetch(`${BASE}/workflows/slug/text-to-image/run`, {
	method: 'POST',
	headers,
	body: JSON.stringify({
		parameters: { prompt: 'a sunset over mountains, 4k', steps: 30 }
	})
}).then((r) => r.json());
const taskId = run.task_id;
console.log('task:', taskId);

// 2. 订阅事件流
const stream = await fetch(`${BASE}/tasks/${taskId}/events`, {
	headers: { Authorization: `Bearer ${API_KEY}` }
});
const reader = stream.body!.getReader();
const decoder = new TextDecoder();
let buffer = '';
let eventType = '';

streamLoop: 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);
				break streamLoop;
			}
		}
	}
}

// 3. 取结果
const result = await fetch(`${BASE}/tasks/${taskId}/result`, { headers }).then((r) => r.json());
console.log('download:', result.download_url);