VanceAI を自社製品に組み込む

# Requires curl and jq
API_KEY="sk_live_..."
BASE_URL="https://cloud-vanceai.vanceai.com/api/v1"
AUTH="Authorization: Bearer $API_KEY"

# 1. Submit a job and capture its ID
JOB_ID=$(curl --fail-with-body -sS "$BASE_URL/jobs" \
  -H "$AUTH" \
  -H "Idempotency-Key: quickstart-$(date +%s)-$$" \
  -F [email protected] \
  -F tool=upscale \
  -F 'config={"scale":4,"face_enhance":true}' \
  -F output_format=jpg | jq -er '.job_id')

# 2. Poll for up to 5 minutes
for _ in $(seq 1 150); do
  JOB=$(curl --fail-with-body -sS "$BASE_URL/jobs/$JOB_ID" -H "$AUTH")
  STATUS=$(jq -r '.status' <<<"$JOB")
  case "$STATUS" in
    succeeded) break ;;
    failed|canceled)
      jq '.error // {status: .status}' <<<"$JOB"
      exit 1
      ;;
  esac
  sleep 2
done

[ "$STATUS" = "succeeded" ] || { echo "Timed out waiting for $JOB_ID"; exit 1; }

# 3. Request a fresh signed URL and download the image
curl --fail-with-body -sS -L "$BASE_URL/jobs/$JOB_ID/result?redirect=1" \
  -H "$AUTH" \
  -o upscaled.jpg

<?php
require 'vendor/autoload.php'; // composer require guzzlehttp/guzzle

use GuzzleHttp\Client;

$api = new Client([
    'base_uri' => 'https://cloud-vanceai.vanceai.com/api/v1/',
    'headers' => ['Authorization' => 'Bearer sk_live_...'],
    'timeout' => 30,
]);

// 1. Submit a job
$job = json_decode($api->post('jobs', [
    'headers' => ['Idempotency-Key' => bin2hex(random_bytes(16))],
    'multipart' => [
        ['name' => 'image', 'contents' => fopen('photo.jpg', 'rb')],
        ['name' => 'tool', 'contents' => 'upscale'],
        ['name' => 'config', 'contents' => '{"scale":4,"face_enhance":true}'],
        ['name' => 'output_format', 'contents' => 'jpg'],
    ],
])->getBody(), true, flags: JSON_THROW_ON_ERROR);

// 2. Poll for up to 5 minutes
$deadline = time() + 300;
do {
    if (time() >= $deadline) throw new RuntimeException('Job timed out');
    sleep(2);
    $job = json_decode(
        $api->get("jobs/{$job['job_id']}")->getBody(),
        true,
        flags: JSON_THROW_ON_ERROR,
    );
} while (in_array($job['status'], ['queued', 'processing'], true));

if ($job['status'] !== 'succeeded') {
    throw new RuntimeException(json_encode($job['error'] ?? $job['status']));
}

// 3. Get a fresh signed URL, then download without the API header
$result = json_decode(
    $api->get("jobs/{$job['job_id']}/result")->getBody(),
    true,
    flags: JSON_THROW_ON_ERROR,
);
(new Client())->get($result['result_url'], ['sink' => 'upscaled.jpg']);

import shutil
import time
import uuid

import requests

base = "https://cloud-vanceai.vanceai.com/api/v1"
api = requests.Session()
api.headers["Authorization"] = "Bearer sk_live_..."

# 1. Submit a job
with open("photo.jpg", "rb") as image:
    response = api.post(
        f"{base}/jobs",
        headers={"Idempotency-Key": str(uuid.uuid4())},
        files={"image": image},
        data={
            "tool": "upscale",
            "config": '{"scale":4,"face_enhance":true}',
            "output_format": "jpg",
        },
        timeout=30,
    )
response.raise_for_status()
job = response.json()

# 2. Poll for up to 5 minutes
deadline = time.monotonic() + 300
while job["status"] in ("queued", "processing"):
    if time.monotonic() >= deadline:
        raise TimeoutError(f"Job {job['job_id']} timed out")
    time.sleep(2)
    response = api.get(f"{base}/jobs/{job['job_id']}", timeout=30)
    response.raise_for_status()
    job = response.json()

if job["status"] != "succeeded":
    raise RuntimeError(job.get("error") or f"Job ended as {job['status']}")

# 3. Get a fresh signed URL, then stream the result to disk
response = api.get(f"{base}/jobs/{job['job_id']}/result", timeout=30)
response.raise_for_status()
result_url = response.json()["result_url"]

with requests.get(result_url, stream=True, timeout=120) as result:
    result.raise_for_status()
    with open("upscaled.jpg", "wb") as output:
        shutil.copyfileobj(result.raw, output)