Se usó la API de Cloud Translation para traducir esta página.

Usa una cola de Cloud Tasks para almacenar en búfer las ejecuciones de tu flujo de trabajo

En este instructivo, se muestra cómo crear una cola de Cloud Tasks que puede regular la velocidad de las ejecuciones de flujos de trabajo.

Existe una cantidad máxima de flujos de trabajo activos ejecuciones que pueden ocurrir de forma simultánea. Una vez que se agote esta cuota backlogging de ejecución se inhabilita o, si se alcanza la cuota de ejecuciones pendientes, se crea las ejecuciones fallan con un código de estado HTTP 429 Too many requests. Al habilitar un Cloud Tasks pone en cola los flujos de trabajo secundarios a la velocidad que tú definir, puedes evitar problemas relacionados con las cuotas de Workflows y lograr una mejor tasa de ejecución.

Ten en cuenta que Cloud Tasks está diseñado para proporcionar “al menos una vez” entrega; Sin embargo, Workflows no garantiza de solicitudes duplicadas de Cloud Tasks.

En el siguiente diagrama, un flujo de trabajo superior invoca flujos de trabajo secundarios que son regulado por una cola de Cloud Tasks que tiene una frecuencia de despacho se aplicó.

Flujo de trabajo superior que invoca iteraciones de un flujo de trabajo secundario mediante
Lista de tareas en cola de Cloud

Objetivos

En este instructivo, realizarás las siguientes acciones:

Crear una cola de Cloud Tasks que actúe como intermediaria entre los flujos de trabajo superiores y los secundarios.
Crear e implementar un flujo de trabajo secundario que reciba datos del superior en el flujo de trabajo.
Crear e implementar el flujo de trabajo superior que ejecuta el flujo de trabajo secundario a través de la cola de Cloud Tasks.
Ejecutar el flujo de trabajo superior sin un límite de frecuencia de despacho, lo que invoca del flujo de trabajo secundario.
Aplica un límite de despacho a la cola de Cloud Tasks y ejecuta la flujo de trabajo superior.
Observa que los flujos de trabajo secundarios se ejecutan al ritmo definido a través del Lista de tareas en cola de Cloud Tasks.

Puedes ejecutar los siguientes comandos en la consola de Google Cloud o con el Google Cloud CLI en tu terminal o en Cloud Shell.

Costos

En este documento, usarás los siguientes componentes facturables de Google Cloud:

Para generar una estimación de costos en función del uso previsto, usa la calculadora de precios. Es posible que los usuarios nuevos de Google Cloud califiquen para obtener una prueba gratuita.

Antes de comenzar

Es posible que las restricciones de seguridad que define tu organización no te permitan completar los siguientes pasos. Para obtener información sobre la solución de problemas, consulta Desarrolla aplicaciones en un entorno de Google Cloud restringido.

Console

Accede a tu cuenta de Google.

Si todavía no tienes una cuenta, regístrate para obtener una nueva.

In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

Go to project selector

Asegúrate de que la facturación esté habilitada para tu proyecto de Google Cloud.

Enable the Cloud Tasks, Compute Engine, and Workflows APIs.

Enable the APIs

In the Google Cloud console, on the project selector page, select or create a Google Cloud project.

Go to project selector

Asegúrate de que la facturación esté habilitada para tu proyecto de Google Cloud.

Enable the Cloud Tasks, Compute Engine, and Workflows APIs.

Enable the APIs

En la consola de Google Cloud, ve a la página IAM para configurar permisos para la instancia de Compute Engine cuenta de servicio predeterminada.
Ir a IAM

Toma nota de la documentación de Compute Engine cuenta de servicio predeterminada, tal como la asociarás con los flujos de trabajo este instructivo con fines de prueba. Esta cuenta de servicio se crea una vez que se habilita o usa un servicio de Google Cloud que usa Compute Engine y el siguiente formato de correo electrónico:
```
PROJECT_NUMBER-compute@developer.gserviceaccount.com
```
Reemplaza PROJECT_NUMBER por tu Número del proyecto de Google Cloud. Puedes encontrar el número de tu proyecto en la Te damos la bienvenida de la consola de Google Cloud.

Para entornos de producción, recomendamos crear una cuenta de servicio nueva y otorgarle uno o más roles de IAM que contengan el permisos mínimos obligatorios y siguen el principio de privilegio mínimo.

Nota:
Según la configuración de la política de la organización, es posible que a la cuenta de servicio predeterminada se le otorgue automáticamente el rol de editor en tu proyecto. Te recomendamos inhabilitar la concesión automática de roles; para ello, aplica la restricción de la política de la organización iam.automaticIamGrantsForDefaultServiceAccounts. Si creaste tu organización después del 3 de mayo de 2024, esta restricción se aplica de forma predeterminada.

Si inhabilitas la concesión automática de roles, debes decidir qué roles se deben otorgar a las cuentas de servicio predeterminadas y, luego, otorgar estos roles a ti mismo.

Si la cuenta de servicio predeterminada ya tiene el rol de editor, te recomendamos que reemplaces el rol de editor por roles menos permisivos. Para modificar de forma segura los roles de la cuenta de servicio, usa Policy Simulator para ver el impacto del cambio y, luego, otorga y revoca los roles adecuados.
Selecciona la cuenta de servicio predeterminada de Compute Engine haz clic en Editar principal.
En el cuadro de diálogo que aparece, haz clic en add Agrega otro rol y agrega los siguientes roles:
1. En la lista Selecciona un rol, Workflows > Invocador de Workflows para que la tiene permiso para activar la ejecución de su flujo de trabajo.
2. En la lista Selecciona un rol, Cloud Tasks > Agregador de elementos en cola de Cloud Tasks tiene permiso para crear tareas.
Haz clic en Guardar.

gcloud

Accede a tu cuenta de Google.

Si todavía no tienes una cuenta, regístrate para obtener una nueva.

Install the Google Cloud CLI.

To initialize the gcloud CLI, run the following command:

gcloud init

Create or select a Google Cloud project.

Create a Google Cloud project:
```
gcloud projects create PROJECT_ID
```
Replace PROJECT_ID with a name for the Google Cloud project you are creating.
Select the Google Cloud project that you created:
```
gcloud config set project PROJECT_ID
```
Replace PROJECT_ID with your Google Cloud project name.

Asegúrate de que la facturación esté habilitada para tu proyecto de Google Cloud.

Enable the Cloud Tasks, Compute Engine, and Workflows APIs:

gcloud services enable cloudtasks.googleapis.com compute.googleapis.com workflows.googleapis.com

Install the Google Cloud CLI.

To initialize the gcloud CLI, run the following command:

gcloud init

Create or select a Google Cloud project.

Create a Google Cloud project:
```
gcloud projects create PROJECT_ID
```
Replace PROJECT_ID with a name for the Google Cloud project you are creating.
Select the Google Cloud project that you created:
```
gcloud config set project PROJECT_ID
```
Replace PROJECT_ID with your Google Cloud project name.

Asegúrate de que la facturación esté habilitada para tu proyecto de Google Cloud.

Enable the Cloud Tasks, Compute Engine, and Workflows APIs:

gcloud services enable cloudtasks.googleapis.com compute.googleapis.com workflows.googleapis.com

Toma nota de la documentación de Compute Engine cuenta de servicio predeterminada, tal como la asociarás con los flujos de trabajo este instructivo con fines de prueba. Esta cuenta de servicio se crea una vez que se habilita o usa un servicio de Google Cloud que usa Compute Engine y el siguiente formato de correo electrónico:
```
PROJECT_NUMBER-compute@developer.gserviceaccount.com
```
Reemplaza PROJECT_NUMBER por tu Número del proyecto de Google Cloud. Puedes buscar el número de tu proyecto mediante la ejecución del siguiente comando:
```
gcloud projects describe PROJECT_ID --format='value(projectNumber)'
```
Para entornos de producción, recomendamos crear una cuenta de servicio nueva y otorgarle uno o más roles de IAM que contengan el permisos mínimos obligatorios y siguen el principio de privilegio mínimo.

Nota:
Según la configuración de la política de la organización, es posible que a la cuenta de servicio predeterminada se le otorgue automáticamente el rol de editor en tu proyecto. Te recomendamos inhabilitar la concesión automática de roles; para ello, aplica la restricción de la política de la organización iam.automaticIamGrantsForDefaultServiceAccounts. Si creaste tu organización después del 3 de mayo de 2024, esta restricción se aplica de forma predeterminada.

Si inhabilitas la concesión automática de roles, debes decidir qué roles se deben otorgar a las cuentas de servicio predeterminadas y, luego, otorgar estos roles a ti mismo.

Si la cuenta de servicio predeterminada ya tiene el rol de editor, te recomendamos que reemplaces el rol de editor por roles menos permisivos. Para modificar de forma segura los roles de la cuenta de servicio, usa Policy Simulator para ver el impacto del cambio y, luego, otorga y revoca los roles adecuados.
Otorga el Función de invocador de flujos de trabajo (roles/workflows.invoker) del proyecto al de Compute Engine para que la cuenta tenga permiso para activar la ejecución del flujo de trabajo.
```
gcloud projects add-iam-policy-binding PROJECT_ID \
    --member=serviceAccount:PROJECT_NUMBER-compute@developer.gserviceaccount.com \
    --role=roles/workflows.invoker
```
Reemplaza lo siguiente:
- PROJECT_ID: El ID del proyecto de Google Cloud
- PROJECT_NUMBER: Es el número del proyecto de Google Cloud.

Otorga el Rol de agregador en cola de Cloud Tasks (roles/cloudtasks.enqueuer) del proyecto al de Compute Engine para que la cuenta tenga permiso para crear tareas.

gcloud projects add-iam-policy-binding PROJECT_ID \
    --member=serviceAccount:PROJECT_NUMBER-compute@developer.gserviceaccount.com \
    --role=roles/cloudtasks.enqueuer

Crea una cola de Cloud Tasks

Crea una cola de Cloud Tasks que puedas usar en el nivel superior y que permite regular la frecuencia de ejecución del flujo de trabajo.

Console

En la consola de Google Cloud, ve a Cloud Tasks página:

Ir a Cloud Tasks
Haz clic en . Crea una lista de aplicaciones en cola.
Ingresa el Nombre de la cola, queue-workflow-child.
En la lista Región, selecciona us-central1 (Iowa).
Haz clic en Crear.

gcloud

QUEUE=queue-workflow-child
LOCATION=us-central1
gcloud tasks queues create $QUEUE --location=$LOCATION

Crea e implementa un flujo de trabajo secundario

Un flujo de trabajo secundario puede recibir y procesar datos de un flujo de trabajo superior. Crea y implementar un flujo de trabajo secundario que realice las siguientes acciones:

Recibe un iteration como argumento.
Se suspende durante 10 segundos para simular un procesamiento.
Devuelve una cadena cuando se ejecuta correctamente

Console

En la consola de Google Cloud, ve a la página Flujos de trabajo.

Ir a Workflows
Haz clic en Crear.
Ingresa el nombre, workflow-child, para el flujo de trabajo nuevo.
En la lista Región, selecciona us-central1 (Iowa).
En la lista Cuenta de servicio, selecciona la Cuenta de servicio predeterminada de Compute Engine.
Haz clic en Siguiente.

En el editor de flujos de trabajo, ingresa la siguiente definición para tu flujo de trabajo:

main:
  params: [args]
  steps:
    - init:
        assign:
          - iteration : ${args.iteration}
    - wait:
        call: sys.sleep
        args:
            seconds: 10
    - return_message:
        return: ${"Hello world"+iteration}

Haz clic en Implementar.

gcloud

Crea un archivo de código fuente para tu flujo de trabajo:
```
touch workflow-child.yaml
```

Abre tu archivo de código fuente en un editor de texto y copia el siguiente flujo de trabajo al archivo.

main:
  params: [args]
  steps:
    - init:
        assign:
          - iteration : ${args.iteration}
    - wait:
        call: sys.sleep
        args:
            seconds: 10
    - return_message:
        return: ${"Hello world"+iteration}

Implementa el flujo de trabajo:

gcloud workflows deploy workflow-child \
    --source=workflow-child.yaml \
    --location=us-central1 \
    --service-account=PROJECT_NUMBER-compute@developer.gserviceaccount.com

Crea e implementa el flujo de trabajo superior

El flujo de trabajo superior ejecuta varias ramas del flujo de trabajo secundario a través de un for.

Copia el código fuente que define el flujo de trabajo superior:

main:
  steps:
    - init:
        assign:
          - project_id: ${sys.get_env("GOOGLE_CLOUD_PROJECT_ID")}
          - project_number: ${sys.get_env("GOOGLE_CLOUD_PROJECT_NUMBER")}
          - location: ${sys.get_env("GOOGLE_CLOUD_LOCATION")}
          - workflow_child_name: "workflow-child"
          - queue_name: "queue-workflow-child"
    - enqueue_tasks_to_execute_child_workflow:
        for:
          value: iteration
          range: [1, 100]
          steps:
              - iterate:
                  assign:
                    - data:
                        iteration: ${iteration}
                    - exec:
                        # Encode object to JSON string in expression for workflow argument
                        argument: ${json.encode_to_string(data)}
              - create_task_to_execute_child_workflow:
                  call: googleapis.cloudtasks.v2.projects.locations.queues.tasks.create
                  args:
                      parent: ${"projects/" + project_id + "/locations/" + location + "/queues/" + queue_name}
                      body:
                        task:
                          httpRequest:
                            body: ${base64.encode(json.encode(exec))}
                            url: ${"https://workflowexecutions.googleapis.com/v1/projects/" + project_id + "/locations/" + location + "/workflows/" + workflow_child_name + "/executions"}
                            oauthToken:
                              serviceAccountEmail: ${project_number + "-compute@developer.gserviceaccount.com"}

El flujo de trabajo consta de las siguientes partes:

Es un mapa que se usa para asignar constantes que hacen referencia al flujo de trabajo secundario. y el nombre de la cola de Cloud Tasks. Para obtener más información, consulta Maps.
Un bucle for que se ejecuta para invocar el flujo de trabajo secundario de manera iterativa. Para obtener más información, consulta Iteración.
Un paso del flujo de trabajo que crea y agrega una gran cantidad de tareas al Se pone en cola de Cloud Tasks para ejecutar el flujo de trabajo secundario. Para ver más información, consulta Conector de la API de Cloud Tasks.

Implementa el flujo de trabajo:
Console
1. En la consola de Google Cloud, ve a Workflows página:
  
  Ir a Workflows
2. Haz clic en Crear.
3. Ingresa el nombre, workflow-parent, para el flujo de trabajo nuevo.
4. En la lista Región, selecciona us-central1 (Iowa).
5. En la lista Cuenta de servicio, selecciona la Cuenta de servicio predeterminada de Compute Engine.
6. Haz clic en Siguiente.
7. En el editor de flujos de trabajo, pega la definición del flujo de trabajo superior.
8. Haz clic en Implementar.
gcloud
1. Crea un archivo de código fuente para tu flujo de trabajo:
  touch workflow-parent.yaml
2. Abre tu archivo de código fuente en un editor de texto y pega la definición para el flujo de trabajo superior.
3. Implementa el flujo de trabajo:
  gcloud workflows deploy workflow-parent \ --source=workflow-parent.yaml \ --location=us-central1 \ --service-account=PROJECT_NUMBER-compute@developer.gserviceaccount.com

Ejecuta el flujo de trabajo superior sin límites de frecuencia

Ejecuta el flujo de trabajo superior para invocar los flujos de trabajo secundarios a través del Lista de tareas en cola de Cloud Tasks. Las ejecuciones deberían tardar alrededor de 10 segundos en completarse.

Console

En la consola de Google Cloud, ve a Workflows página:

Ir a Workflows
En la página Flujos de trabajo, haz clic en el workflow-parent para ir a su página de detalles.
En la página Detalles del flujo de trabajo, haz clic en Ejecución.
Haz clic de nuevo en Ejecutar.
Mientras se ejecuta el flujo de trabajo superior, vuelve a Flujos de trabajo y haz clic en el workflow-child para ir a su página de detalles.
Haz clic en la pestaña Ejecuciones.

Deberías ver ejecuciones del flujo de trabajo secundario, prácticamente de la misma forma. tiempo, similar a lo siguiente:

gcloud

Ejecuta el flujo de trabajo:

gcloud workflows run workflow-parent \
     --location=us-central1

Para verificar que se activó la ejecución de un flujo de trabajo, enumera los últimos cuatro ejecuciones:

gcloud workflows executions list workflow-child --limit=4

Dado que la cantidad de ejecuciones (100 ) es inferior a la de simultaneidad de Workflows, los resultados deben tener similares a los siguientes. Pueden surgir problemas con las cuotas si envías miles de ejecuciones al mismo tiempo.

NAME: projects/620278351741/locations/us-central1/workflows/workflow-child/executions/1570d06e-d133-4536-a859-b7b6a1a85524
STATE: ACTIVE
START_TIME: 2023-07-27T00:56:15.093934448Z
END_TIME:
NAME: projects/620278351741/locations/us-central1/workflows/workflow-child/executions/82724960-7d92-4961-aa2c-a0f0be46212c
STATE: ACTIVE
START_TIME: 2023-07-27T00:56:14.903007626Z
END_TIME:
NAME: projects/620278351741/locations/us-central1/workflows/workflow-child/executions/598126fb-37f9-45bc-91d8-aea7d795d702
STATE: ACTIVE
START_TIME: 2023-07-27T00:56:14.698260524Z
END_TIME:
NAME: projects/620278351741/locations/us-central1/workflows/workflow-child/executions/d2e9960b-f93f-4df4-a594-3e7e5c2be53f
STATE: ACTIVE
START_TIME: 2023-07-27T00:56:14.503818840Z
END_TIME:

Creaste e implementaste un flujo de trabajo que invoca 100 iteraciones del del flujo de trabajo secundario.

Ejecuta el flujo de trabajo superior con límites de frecuencia

Aplica un límite de frecuencia de un envío por segundo a Cloud Tasks y ejecutar el flujo de trabajo superior.

Console

En la consola de Google Cloud, ve a Cloud Tasks página:

Ir a Cloud Tasks
Haz clic en queue-workflow-child, la cola de Cloud Tasks que creaste y haz clic en Editar cola.
En la sección Límites de frecuencia para envíos de tareas, de la Máximo de envíos, tipo 1.
Haz clic en Guardar.
Ve a la página Flujos de trabajo:

Ir a Workflows
Haz clic en el flujo de trabajo workflow-parent para ir a su página de detalles.
En la página Detalles del flujo de trabajo, haz clic en Ejecución.
Haz clic de nuevo en Ejecutar.
Mientras se ejecuta el flujo de trabajo superior, vuelve a Flujos de trabajo y haz clic en el workflow-child para ir a su página de detalles.
Haz clic en la pestaña Ejecuciones.

Deberías ver ejecuciones del flujo de trabajo secundario en una sola solicitud por segundo, de la siguiente manera:

gcloud

Actualiza la cola de Cloud Tasks para aplicar un límite de frecuencia de uno envío por segundo:

gcloud tasks queues update $QUEUE \
    --max-dispatches-per-second=1 \
    --location=us-central1

Ejecuta el flujo de trabajo:

gcloud workflows run workflow-parent \
   --location=us-central1

Para verificar que se activó la ejecución de un flujo de trabajo, enumera los últimos cuatro ejecuciones:

gcloud workflows executions list workflow-child --limit=4

Los resultados deberían ser similares a los siguientes, con un flujo de trabajo ejecutado por segundo:

NAME: projects/620278351741/locations/us-central1/workflows/workflow-child/executions/becf4957-9fb2-40d9-835d-0ff2dd0c1249
STATE: ACTIVE
START_TIME: 2023-07-27T01:07:24.446361457Z
END_TIME:
NAME: projects/620278351741/locations/us-central1/workflows/workflow-child/executions/6c1e7c4b-7ac6-4121-b351-1e2d56d10903
STATE: ACTIVE
START_TIME: 2023-07-27T01:07:23.448213989Z
END_TIME:
NAME: projects/620278351741/locations/us-central1/workflows/workflow-child/executions/f2ba5027-af40-4cd3-8cd0-b8033bcc6211
STATE: ACTIVE
START_TIME: 2023-07-27T01:07:22.431485914Z
END_TIME:
NAME: projects/620278351741/locations/us-central1/workflows/workflow-child/executions/ecc61ee5-fe87-49eb-8803-89dba929f6c8
STATE: ACTIVE
START_TIME: 2023-07-27T01:07:21.443466369Z
END_TIME:

Implementaste correctamente un flujo de trabajo que invoca 100 iteraciones del flujo de trabajo secundario con una frecuencia de despacho de una ejecución por segundo.

Limpia

Si creaste un proyecto nuevo para este instructivo, bórralo. Si usaste un proyecto existente y deseas conservarlo sin los cambios que se agregaron en este instructivo, borra los recursos creados para el instructivo.

Borra el proyecto

La manera más fácil de eliminar la facturación es borrar el proyecto que creaste para el instructivo.

Para borrar el proyecto, haz lo siguiente:

Precaución: Borrar un proyecto tiene estas consecuencias:

Se borra todo en el proyecto. Si usaste un proyecto existente para las tareas de este documento, cuando lo borres, también se borrará cualquier otro trabajo que hayas realizado en el proyecto.
Se pierden los ID personalizados de proyectos. Cuando creaste este proyecto, es posible que hayas creado un ID del proyecto personalizado que desees utilizar en el futuro. Para conservar las URL que utilizan el ID del proyecto, como una URL appspot.com, borra los recursos seleccionados dentro del proyecto en lugar de borrar todo el proyecto.

Si planeas explorar varias infraestructuras, instructivos y guías de inicio rápido la reutilización de proyectos puede ayudarte a evitar exceder los límites de las cuotas del proyecto.

En la consola de Google Cloud, ve a la página Administrar recursos.
Ir a Administrar recursos
En la lista de proyectos, elige el proyecto que quieres borrar y haz clic en Borrar.
En el diálogo, escribe el ID del proyecto y, luego, haz clic en Cerrar para borrar el proyecto.

Elimina recursos de instructivos

Borra los flujos de trabajo y los recursos de Cloud Tasks creados en esta instructivo:

Console

Para borrar los flujos de trabajo, sigue estos pasos:
1. En la consola de Google Cloud, ve a Workflows página:
  
  Ir a Workflows
2. En la lista de flujos de trabajo, haz clic en un flujo de trabajo para ir a su Detalles del flujo de trabajo.
3. Haz clic en Borrar.
4. Escribe el nombre del flujo de trabajo y, luego, haz clic en Confirmar.
Para borrar la cola de Cloud Tasks, sigue estos pasos:
1. En la consola de Google Cloud, ve a Cloud Tasks página:
  
  Ir a Cloud Tasks
2. Selecciona el nombre de la cola que deseas borrar y haz clic en Borra la cola.
3. Confirma la acción.

gcloud

Para borrar los flujos de trabajo, ejecuta los siguientes comandos:

gcloud workflows delete workflow-child
gcloud workflows delete workflow-parent

Para borrar la cola de Cloud Tasks, ejecuta este comando:
```
gcloud tasks queues delete queue-workflow-child
```

¿Qué sigue?

Para obtener más información sobre cómo usar Cloud Tasks para poner en cola un flujo de trabajo y ejecútalo de forma asíncrona. Consulta Cómo poner en cola ejecuciones de flujos de trabajo con Cloud Tasks.
Para obtener más información sobre la sintaxis de Workflows, consulta la Referencia de sintaxis de Workflows.