Ejecuta un flujo de trabajo

Console

1. Para ejecutar un flujo de trabajo, en la Google Cloud consola, ve a la página Workflows:

   Ir a Workflows

2. En la página Flujos de trabajo, selecciona un flujo de trabajo para ir a su página de detalles.

3. En la página Detalles del flujo de trabajo, haz clic en play_arrow Ejecutar.

4. En la página Ejecutar flujo de trabajo, en el panel Entrada, puedes ingresar argumentos de entorno de ejecución opcionales para pasarlos a tu flujo de trabajo antes de la ejecución. Los argumentos deben estar en formato JSON, por ejemplo, {"animal":"cat"}. Si tu flujo de trabajo no usa argumentos de tiempo de ejecución, déjalo en blanco.

5. De manera opcional, especifica el nivel de registro de llamadas que deseas aplicar a la ejecución del flujo de trabajo. En la lista Nivel de registro de llamadas, selecciona una de las siguientes opciones:

   • No especificado: No se especifica ningún nivel de registro. Esta es la opción predeterminada. Un nivel de registro de ejecución tiene prioridad sobre cualquier nivel de registro de flujo de trabajo, a menos que no se especifique el nivel de registro de ejecución (predeterminado). En ese caso, se aplica el nivel de registro del flujo de trabajo.
   • Solo errores: Registra todas las excepciones detectadas, o cuando se detiene una llamada debido a una excepción.
   • Todas las llamadas: Registra todas las llamadas a subflujos de trabajo o funciones de biblioteca y sus resultados.
   • Sin registros: Sin registro de llamadas.

6. De manera opcional, especifica el nivel de historial de ejecución que deseas aplicar a la ejecución del flujo de trabajo. En la lista Historial de ejecución, selecciona una de las siguientes opciones:

   • Heredar del flujo de trabajo: Aplica la configuración del historial de ejecución del flujo de trabajo. Esta es la opción predeterminada.
   • Básica: Habilita el historial de ejecuciones básico.
   • Detallado: Habilita el historial de ejecución detallado, incluidos los valores de las variables dentro del alcance y la cantidad esperada de iteraciones.

7. Haz clic en Ejecutar.

8. En la página Detalles de la ejecución, puedes ver los resultados de la ejecución, incluidos los resultados, el ID y el estado de la ejecución, y el paso actual o final de la ejecución del flujo de trabajo. Para obtener más información, consulta Cómo acceder a los resultados de la ejecución de un flujo de trabajo.

gcloud

1. Abre una terminal.

2. Busca el nombre del flujo de trabajo que deseas ejecutar. Si no conoces el nombre del flujo de trabajo, puedes ingresar el siguiente comando para ver una lista de todos tus flujos de trabajo:

   gcloud workflows list

3. Puedes ejecutar el flujo de trabajo con el comando gcloud workflows run o el comando gcloud workflows execute:

   • Ejecuta el flujo de trabajo y espera a que se complete la ejecución:

     gcloud workflows run WORKFLOW_NAME \
         --call-log-level=CALL_LOGGING_LEVEL \
         --execution-history-level="EXECUTION_HISTORY_LEVEL" \
         --data=DATA

   • Ejecuta el flujo de trabajo sin esperar a que finalice el intento de ejecución:

     gcloud workflows execute WORKFLOW_NAME \
         --call-log-level=CALL_LOGGING_LEVEL \
         --execution-history-level="EXECUTION_HISTORY_LEVEL" \
         --data=DATA

     Reemplaza lo siguiente:

     • WORKFLOW_NAME: El nombre del flujo de trabajo.

     • CALL_LOGGING_LEVEL (opcional): Es el nivel de registro de llamadas que se aplicará durante la ejecución. Puede ser una de las siguientes opciones:

       • none: No se especifica ningún nivel de registro. Esta es la opción predeterminada. Un nivel de registro de ejecución tiene prioridad sobre cualquier nivel de registro de flujo de trabajo, a menos que no se especifique el nivel de registro de ejecución (predeterminado). En ese caso, se aplica el nivel de registro del flujo de trabajo.
       • log-errors-only: Registra todas las excepciones detectadas; o cuando se detiene una llamada debido a una excepción.
       • log-all-calls: Registra todas las llamadas a subflujos de trabajo o funciones de biblioteca y sus resultados.
       • log-none: Sin registro de llamadas.

     • EXECUTION_HISTORY_LEVEL (opcional): Es el nivel del historial de ejecuciones que se aplicará durante la ejecución. Puede ser una de las siguientes opciones:

       • none: No se especifica ningún nivel de historial de ejecución. Esta es la opción predeterminada. Si no se especifica un nivel de historial de ejecución para una ejecución, se determina según el nivel aplicado al flujo de trabajo. Si los niveles son diferentes, la configuración aplicada a nivel de la ejecución anula la configuración aplicada a nivel del flujo de trabajo para esta ejecución.
       • execution-history-basic: Habilita el historial de ejecución básico.
       • execution-history-detailed: Habilita el historial de ejecución detallado, incluidos los valores de las variables dentro del alcance y la cantidad esperada de iteraciones.

     • DATA (opcional): Son los argumentos del tiempo de ejecución para tu flujo de trabajo en formato JSON.

4. Si ejecutaste gcloud workflows execute, se muestra el ID único del intento de ejecución del flujo de trabajo y el resultado es similar al siguiente:

    To view the workflow status, you can use following command:
    gcloud workflows executions describe b113b589-8eff-4968-b830-8d35696f0b33 --workflow workflow-2 --location us-central1

   Para ver el estado de la ejecución, ingresa el comando que muestra el paso anterior.

Si el intento de ejecución se realiza de forma correcta, el resultado es similar al siguiente, con un state que indica que el flujo de trabajo se realizó correctamente y un status que especifica el paso final del flujo de trabajo de la ejecución.

argument: '{"searchTerm":"Friday"}'
endTime: '2022-06-22T12:17:53.086073678Z'
name: projects/1051295516635/locations/us-central1/workflows/myFirstWorkflow/executions/c4dffd1f-13db-46a0-8a4a-ee39c144cb96
result: '["Friday","Friday the 13th (franchise)","Friday Night Lights (TV series)","Friday
    the 13th (1980 film)","Friday the 13th","Friday the 13th (2009 film)","Friday the
    13th Part III","Friday the 13th Part 2","Friday (Rebecca Black song)","Friday Night
    Lights (film)"]'
startTime: '2022-06-22T12:17:52.799387653Z'
state: SUCCEEDED
status:
    currentSteps:
    - routine: main
        step: returnOutput
workflowRevisionId: 000001-ac2

API de REST

Para crear una ejecución nueva con la revisión más reciente de un flujo de trabajo determinado, usa el método projects.locations.workflows.executions.create.

Antes de usar cualquiera de los datos de solicitud a continuación, realiza los siguientes reemplazos:

• PROJECT_NUMBER: Es el número de proyecto Google Cloudque aparece en la página Configuración de IAM y administración.
• LOCATION: La región en la que se implementa el flujo de trabajo, por ejemplo, us-central1.
• WORKFLOW_NAME: Es el nombre definido por el usuario para el flujo de trabajo, por ejemplo, myFirstWorkflow.
• PARAMETER: es opcional. Si el flujo de trabajo que ejecutas puede recibir argumentos de tiempo de ejecución que le pasas como parte de una solicitud de ejecución, puedes agregar al cuerpo de la solicitud una cadena con formato JSON cuyo valor sea uno o más pares de valor de parámetro escapados, por ejemplo, "{\"searchTerm\":\"asia\"}".
• VALUE: es opcional. Es el valor de un par clave-valor que tu flujo de trabajo puede recibir como argumento de tiempo de ejecución.
• CALL_LOGGING_LEVEL: es opcional. Es el nivel de registro de llamadas que se aplicará durante la ejecución. La opción predeterminada es que no se especifique ningún nivel de registro y, en su lugar, se aplique el nivel de registro del flujo de trabajo. Para obtener más información, consulta Cómo enviar registros a Logging. Uno de los siguientes:
  • CALL_LOG_LEVEL_UNSPECIFIED: No se especifica ningún nivel de registro y, en su lugar, se aplica el nivel de registro del flujo de trabajo. Esta es la opción predeterminada. De lo contrario, se aplica el nivel de registro de ejecución y tiene prioridad sobre el nivel de registro de flujo de trabajo.
  • LOG_ERRORS_ONLY: Registra todas las excepciones detectadas; o cuando se detiene una llamada debido a una excepción.
  • LOG_ALL_CALLS: Registra todas las llamadas a subflujos de trabajo o funciones de biblioteca y sus resultados.
  • LOG_NONE: Sin registro de llamadas.
• BACKLOG_EXECUTION: Opcional. Si se establece en true, la ejecución no se pone en cola cuando se agota la cuota de simultaneidad. Para obtener más información, consulta Administra el retraso en la ejecución.
• EXECUTION_HISTORY_LEVEL: Opcional. Es el nivel del historial de ejecución que se aplicará durante la ejecución. Para obtener más información, consulta Cómo ver el historial de los pasos de ejecución. Uno de los siguientes:
  • EXECUTION_HISTORY_LEVEL_UNSPECIFIED: No se especifica ningún nivel del historial de ejecución. Esta es la opción predeterminada. Si no se especifica un nivel de historial de ejecución para una ejecución, se determina según el nivel aplicado al flujo de trabajo. Si los niveles son diferentes, la configuración aplicada a nivel de la ejecución anula la configuración aplicada a nivel del flujo de trabajo para esta ejecución.
  • EXECUTION_HISTORY_BASIC: Habilita el historial de ejecución básico.
  • EXECUTION_HISTORY_ADVANCED: Habilita el historial de ejecución detallado, incluidos los valores de las variables dentro del alcance y la cantidad esperada de iteraciones.

Cuerpo JSON de la solicitud:

{
  "argument": "{\"PARAMETER\":\"VALUE\"}",
  "callLogLevel": "CALL_LOGGING_LEVEL",
  "disableConcurrencyQuotaOverflowBuffering": "BACKLOG_EXECUTION",
  "executionHistoryLevel": "EXECUTION_HISTORY_LEVEL"
}

Para enviar tu solicitud, expande una de estas opciones:

cat > request.json << 'EOF'
{
  "argument": "{\"PARAMETER\":\"VALUE\"}",
  "callLogLevel": "CALL_LOGGING_LEVEL",
  "disableConcurrencyQuotaOverflowBuffering": "BACKLOG_EXECUTION",
  "executionHistoryLevel": "EXECUTION_HISTORY_LEVEL"
}
EOF

curl -X POST \
     -H "Authorization: Bearer $(gcloud auth print-access-token)" \
     -H "Content-Type: application/json; charset=utf-8" \
     -d @request.json \
     "https://workflowexecutions.googleapis.com/v1/projects/PROJECT_NUMBER/locations/LOCATION/workflows/WORKFLOW_NAME/executions"

@'
{
  "argument": "{\"PARAMETER\":\"VALUE\"}",
  "callLogLevel": "CALL_LOGGING_LEVEL",
  "disableConcurrencyQuotaOverflowBuffering": "BACKLOG_EXECUTION",
  "executionHistoryLevel": "EXECUTION_HISTORY_LEVEL"
}
'@  | Out-File -FilePath request.json -Encoding utf8

$cred = gcloud auth print-access-token
$headers = @{ "Authorization" = "Bearer $cred" }

Invoke-WebRequest `
    -Method POST `
    -Headers $headers `
    -ContentType: "application/json; charset=utf-8" `
    -InFile request.json `
    -Uri "https://workflowexecutions.googleapis.com/v1/projects/PROJECT_NUMBER/locations/LOCATION/workflows/WORKFLOW_NAME/executions" | Select-Object -Expand Content

Si el proceso se realiza de forma correcta, el cuerpo de la respuesta contiene una instancia recién creada de Execution:

{
  "name": "projects/PROJECT_NUMBER/locations/LOCATION/workflows/WORKFLOW_NAME/executions/EXECUTION_ID",
  "startTime": "2023-11-07T14:35:27.215337069Z",
  "state": "ACTIVE",
  "argument": "{\"PARAMETER\":\"VALUE\"}",
  "workflowRevisionId": "000001-2df",
  "callLogLevel": "CALL_LOGGING_LEVEL",
  "executionHistoryLevel": "EXECUTION_HISTORY_LEVEL",
  "status": {}
}