Puedes pasar argumentos del entorno de ejecución en una solicitud de ejecución de flujo de trabajo y acceder a esos argumentos con variables de flujo de trabajo.
Configura un flujo de trabajo que reciba argumentos de entorno de ejecución
Para configurar un flujo de trabajo que reciba argumentos de entorno de ejecución que le pases como parte de una solicitud de ejecución, haz lo siguiente:
Sigue los pasos para crear un flujo de trabajo nuevo o elige uno existente para actualizarlo, pero no lo implementes todavía.
Agrega un campo
params
a la definición del flujo de trabajo principal. Asegúrate de que el nombre del argumento esté dentro de corchetes y de que el flujo de trabajo principal esté en un bloquemain
:YAML
main: params: [ARG_NAME] steps: ...
JSON
{ "main": { "params": ["ARG_NAME"], "steps": [ ... ] ... } }
El bloque
main
acepta un solo argumento que es el nombre de cualquier tipo de datos JSON válido, por ejemplo, un array, un objeto o una cadena.Como práctica recomendada, pasar un objeto con varios argumentos con nombre facilita la comprensión de su propósito y la adición de argumentos. También puedes usar la notación de puntos para acceder a los argumentos.
Otros subflujos de trabajo pueden tener varios argumentos.
Por ejemplo, el siguiente flujo de trabajo muestra un saludo de “Hola” a una persona cuyo nombre y apellido pasas como argumentos de entorno de ejecución:
YAML
main: params: [args] steps: - step1: assign: - outputVar: ${"Hello, " + args.firstName + " " + args.lastName + "!"} - step2: return: ${outputVar}
JSON
{ "main": { "params": [ "args" ], "steps": [ { "step1": { "assign": [ { "outputVar": "${\"Hello \" + args.firstName + \" \" + args.lastName}" } ] } }, { "step2": { "return": "${outputVar}" } } ] } }
Implementa tu flujo de trabajo para terminar de crearlo o actualizarlo.
Cómo pasar datos en una solicitud de ejecución
Una vez que tu flujo de trabajo esté configurado para recibir argumentos de entorno de ejecución, puedes pasar una cadena
en formato JSON, como
{"firstName":"Workflows","lastName":"User"}
, al flujo de trabajo en una
solicitud de ejecución.
Console
Para ejecutar un flujo de trabajo, en la consola de Google Cloud, ve a la página Workflows:
En la página Flujos de trabajo, selecciona un flujo de trabajo para ir a su página de detalles.
En la página Detalles del flujo de trabajo, haz clic en play_arrow Ejecutar.
En la página "Execute workflow" que se muestra, ingresa una cadena JSON con los nombres de los parámetros y los valores de los argumentos, como
{"firstName":"Workflows","lastName":"User"}
, en el área "Input":Haz clic en Ejecutar.
En la página Detalles de la ejecución, puedes ver los resultados de la ejecución, incluido el resultado
Hello, Workflows User!
, el ID de ejecución y el estado, 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 del flujo de trabajo.
gcloud
Agrega la marca --data al comando gcloud workflows execute que usas para ejecutar tu flujo de trabajo. Esta marca toma una cadena JSON de tus datos. Por ejemplo, para pasar un firstName
y un lastName
al flujo de trabajo de ejemplo anterior, haz lo siguiente:
gcloud workflows run WORKFLOW_NAME \ --data='{"firstName":"FIRST","lastName":"LAST"}'
Reemplaza lo siguiente:
WORKFLOW_NAME
: El nombre del flujo de trabajoFIRST
: Es la cadena que deseas pasar a tu flujo de trabajo parafirstName
.LAST
: Es la cadena que deseas pasar a tu flujo de trabajo paralastName
.
El resultado debería ser similar al siguiente ejemplo:
Waiting for execution [9379b067-306a-4db1-a58d-c9fc99aebfd4] to complete...done.
argument: '{"firstName":"Workflows","lastName":"User"}'
endTime: '2022-07-19T13:52:47.659199466Z'
name: projects/1051295516635/locations/us-central1/workflows/workflow-6/executions/9379b067-306a-4db1-a58d-c9fc99aebfd4
result: '"Hello, Workflows User!"'
startTime: '2022-07-19T13:52:47.623862835Z'
state: SUCCEEDED
status:
currentSteps:
- routine: main
step: step2
workflowRevisionId: 000002-138
Bibliotecas cliente
Según el lenguaje de la biblioteca cliente, puedes pasar un argumento del entorno de ejecución en una solicitud de ejecución.
Por ejemplo, con JavaScript:
// Execute workflow
try {
const createExecutionRes = await client.createExecution({
parent: client.workflowPath(projectId, location, workflow),
execution: {
argument: JSON.stringify({"firstName":"Workflows","lastName":"User"})
}
});
const executionName = createExecutionRes[0].name;
O bien, usa Java:
// Creates the execution object.
CreateExecutionRequest request =
CreateExecutionRequest.newBuilder()
.setParent(parent.toString())
.setExecution(Execution.newBuilder().setArgument("{\"firstName\":\"Workflows\",\"lastName\":\"User\"}").build())
.build();
Para obtener más información sobre cómo ejecutar un flujo de trabajo con las bibliotecas cliente de la API de Google, consulta Cómo ejecutar un flujo de trabajo.
API de REST
Agrega la marca
data
al comando que usas para ejecutar tu flujo de trabajo. El valor dedata
es una cadena con formato JSON con un argumento cuyo valor es uno o más pares de valores de parámetros escapados. Por ejemplo, para pasar unfirstName
y unlastName
al flujo de trabajo de ejemplo anterior, haz lo siguiente:curl --request POST \ --header "Authorization: Bearer "$(gcloud auth application-default print-access-token) \ --header 'Content-Type: application/json' \ --data '{"argument":"{\"firstName\":\"FIRST\",\"lastName\":\"LAST\"}"}' \ "https://workflowexecutions.googleapis.com/v1/projects/PROJECT_NUMBER/locations/us-central1/workflows/WORKFLOW_NAME/executions"
Reemplaza lo siguiente:
PROJECT_NUMBER
: Es el número de tu proyecto de Google Cloud.WORKFLOW_NAME
: El nombre del flujo de trabajoFIRST
: Es la cadena que deseas pasar a tu flujo de trabajo parafirstName
.LAST
: Es la cadena que deseas pasar a tu flujo de trabajo paralastName
.
El resultado debería ser similar al siguiente ejemplo:
{ "name": "projects/PROJECT_NUMBER/locations/us-central1/workflows/WORKFLOW_NAME/executions/EXECUTION_ID", "startTime": "2020-11-09T23:51:31.765761331Z", "state": "ACTIVE", "argument": "{\"firstName\":\"Workflows\",\"lastName\":\"User\"}", "workflowRevisionId": "000001-08c" } ```
Para obtener los resultados de la ejecución, ejecuta el siguiente comando:
curl --request GET \ --header "Authorization: Bearer "$(gcloud auth application-default print-access-token) \ --header 'Content-Type: application/json' \ "https://workflowexecutions.googleapis.com/v1/projects/PROJECT_NUMBER/locations/us-central1/workflows/WORKFLOW_NAME/executions/EXECUTION_ID"
Reemplaza
EXECUTION_ID
por el ID del resultado que mostró tu primer comando.Este resultado contiene líneas similares a las siguientes:
"argument": "{\"firstName\":\"Workflows\",\"lastName\":\"User\"}", "result": "\"Hello, Workflows User!\"",
Para obtener más información sobre cómo ejecutar un flujo de trabajo con la API de REST, consulta Cómo ejecutar un flujo de trabajo.
Cómo acceder a los argumentos del entorno de ejecución
En este ejemplo, se accede a los argumentos del entorno de ejecución que se pasan al flujo de trabajo como parte de la solicitud de ejecución. Todos los argumentos se almacenan en el mismo mapa, declarado como un parámetro del flujo de trabajo principal.
Cuando ejecutes este flujo de trabajo, pasa los argumentos del entorno de ejecución con el siguiente formato:
{"firstName":"Sherlock", "lastName":"Holmes"}
YAML
JSON
Puedes usar default
con la función de biblioteca estándar, map.get, para acceder a argumentos de tiempo de ejecución opcionales y mostrar un valor predeterminado si no se encuentra la clave. En el siguiente ejemplo, si no se especifica un region
, se usa northamerica-northeast1
:
YAML
main: params: [input] steps: - init: assign: - region: ${default(map.get(input, "region"), "northamerica-northeast1")}
JSON
{ "main": { "params": [ "input" ], "steps": [ { "init": { "assign": [ { "region": "${default(map.get(input, \"region\"), \"northamerica-northeast1\")}" } ] } } ] } }