Cómo poner en cola ejecuciones de flujos de trabajo con Cloud Tasks

Puedes usar Cloud Tasks para poner en cola un flujo de trabajo y ejecutarlo de forma asíncrona.

Cloud Tasks ofrece los siguientes controles:

  • Programar horas de entrega específicas
  • Administrar las frecuencias de envío
  • Configurar el comportamiento de reintento
  • Acceder y administrar tareas individuales en una cola
  • Habilitar la anulación de duplicación de tareas

Estos controles pueden ser útiles, por ejemplo, para administrar solicitudes que activan un flujo de trabajo y que podrían exceder de forma inesperada los límites de Workflows. Si configuras una cola de Cloud Tasks con límites de frecuencia y reintentos, puedes asegurarte de que todas esas solicitudes generen ejecuciones de flujo de trabajo.

Para obtener más información, consulta Comprende Cloud Tasks.

Ten en cuenta lo siguiente:

  • Debes basar el límite de frecuencia en el límite de Workflows para solicitudes de escritura de la API de Execution. Si es necesario, puedes solicitar un ajuste de la mayoría de las cuotas en la Google Cloud consola. Obtén más información sobre los ajustes de cuota.

  • Cloud Tasks está diseñado para brindar una entrega "al menos una vez"; sin embargo, Workflows no garantiza el procesamiento exactamente una vez de las solicitudes duplicadas de Cloud Tasks.

  • Puedes quitar los retrasos de ejecución y maximizar el rendimiento si habilitas el registro de ejecuciones pendientes en Workflows. Las ejecuciones pendientes se ejecutan automáticamente en cuanto está disponible la cuota de simultaneidad de ejecución. Para obtener más información, consulta Administra el registro de ejecuciones pendientes.

Antes de comenzar

  1. Si aún no tienes un flujo de trabajo que quieras poner en cola, crea uno.

  2. Habilita la API de Cloud Tasks.

    Roles necesarios para habilitar las APIs

    Para habilitar las APIs, necesitas el rol de IAM de administrador de Service Usage (roles/serviceusage.serviceUsageAdmin), que contiene el permiso serviceusage.services.enable. Obtén más información para otorgar roles.

    Habilitar la API

Poner en cola una tarea para ejecutar un flujo de trabajo

  1. Crea una cuenta de servicio para que Cloud Tasks pueda realizar solicitudes a la API de Workflows:

    gcloud iam service-accounts create SERVICE_ACCOUNT_NAME

    Reemplaza SERVICE_ACCOUNT_NAME por un nombre que tenga entre 6 y 30 caracteres. Puede contener guiones y caracteres alfanuméricos en minúscula. Después de crear una cuenta de servicio, no podrás cambiar su nombre.

  2. Para permitir que la cuenta principal que ejecutará tus comandos de Cloud Tasks pueda actuar como una cuenta de servicio de Identity and Access Management (IAM), otorga un rol que le permita a la cuenta principal usar la identidad de la cuenta de servicio.

  3. Otorga a la cuenta de servicio nueva el workflows.invoker rol para que la cuenta tenga permiso para activar tu flujo de trabajo:

    gcloud projects add-iam-policy-binding PROJECT_NAME \
    --member serviceAccount:SERVICE_ACCOUNT_NAME@PROJECT_NAME.iam.gserviceaccount.com \
    --role roles/workflows.invoker

    Reemplaza lo siguiente:

    • PROJECT_NAME: el nombre de tu Google Cloud proyecto.
    • SERVICE_ACCOUNT_NAME: el nombre de la cuenta de servicio que creaste anteriormente.

  4. Si aún no tienes una cola de Cloud Tasks, crea una.

  5. Crea una tarea que apunte al extremo HTTP de tu flujo de trabajo con la cuenta de servicio que creaste anteriormente para autenticar:

    gcloud tasks create-http-task \
    --queue="QUEUE_ID" \
    --url="https://workflowexecutions.googleapis.com/v1/projects/PROJECT_NAME/locations/REGION_NAME/workflows/WORKFLOW_NAME/executions" \
    --body-content="{\"argument\": \"DOUBLE_ESCAPED_JSON_STRING\"}" \
    --oauth-service-account-email="SERVICE_ACCOUNT_NAME@PROJECT_NAME.iam.gserviceaccount.com"

    Reemplaza lo siguiente:

    • QUEUE_ID: el identificador que asignaste a tu cola de Cloud Tasks; por ejemplo, my-queue.
    • PROJECT_NAME: el nombre de tu Google Cloud proyecto.
    • REGION_NAME: la región en la que se encuentra tu flujo de trabajo, como us-central1.
    • WORKFLOW_NAME: el nombre del flujo de trabajo para el que deseas crear una tarea.
    • DOUBLE_ESCAPED_JSON_STRING: una codificación JSON de cualquier argumento que pases. Las comillas dobles dentro de la cadena entre comillas se escapan con barras invertidas (\). Por ejemplo: --body-content="{\"argument\": \"{\\\"foo\\\": \\\"bar\\\"}\"}"
    • SERVICE_ACCOUNT_NAME: el nombre de la cuenta de servicio que creaste anteriormente.

    Tu tarea se crea y se agrega a tu cola de Cloud Tasks. La tarea persiste en la cola hasta que se inicia la ejecución del flujo de trabajo y muestra un código de estado HTTP 2xx, momento en el que Cloud Tasks considera que la tarea está completa.

¿Qué sigue?