Task asincroni

#Un solo ciclo di vita per ogni modello asincrono

1. 1

   Invia una sola volta

   Usa una Idempotency-Key univoca e salva subito la risposta.

   POST /v1/{capability}
2. 2

   Salva task_id

   Salvalo prima che il worker confermi il job.

   task_id
3. 3

   Polling o webhook

   Confronta status senza distinguere maiuscole e minuscole e fermati a uno stato finale.

   GET /{task_id}
4. 4

   Recupera e salva il risultato

   Chiama /content dopo il successo e salva l'URL della piattaforma restituito.

   GET /{task_id}/content

#Famiglie di endpoint

#Valori di stato

Un ciclo di vita, due vocabolari di trasmissione. I task di immagini, musica e 3D usano i termini dei task OpenAI; i video e ogni payload dei webhook usano i termini dei video OpenAI. Un controllo di stato scritto per una famiglia non corrisponde mai, senza avvisi, nell'altra — questa tabella è la mappatura.

#Ciclo di polling sicuro

Fermati sulle parole finali della famiglia che stai interrogando, mantieni una scadenza in tempo reale per tutto il resto e applica un backoff, così un task bloccato non può trasformarsi in un ciclo frenetico.

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)

#Conservazione dei risultati

Recupera /content solo dopo il successo. Salva l'URL della piattaforma restituito nel tuo record di business e scarica una copia privata quando i tuoi requisiti di conservazione richiedono uno storage indipendente.