Supervisa flujos de trabajo

Esta página brinda información para ayudarte a supervisar las implementaciones de flujos de trabajo y ejecuciones.

Acceder a los registros de implementación y eliminación de flujos de trabajo

Puedes acceder a los registros de errores relacionados con la implementación y eliminación de un flujo de trabajo en el Consola de Google Cloud

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

   Ir a Workflows

2. Haz clic en el nombre del flujo de trabajo para mostrar la página Detalles del flujo de trabajo.

3. Haz clic en la pestaña Registros.

4. Para filtrar los registros por gravedad, en la lista Predeterminada, selecciona el tipo de registro que se mostrará.

Accede a los resultados de la ejecución del flujo de trabajo

Puedes acceder a los resultados de la ejecución del flujo de trabajo en la consola de Google Cloud o con gcloud CLI.

Console

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

   Ir a Workflows

2. Si quieres acceder a los resultados de la ejecución de un flujo de trabajo, haz clic en el nombre del flujo de trabajo para ir a la página Detalles del flujo de trabajo.

3. Para obtener detalles sobre una ejecución en particular, en la pestaña Ejecuciones, haz clic en el ID de ejecución en la lista para ir a la página Detalles de la ejecución.

   Nota: Para acceder a la página Detalles de la ejecución, debes tener un rol. que contiene los objetos workflows.workflows.get, workflows.executions.get y workflows.stepEntries.list. Para obtener más información, consulta Los roles de Workflows y permisos y Administra el acceso.

4. En la pestaña Resumen, cada ejecución tiene la siguiente información:

   • Estado de ejecución: Indica el estado final del flujo de trabajo, incluidos los del flujo de trabajo actual o final.
   • Inicio de la ejecución: cuándo comenzó la ejecución.
   • Execution end: Cuando finalizó la ejecución.
   • Duración de la ejecución: Es el tiempo total transcurrido. Esto puede indicarte errores de red o problemas de conectividad.
   • Nombre del flujo de trabajo: El nombre del flujo de trabajo.
   • Revisión del flujo de trabajo: Es la revisión actual en el momento de la ejecución.
   • Nivel de registro de llamadas: El nivel de registro de llamadas aplicado durante la ejecución. En este documento, consulta Registro de llamadas.
   • Entrada: Son los argumentos del entorno de ejecución que se pasan al flujo de trabajo, si los hay.
   • Resultado: el resultado del flujo de trabajo. Si la ejecución falla, incluye los que provocó la falla de la ejecución. En este documento, consulta Mensajes de error de ejecución.

5. Para ver el historial de ejecución del flujo de trabajo como una lista de entradas de paso, haz clic en el la pestaña Pasos. Para obtener más información, consulta Consulta el historial de pasos de la ejecución.

6. Para ver los registros de la ejecución de un flujo de trabajo, haz clic en la pestaña Registros.

7. Para filtrar los registros de ejecución, usa el campo Filtrar en la parte superior de la desde una tabla de particiones. Por ejemplo, para mostrar solo los intentos de ejecución fallidos, ingresa failed en el campo de texto del filtro

gcloud

1. Para ver una lista completa de las ejecuciones de un flujo de trabajo, ingresa lo siguiente: :

   gcloud workflows executions list WORKFLOW_NAME
   

   Reemplaza WORKFLOW_NAME por el nombre de tu flujo de trabajo. Copia el ID de la ejecución que te interesa.

2. Para ver los registros de ejecución de un flujo de trabajo, ingresa el siguiente comando:

   gcloud workflows executions describe \
       --workflow=WORKFLOW_NAME \
       EXECUTION_ID
   

   Reemplaza lo siguiente:

   • WORKFLOW_NAME: Es el nombre del flujo de trabajo.
   • EXECUTION_ID: El ID único de la ejecución

   Este comando muestra un resultado similar al siguiente:

   argument: 'null'
   endTime: '2022-07-19T12:40:07.070039707Z'
   error:
    context: |-
       The argument of 'in' must be a dict or an array; got: null
       in step "checkSearchTermInInput", routine "main", line: 12
    payload: "{"message":"The argument of 'in' must be a dict or an array; got: null"
   
       ,"tags":["TypeError"]}"
    stackTrace:
       elements:
       - position:
          column: '26'
          length: '24'
          line: '12'
          routine: main
          step: checkSearchTermInInput
   name: projects/1051295516635/locations/us-central1/workflows/myFirstWorkflow/executions/17ffc89c-0a27-4d2f-8356-e681d949a3d3
   startTime: '2022-07-19T12:40:07.024823663Z'
   state: FAILED
   status:
    currentSteps:
    - routine: main
       step: checkSearchTermInInput
   workflowRevisionId: 000001-ac2
   

   En el resultado, se incluye la siguiente información:
   • argument: Son los argumentos del entorno de ejecución que se pasan al flujo de trabajo, si los hay.
   • endTime: Cuando finalizó la ejecución
   • error: Es el mensaje de error que se arroja como parte de la excepción que provocó la falla de la ejecución
   • name: Es el nombre completo de la ejecución, incluido el nombre de la proyecto, la ubicación del flujo de trabajo, el nombre del flujo de trabajo y el ID de ejecución
   • startTime: cuándo comenzó la ejecución
   • state: Indica el estado final del flujo de trabajo.
   • status: Es el paso actual o final del flujo de trabajo de la ejecución.
   • workflowRevisionID: Es la revisión actual en el momento de la ejecución.

Mapas de errores de ejecución

Cuando un flujo de trabajo arroja un error durante la ejecución que no está capturado en una bloque try/except, ejecución falla y un mapa de errores (un diccionario JSON) que describe el error que se devuelven.

Los errores arrojados durante la ejecución del flujo de trabajo contienen etiquetas para ayudarte a identificar causó el error. Por ejemplo, el error que muestra un conector puede tener dos claves (tags y message) similares a las siguientes:

{'tags': ['SystemError'], 'message': 'an error has occurred'}

Puede haber más de una etiqueta. Para verificar si hay una etiqueta específica, puedes usar un expresión. Por ejemplo:

${'SystemError' in e.tags}

Datos de errores de acceso que se muestran como una cadena

Algunos conectores y APIs de HTTP serializan errores como cadenas antes de devolver los errores. Puedes usar funciones de biblioteca estándar para restablecer una carga útil en el error original. Por ejemplo, para convertir una cadena de error en un mapa, puedes usar el json.decode y las funciones text.encode:

json.decode(text.encode(ERROR_FROM_API))

Etiquetas de error

En la siguiente tabla, se describe el significado de diferentes etiquetas de error.

Etiqueta	Descripción
AuthError	Se genera cuando falla la generación de credenciales para una solicitud HTTP.
ConnectionError	Se genera cuando se establece correctamente una conexión con el extremo. pero hay un problema con la conexión durante la transferencia de datos. El la conexión se finaliza antes de que se reciba una respuesta completa y aparezca un mensaje podría no haberse entregado al endpoint. Es posible que los reintentos no idempotentes.
ConnectionFailedError	Se genera cuando no se establece una conexión con el extremo de API. para ejemplo, debido a un nombre de dominio incorrecto, problemas de resolución de DNS u otras problemas de red. Los reintentos son idempotentes.
HttpError	Se genera cuando un La solicitud HTTP falla con un estado de error de HTTP. Cuando se plantea esta excepción, el es un mapa con los siguientes elementos: tags: Lista con la cadena HttpError message: Mensaje de error legible por humanos code: Código de estado de respuesta HTTP headers: Encabezados de respuesta body: Cuerpo de la respuesta
IndexError	Se genera cuando el subíndice de una secuencia es un número entero fuera del rango.
KeyError	Se genera cuando no se encuentra una clave de mapa en el conjunto de claves existentes.
OperationError	Se genera cuando una operación de larga duración finaliza sin éxito.
ParallelNestingError	Se aumenta cuando la cantidad máxima se supera la profundidad con la que se pueden anidar los pasos paralelos.
RecursionError	Se genera cuando el intérprete detecta que el elemento se supere la profundidad máxima de la pila de llamadas.
ResourceLimitError	Se genera cuando se agota algún límite de recursos. Cuando se genera internamente, este tipo de error no se puede detectar y provoca la ejecución inmediata falla.
ResponseTypeError	Se genera cuando una operación de larga duración muestra una respuesta de lo incorrecto. el tipo de letra.
SystemError	Se genera cuando el intérprete encuentra un error interno.
TimeoutError	Se genera cuando se agota el tiempo de espera de una función del sistema a nivel del sistema.
TypeError	Se genera cuando una operación o función se aplica a un objeto de o un tipo incompatible. El valor asociado es una cadena que proporciona detalles sobre el tipo no coincide.
UnhandledBranchError	Se genera cuando una o más ramas o iteraciones encuentran un error de entorno de ejecución no controlado hasta un cantidad máxima.
ValueError	Se genera cuando una operación o función recibe un argumento que tiene el valor de el tipo correcto, pero un valor incorrecto, y no se describe la situación por una excepción más precisa, como IndexError.
ZeroDivisionError	Se genera cuando el segundo argumento de una división o una operación de módulo es cero. El valor asociado es una cadena que indica el tipo de los operandos y la operación.

También puedes generar errores personalizados con la sintaxis raise.

Verifica el estado de las ejecuciones

Hay varios comandos para ayudarte a verificar el estado de un flujo de trabajo ejecución.

• Para recuperar una lista de los intentos de ejecución de un flujo de trabajo y sus IDs, ingresa el siguiente comando:

  gcloud workflows executions list WORKFLOW_NAME
  

  Reemplaza WORKFLOW_NAME por el nombre del flujo de trabajo.

  El comando muestra un valor NAME similar al siguiente:

  projects/PROJECT_NUMBER/locations/REGION/workflows/WORKFLOW_NAME/executions/EXECUTION_ID

  Copia el ID de ejecución para usarlo en el siguiente comando.

• Para verificar el estado de un intento de ejecución y esperar a que el intento finaliza, ingresa el siguiente comando:

  gcloud workflows executions wait EXECUTION_ID
  

  Reemplaza EXECUTION_ID por el ID del intento de ejecución.

  El comando espera a que finalice el intento de ejecución y, luego, muestra el resultados.

• Esperar hasta que se complete la última ejecución y, luego, mostrar el resultado del se completó la ejecución, ingresa el siguiente comando:

  gcloud workflows executions wait-last
  

  Si hiciste un intento de ejecución anterior en la misma sesión de gcloud, el espera a que finalice el intento de ejecución anterior y, luego, devuelve los resultados de la ejecución completada. Si no existe un intento anterior, gcloud muestra el siguiente error:

  ERROR: (gcloud.workflows.executions.wait-last) [NOT FOUND] There are no cached executions available.
  

• Para obtener el estado de la última ejecución, ingresa el siguiente comando:

  gcloud workflows executions describe-last
  

  Si hiciste un intento de ejecución anterior en la misma sesión de gcloud, el muestra los resultados de la última ejecución, incluso si está en ejecución. Si la respuesta es no existe un intento anterior, gcloud muestra el siguiente error:

  ERROR: (gcloud.beta.workflows.executions.describe-last) [NOT FOUND] There are no cached executions available.
  

Filtrar ejecuciones

Puedes aplicar filtros a la lista de ejecuciones de flujo de trabajo que devuelve el Método workflows.executions.list.

Puedes filtrar según los siguientes campos:

• duration
• endTime
• executionId
• label
• startTime
• state
• stepName
• workflowRevisionId

Por ejemplo, para filtrar según una etiqueta (labels."fruit":"apple"), puedes hacer que Una solicitud a la API similar a la siguiente:

GET https://workflowexecutions.googleapis.com/v1/projects/MY_PROJECT/locations/MY_LOCATION/workflows/MY_WORKFLOW/executions?view=full&filter=labels.%22fruit%22%3A%22apple%22"

Aquí:

• view=full especifica una vista que define qué campos se deben completar en la ejecuciones devueltas; En este caso, todos los datos
• labels.%22fruit%22%3A%22apple%22 es la sintaxis de filtro codificada para URL.

Para obtener más información, consulta Filtrado de AIP-160.

Envía registros a Cloud Logging

Workflows genera automáticamente registros de ejecución para el flujo de trabajo. ejecuciones en Cloud Logging.

También puedes habilitar el registro de llamadas. O bien, puedes crear registros personalizados que usen la función sys.log en tu fuente. El registro de llamadas y los registros personalizados te permiten controlar cuándo se envían los registros a Logging durante la ejecución de un flujo de trabajo y pueden ser muy útiles para depurar tu flujo de trabajo.

Para obtener más información, incluido el protocolo de registro engine_call y executions_system consulta este repositorio de GitHub.

Registros de ejecución

Cada ejecución de flujo de trabajo activa automáticamente al menos dos registros de ejecución: una al inicio de una ejecución y otra al final.

Para obtener más información sobre los registros de la plataforma Workflows que están disponibles en Logging, consulta los registros de la plataforma de Google Cloud.

Registro de llamadas

Puedes configurar una marca para que cada paso de la llamada durante la ejecución de tu flujo de trabajo se registra, y los nombres de los pasos, los nombres de las funciones, argumentos de función y se muestran respuestas de llamadas. También puedes registrar excepciones que se detectan o que detienen una llamada.

Solo se registran los pasos explícitos de la llamada. por ejemplo, llamadas a subflujos de trabajo o las funciones de biblioteca. Llamadas desde las expresiones o desde la interfaz funciones de biblioteca (por ejemplo, http.post en sys.log) y conectores internos no se registran.

Los encabezados de la solicitud HTTP Authorization se ocultan en los registros de las llamadas HTTP.

Al aplicar el registro de llamadas a un definición del flujo de trabajo o a la la ejecución de un flujo de trabajo puedes especificar el nivel de registro requerido. El nivel de registro de ejecución toma prioridad sobre cualquier nivel de registro de flujo de trabajo, a menos que el nivel de registro de ejecución no sea especificado (predeterminado); en ese caso, se aplicará el nivel de registro de flujo de trabajo.

Ten en cuenta que el límite de tamaño de las entradas de registro establecido por Cloud Logging también se aplica al registro de llamadas.

Registros personalizados

Para crear una entrada de registro en Logging durante la ejecución de un flujo de trabajo, Define un paso en el flujo de trabajo que realiza una llamada a la biblioteca estándar sys.log. función:

YAML

  - step1:
      assign:
          - varA: "Hello"
          - varB: "World"
  - logStep:
      call: sys.log
      args:
          text: TEXT
          severity: SEVERITY 
  - step2:
      return: ${varA + " " + varB}
    

JSON

    [
      {
        "step1": {
          "assign": [
            {
              "varA": "Hello"
            },
            {
              "varB": "World"
            }
          ]
        }
      },
      {
        "logStep": {
          "call": "sys.log",
          "args": {
            "text": "TEXT",
            "severity": "SEVERITY"
          }
        }
      },
      {
        "step2": {
          "return": "${varA + " " + varB}"
        }
      }
    ]
      

Cuando crees una entrada de registro, define lo siguiente:

• TEXT: obligatorio. El texto que se registrará. Si necesitas Para registrar los valores de un mapa, usa ${json.encode_to_string(myMap)}.
• SEVERITY: es opcional. El nivel de gravedad del registro entrada. Por ejemplo, INFO, WARNING o CRITICAL.

Para obtener más información, consulta la referencia de la función sys.log.

Permisos necesarios

Para aplicar el registro de llamadas o enviar registros personalizados a Logging, un flujo de trabajo debe estar asociado con una cuenta de servicio que incluya la permiso logging.logEntries.create (por ejemplo, roles/logging.logWriter de seguridad en la nube). Si necesitas cambiar la cuenta de servicio actualizada con tu flujo de trabajo, consulta Actualiza un flujo de trabajo. Para obtener más información sobre cómo crear cuentas de servicio y asignar roles, consulta Administra el acceso a proyectos, carpetas y organizaciones.

Ver registros del flujo de trabajo

Puedes ver los registros en Workflows o Logging. Para ver los registros de un solo flujo de trabajo, usa la pestaña Registros en Workflows Para obtener una vista agregada de los registros de todos de tus flujos de trabajo, usa la página Explorador de registros en Logging.

Ver registros en Workflows

Para ver los registros de un flujo de trabajo en Workflows, haz lo siguiente:

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

   Ir a Workflows

2. Si quieres acceder a los registros de un flujo de trabajo, haz clic en el nombre del flujo de trabajo para ir a la página de detalles.

3. Para ver los registros, haz clic en Registros.

4. Para filtrar los registros por gravedad, en la lista Predeterminada, selecciona el tipo de registro que se mostrará. De forma predeterminada, los registros de se muestran los diferentes niveles.

La pestaña Registros en la página Detalles de un flujo de trabajo muestra los siguientes tipos de registros:

• Registros enviados a Logging

• Registros de auditoría de cualquier operación realizada en el flujo de trabajo, como las actualizaciones de la definición del flujo de trabajo

Visualiza registros en Logging

Para ver los registros en Logging, haz lo siguiente:

1. En la consola de Google Cloud, ve a la página Explorador de registros:
   

   Ir al Explorador de registros

2. En el Compilador de consultas, haz clic en Recurso y, luego, ingresa workflow. Seleccionar Cloud Workflow en la lista y haz clic en Agregar.

   

3. Haz clic en Ejecutar consulta.

Para obtener más información sobre la visualización de registros en Logging, consulta Usa el Explorador de registros.

¿Qué sigue?

• Descripción general de la depuración
• Soluciona problemas
• Problemas conocidos de Workflows