Asynchrone Tasks

#Ein Lebenszyklus für alle asynchronen Modelle

1. 1

   Einmal einreichen

   Verwenden Sie einen eindeutigen Idempotency-Key und speichern Sie die Antwort sofort.

   POST /v1/{capability}
2. 2

   task_id speichern

   Speichern Sie sie, bevor der Worker den Job bestätigt.

   task_id
3. 3

   Abfragen oder Webhook empfangen

   Vergleichen Sie status ohne Berücksichtigung der Groß-/Kleinschreibung und stoppen Sie bei einem Endzustand.

   GET /{task_id}
4. 4

   Ergebnis abrufen und speichern

   Rufen Sie nach Erfolg /content auf und speichern Sie die zurückgegebene Plattform-URL.

   GET /{task_id}/content

#Endpunktfamilien

#Statuswerte

Ein Lebenszyklus, zwei Wire-Vokabulare. Bild-, Musik- und 3D-Tasks melden die Task-Begriffe von OpenAI; Videos und alle Webhook-Payloads melden die Video-Begriffe von OpenAI. Eine Statusprüfung, die für eine Familie geschrieben wurde, greift in der anderen stillschweigend nie — diese Tabelle ist die Zuordnung.

#Sichere Abfrageschleife

Stoppen Sie bei den Endzustandswörtern der Familie, die Sie abfragen, setzen Sie für alles andere eine feste Zeitgrenze, und nutzen Sie Backoff, damit ein hängender Task nicht zur Endlosschleife wird.

import time, requests

# The two vocabularies. Pick the one that matches the endpoint you poll.
TASK_DONE, TASK_FAILED = {"succeeded"}, {"failed"}      # images / music / 3D
VIDEO_DONE, VIDEO_FAILED = {"completed"}, {"failed"}    # videos + webhooks
DEADLINE_SECONDS = 15 * 60

def wait_for_image_task(task_id, api_key):
    started = time.monotonic()
    delay = 2
    while True:
        response = requests.get(
            f"https://www.aisplice.store/v1/images/tasks/{task_id}",
            headers={"Authorization": f"Bearer {api_key}"},
            timeout=30,
        )
        response.raise_for_status()
        task = response.json()
        status = task.get("status", "")

        if status in TASK_DONE:
            return task
        if status in TASK_FAILED:
            raise RuntimeError((task.get("error") or {}).get("message", "task failed"))

        # queued / processing / unknown all mean "not finished". Wait — but
        # never forever: hand an overdue task to reconciliation.
        if time.monotonic() - started > DEADLINE_SECONDS:
            raise TimeoutError(f"task {task_id} still {status} after the deadline")

        time.sleep(delay)
        delay = min(delay * 1.5, 15)

#Aufbewahrung der Ergebnisse

Rufen Sie /content erst nach Erfolg ab. Speichern Sie die zurückgegebene Plattform-URL in Ihrem Geschäftsdatensatz und laden Sie eine eigene Kopie herunter, wenn Ihre Aufbewahrungsanforderungen unabhängigen Speicher verlangen.