Asignar tareas extraídas

Una vez que las tareas están en una cola de extracción, un trabajador puede alquilarlas. Una vez que se hayan procesado las tareas, el trabajador debe eliminarlas.

Antes de empezar

Contexto importante

  • Este método solo se aplica a los workers que se ejecutan en un servicio del entorno estándar.
  • Cuando usas colas de extracción, eres responsable de escalar tus trabajadores en función del volumen de procesamiento.

Asignar tareas

Una vez que las tareas están en la cola, un trabajador puede alquilar una o varias de ellas mediante el método leaseTasks(). Puede que las tareas que hayas añadido recientemente con add() tarden un poco en estar disponibles en leaseTasks().

Cuando solicitas una asignación, especificas el número de tareas que quieres asignar (hasta un máximo de 1000) y la duración de la asignación en segundos (hasta un máximo de una semana). La duración de la asignación debe ser suficiente para que la tarea más lenta tenga tiempo de ejecutarse antes de que caduque el periodo de asignación. Puedes modificar un alquiler de tarea con modifyTaskLease().

Durante la asignación de una tarea, otro trabajador no puede procesarla. La tarea deja de estar disponible hasta que caduca la asignación.

En el siguiente código de ejemplo se alquilan tareas de la cola pull-queue durante una hora:

List<TaskHandle> tasks = q.leaseTasks(3600, TimeUnit.SECONDS, numberOfTasksToLease);

Agrupación por lotes con etiquetas de tarea

No todas las tareas son iguales. Tu código puede "etiquetar" tareas y, a continuación, elegir las tareas que se van a alquilar por etiqueta. La etiqueta actúa como filtro.

q.add(
    TaskOptions.Builder.withMethod(TaskOptions.Method.PULL)
        .payload(content.toString())
        .tag("process".getBytes()));

A continuación, alquila las tareas filtradas:

// Lease only tasks tagged with "process"
List<TaskHandle> tasks =
    q.leaseTasksByTag(3600, TimeUnit.SECONDS, numberOfTasksToLease, "process");
// You can also specify a tag to lease via LeaseOptions passed to leaseTasks.

Regular las frecuencias de sondeo

Los trabajadores que sondean la cola para arrendar tareas deben detectar si están intentando arrendar tareas más rápido de lo que la cola puede proporcionárselas. Si se produce este fallo, se pueden generar las siguientes excepciones de leaseTasks():


Tu código debe detectar estas excepciones, dejar de llamar a leaseTasks() y volver a intentarlo más tarde. Para evitar este problema, te recomendamos que definas un plazo de RPC más largo al llamar a leaseTasks(). También debes esperar cuando una solicitud de concesión devuelva una lista de tareas vacía.

Si generas más de 10 solicitudes de LeaseTasks por cola y por segundo, solo las primeras 10 solicitudes devolverán resultados. Si las solicitudes superan este límite, se devuelve OK con cero resultados.

Monitorizar tareas en la consola de Google Cloud

Para ver información sobre todas las tareas y colas de su aplicación, siga estos pasos:

  1. Abre la página Cloud Tasks en la consola de Google Cloud y busca el valor Pull en la columna Tipo.

    Ir a Cloud Tasks

  2. Haz clic en el nombre de la cola que te interese para abrir la página de detalles de la cola. Se muestran todas las tareas de la cola seleccionada.

Eliminar tareas

Una vez que un trabajador completa una tarea, debe eliminarla de la cola. Si ves que quedan tareas en una cola después de que un trabajador las haya procesado, es probable que el trabajador haya fallado. En ese caso, las tareas las procesará otro trabajador.

Puedes eliminar una tarea concreta o una lista de tareas con deleteTask(). Para eliminar una tarea, debes conocer su nombre. Puedes encontrar los nombres de las tareas en el Task object devuelto por leaseTasks().

En el siguiente ejemplo de código se muestra cómo eliminar una tarea de una cola:

q.deleteTask(task);