​

Streaming y trabajos asincrónicos

1. Transmisión de respuesta (/convert/stream, /convert/stream-from-url): el servidor genera el Markdown en fragmentos progresivos durante la conversión, para reducir el TTFB en documentos grandes.
2. Trabajos de saturación (202): cuando todos los servidores están ocupados, cualquier punto final de conversión pone en cola la solicitud y responde 202 con un job_id para realizar una consulta más tarde. Consulte GET /jobs/{id}.

​

Transmitiendo con convert_stream

import markpdf

client = markpdf.Client(api_key="YOUR_API_KEY")

for chunk in client.convert_stream("informe-grande.pdf"):
    print(chunk, end="", flush=True)

for chunk in client.convert_stream("report.pdf", slim=True):
    handle(chunk)

for chunk in client.convert_stream(url="https://bucket.example.com/report.pdf?sig=...", slim=True):
    handle(chunk)

async with markpdf.AsyncClient(api_key="YOUR_API_KEY") as client:
    async for chunk in client.convert_stream("report.pdf"):
        handle(chunk)

​

stream_slim_strategy

client.convert_stream("report.pdf", slim=True, stream_slim_strategy="sampled")

• "off": streaming puro por página, sin detección de ruido. TTFB mínimo.
• "sampled" (predeterminado): muestree las primeras páginas en busca de ruido y luego genere por página.
• "full": materializa el documento completo antes de su emisión. Mejor limpieza, peor TTFB.

​

Empleos por saturación (202)

# auto_poll=True (default): SDK waits and polls for you
markdown = client.convert_file("report.pdf")

1. Lea job_id y retry_after_seconds de la respuesta.
2. Dormir retry_after_seconds (5 segundos por defecto).
3. Llama GET /jobs/{job_id}.
4. Repite mientras status sea "queued" o "processing".
5. Devuelve body cuando status == "completed", o arroja MarkpdfJobFailedError si status == "failed".

​

Manual de encuestas

from markpdf import MarkpdfJobQueuedError

try:
    markdown = client.convert_file("report.pdf", auto_poll=Failedse)
except MarkpdfJobQueuedError as job:
    print(f"En cola: {job.job_id}")
    while True:
        status = client.get_job(job.job_id)
        if status.status == "completed":
            markdown = status.body
            break
        if status.status == "failed":
            raise RuntimeError(status.error)
        time.sleep(job.retry_after_seconds)