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

Ejecutar un flujo de trabajo que ejecute otros flujos de trabajo en paralelo

En este instructivo, se muestra cómo crear y ejecutar un flujo de trabajo superior que se ejecute varios flujos de trabajo secundarios en paralelo.

En el siguiente diagrama, se muestran cuatro ejecuciones paralelas del flujo de trabajo secundario se invocan. Esto permite que el flujo de trabajo superior procese datos en ramas paralelas, y reduce el tiempo de ejecución general. El flujo de trabajo superior espera de flujos de trabajo secundarios que finalicen antes de mostrar un resumen de las ejecuciones correctas ejecuciones fallidas, lo que simplifica cualquier detección de errores.

Flujo de trabajo superior que invoca iteraciones paralelas de un flujo de trabajo secundario

Objetivos

En este instructivo, realizarás las siguientes acciones:

Crea e implementa un flujo de trabajo secundario que reciba datos de un flujo de trabajo superior.
Crear e implementar un flujo de trabajo superior que ejecute varios flujos de trabajo secundarios con un bucle for paralelo.
Ejecutar el flujo de trabajo superior que invoca ejecuciones paralelas del elemento secundario en el flujo de trabajo.
Se almacenan los resultados de todas las ejecuciones de flujos de trabajo secundarios exitosos y fallidos. y se muestran en un mapa.

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:

Workflows

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 Workflow Executions and Workflows APIs.

Enable the APIs

Create a service account:

In the Google Cloud console, go to the Create service account page.
Go to Create service account
Select your project.
In the Service account name field, enter a name. The Google Cloud console fills in the Service account ID field based on this name.

In the Service account description field, enter a description. For example, Service account for quickstart.
Click Create and continue.
Grant the Workflows > Workflows Invoker role to the service account.

To grant the role, find the Select a role list, then select Workflows > Workflows Invoker.

Note: The Role field affects which resources the service account can access in your project. You can revoke these roles or grant additional roles later. In production environments, do not grant the Owner, Editor, or Viewer roles. Instead, grant a predefined role or custom role that meets your needs.
Click Continue.
Click Done to finish creating the service account.

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 Workflow Executions and Workflows APIs.

Enable the APIs

Create a service account:

In the Google Cloud console, go to the Create service account page.
Go to Create service account
Select your project.
In the Service account name field, enter a name. The Google Cloud console fills in the Service account ID field based on this name.

In the Service account description field, enter a description. For example, Service account for quickstart.
Click Create and continue.
Grant the Workflows > Workflows Invoker role to the service account.

To grant the role, find the Select a role list, then select Workflows > Workflows Invoker.

Note: The Role field affects which resources the service account can access in your project. You can revoke these roles or grant additional roles later. In production environments, do not grant the Owner, Editor, or Viewer roles. Instead, grant a predefined role or custom role that meets your needs.
Click Continue.
Click Done to finish creating the service account.

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 Workflow Executions and Workflows APIs:

gcloud services enable workflowexecutions.googleapis.com workflows.googleapis.com

Set up authentication:

Create the service account:
```
gcloud iam service-accounts create SERVICE_ACCOUNT_NAME
```
Replace SERVICE_ACCOUNT_NAME with a name for the service account.
Grant the roles/workflows.invoker IAM role to the service account:
```
gcloud projects add-iam-policy-binding PROJECT_ID --member="serviceAccount:SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com" --role=roles/workflows.invoker
```
Replace the following:
- SERVICE_ACCOUNT_NAME: the name of the service account
- PROJECT_ID: the project ID where you created the service account
Note: The --role flag affects which resources the service account can access in your project. You can revoke these roles or grant additional roles later. In production environments, do not grant the Owner, Editor, or Viewer roles. Instead, grant a predefined role or custom role that meets your needs.

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 Workflow Executions and Workflows APIs:

gcloud services enable workflowexecutions.googleapis.com workflows.googleapis.com

Set up authentication:

Create the service account:
```
gcloud iam service-accounts create SERVICE_ACCOUNT_NAME
```
Replace SERVICE_ACCOUNT_NAME with a name for the service account.
Grant the roles/workflows.invoker IAM role to the service account:
```
gcloud projects add-iam-policy-binding PROJECT_ID --member="serviceAccount:SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com" --role=roles/workflows.invoker
```
Replace the following:
- SERVICE_ACCOUNT_NAME: the name of the service account
- PROJECT_ID: the project ID where you created the service account
Note: The --role flag affects which resources the service account can access in your project. You can revoke these roles or grant additional roles later. In production environments, do not grant the Owner, Editor, or Viewer roles. Instead, grant a predefined role or custom role that meets your needs.

Crea e implementa un flujo de trabajo secundario

Un flujo de trabajo secundario puede recibir y procesar datos de un flujo de trabajo superior. El niño flujo de trabajo demuestra esto de la siguiente manera:

Recibe un número entero como argumento.
Se suspende durante 10 segundos para simular un procesamiento.
Devuelve un indicador (en función de si el número entero es impar o par) para simular el éxito o el fracaso de la ejecución del flujo de trabajo

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.
Selecciona la Cuenta de servicio que creaste con anterioridad.
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
    - check_iteration_even_or_odd:
        switch:
          - condition: ${iteration % 2 == 0}
            next: raise_error
    - return_message:
        return: ${"Hello world"+iteration}
    - raise_error:
        raise: ${"Error with iteration "+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
    - check_iteration_even_or_odd:
        switch:
          - condition: ${iteration % 2 == 0}
            next: raise_error
    - return_message:
        return: ${"Hello world"+iteration}
    - raise_error:
        raise: ${"Error with iteration "+iteration}

Implementa el flujo de trabajo:

gcloud workflows deploy workflow-child \
    --source=workflow-child.yaml \
    --location=us-central1 \
    --service-account=SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com

Reemplaza SERVICE_ACCOUNT_NAME por el nombre del cuenta de servicio creada anteriormente.

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 bucle for paralelo.

Copia el código fuente para la definición del flujo de trabajo. Consta de los siguientes partes:

Se usa un mapa para almacenar los resultados de las ejecuciones de flujos de trabajo secundarios. Para obtener más información, consulta Maps.

main:
  steps:
    - init:
        assign:
          - execution_results: {} # results from each execution
          - execution_results.success: {} # successful executions saved under 'success' key
          - execution_results.failure: {} # failed executions saved under 'failure' key

Se ejecuta un bucle for en paralelo para invocar el flujo de trabajo secundario. Para obtener más información, consulta Los pasos paralelos y Iteración.

- execute_child_workflows:
    parallel:
      shared: [execution_results]
      for:
        value: iteration
        in: [1, 2, 3, 4]
        steps:
            - iterate:

El flujo de trabajo secundario se invoca mediante un conector. Cada iteración del al flujo de trabajo secundario se le pasa el argumento iteration. Flujo de trabajo superior espera y almacena el resultado de cada ejecución del flujo de trabajo secundario. Para ver más información, consulta Conector de la API de Workflows Executions y Argumentos del entorno de ejecución.

try:
  steps:
    - execute_child_workflow:
        call: googleapis.workflowexecutions.v1.projects.locations.workflows.executions.run
        args:
          workflow_id: workflow-child
          #location: ...
          #project_id: ...
          argument:
            iteration: ${iteration}
        result: execution_result
    - save_successful_execution:
        assign:
          - execution_results.success[string(iteration)]: ${execution_result}
except:
    as: e
    steps:
      - save_failed_execution:
          assign:
            - execution_results.failure[string(iteration)]: ${e}

Se muestran los resultados de la ejecución. Para obtener más información, consulta Completa la ejecución de un flujo de trabajo.
```
- return_execution_results:
    return: ${execution_results}
```

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.
5. Selecciona la Cuenta de servicio que creaste con anterioridad.
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=SERVICE_ACCOUNT_NAME@PROJECT_ID.iam.gserviceaccount.com
  Reemplaza SERVICE_ACCOUNT_NAME por el nombre de la cuenta de servicio que creaste previamente.

Ejecuta el flujo de trabajo superior

Ejecuta el flujo de trabajo superior para que las invocaciones del flujo de trabajo secundario se ejecuten en en paralelo. Las ejecuciones deberían tardar unos 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.

Observa los resultados del flujo de trabajo en el panel Output.

Los resultados deberían ser similares a los siguientes y mostrar errores con las iteraciones 2 y 4, y el éxito con las iteraciones 1 y 3.

"failure": {
  "2": {
    "message": "Execution failed or cancelled.",
    "operation": {
      "argument": "{\"iteration\":2}",
      "duration": "10.157992541s",
      "endTime": "2023-07-11T13:13:13.028424329Z",
      "error": {
        "context": "RuntimeError: \"Error with iteration 2\"\nin step \"raise_error\", routine \"main\", line: 18",
        "payload": "\"Error with iteration 2\"",
...
  "4": {
    "message": "Execution failed or cancelled.",
    "operation": {
      "argument": "{\"iteration\":4}",
      "duration": "10.157929734s",
      "endTime": "2023-07-11T13:13:13.061289142Z",
      "error": {
        "context": "RuntimeError: \"Error with iteration 4\"\nin step \"raise_error\", routine \"main\", line: 18",
        "payload": "\"Error with iteration 4\"",
...
"success": {
  "1": "Hello world1",
  "3": "Hello world3"

gcloud

Ejecuta el flujo de trabajo:

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

Los resultados deberían ser similares a los siguientes y mostrar errores con las iteraciones 2 y 4, y el éxito con las iteraciones 1 y 3.

Waiting for execution [06c753e4-6947-4c62-ac0b-2a9d53fb1b8f] to complete...done.
argument: 'null'
duration: 14.065415004s
endTime: '2023-07-11T12:50:43.929023883Z'
name: projects/386837416586/locations/us-central1/workflows/workflow-parent/executions/06c753e4-6947-4c62-ac0b-2a9d53fb1b8f
result: '{"failure":{"2":{"message":"Execution failed or cancelled.","operation":{"argument":"{\"iteration\":2}","duration":"10.143718070s","endTime":"2023-07-11T12:50:40.673209821Z","error":{"context":"RuntimeError:
...
"Error with iteration 2\"\nin step \"raise_error\", routine \"main\", line: 18","payload":"\"Error
...
"Error with iteration 4\"\nin step \"raise_error\", routine \"main\", line: 18","payload":"\"Error
...
"success":{"1":"Hello world1","3":"Hello world3"}}'
startTime: '2023-07-11T12:50:29.863608879Z'
state: SUCCEEDED

Creaste e implementaste correctamente un flujo de trabajo que invoca un elemento secundario de Google Cloud ejecuta cuatro iteraciones del flujo de trabajo secundario en ramas paralelas y muestra un indicador de éxito o fracaso de la ejecución de cada flujo de trabajo secundario.

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 que creaste en este instructivo:

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

¿Qué sigue?

Para obtener más información sobre la sintaxis de Workflows, consulta la Referencia de sintaxis de Workflows.
Para obtener más información sobre los conectores de Workflows, consulta Información sobre los conectores.