Trabajos y trabajos por lotes

El trabajo largo corre en segundo plano como un trabajo, que usted sigue por su ID.

Antes de empezarCopiar el enlace

• El Acceso de su clave permite escribir.
• El espacio de trabajo tiene créditos; si no, un trabajo se rechaza antes de empezar.
• Todos los ejemplos suponen nexus = Nexus.connect().

Trabajos por lotesCopiar el enlace

Un trabajo por lotes ejecuta de 1 a 50 sentencias SQL que cambian filas y las publica como un solo cambio: llegan todas, o ninguna.

Inicie un trabajo por lotesCopiar el enlace

import time

from klarety import Nexus, RefusedError, WaitingForOwnerError

with Nexus.connect() as nexus:
    try:
        job = nexus.start_batch_job([
            "UPDATE orders SET status = 'closed' WHERE ordered_at < DATE '2026-01-01'",
            "DELETE FROM orders WHERE status = 'test'",
        ])
    except RefusedError as refused:
        raise SystemExit(f"Refused: {refused}")

    try:
        state = nexus.jobs.describe(job["job_id"])
        while state["state"] in ("running", "publishing"):
            time.sleep(5)
            state = nexus.jobs.describe(job["job_id"])
        print("Ended as", state["state"])
    except WaitingForOwnerError as waiting:
        print("Waiting for the owner's OK:", waiting, waiting.job_id)

SígaloCopiar el enlace

jobs.describe() informa running, luego publishing y luego cómo terminó el trabajo: succeeded, failed, declined o expired.

ReglasCopiar el enlace

• Cada sentencia debe leer o cambiar filas. Cambie columnas con Tablas y esquemas.
• Una tabla vacía no tiene desde dónde partir. Agregue sus primeras filas con tables.edit_rows() o con una carga.

Trabajos con script de SparkCopiar el enlace

jobs.submit() ejecuta un script de Spark en Python dentro de los recursos que permite su plan.

Envíe un scriptCopiar el enlace

from klarety import Nexus, RefusedError

with Nexus.connect() as nexus:
    try:
        job = nexus.jobs.submit(script_uri, args=["--day", "2026-11-09"])
    except RefusedError as refused:
        raise SystemExit(f"Job refused: {refused}")
    print(job["job_id"], job["state"])

• script_uri es un archivo .py en el almacenamiento propio de su espacio de trabajo; cualquier otro lugar se rechaza.
• args se pasan al script, hasta 64.
• Un trabajo corre como máximo lo que su plan permite correr a una sentencia.

Sígalo o cancéleloCopiar el enlace

print(nexus.jobs.describe(job["job_id"]))   # submitted, running, succeeded, failed or cancelled
nexus.jobs.cancel(job["job_id"])

Cuando un trabajo falla, exit_reason dice por qué.

Qué puede salir malCopiar el enlace

Próximos pasosCopiar el enlace

• Ejecutar SQL para lecturas.
• Sesiones de Spark para Spark interactivo.
• Límites y límites de solicitudes para los recursos de trabajos de su plan.