Supervisa flujos de trabajo

Google Cloud Observability proporciona herramientas de supervisión, registro y diagnóstico. Estas herramientas pueden ayudarte a supervisar y analizar las implementaciones y ejecuciones de flujos de trabajo, así como a comprender el comportamiento, el estado y el rendimiento de tus aplicaciones.

De forma predeterminada, Workflows está configurado para hacer lo siguiente:

  • Enviar datos y registros de auditoría del sistema a Cloud Logging Puedes usar los registros recopilados para depurar y solucionar problemas de tus aplicaciones, y obtener estadísticas sobre ellas.
  • Enviar métricas del sistema y de los recursos a Cloud Monitoring Puedes usar las métricas recopiladas para supervisar el estado y el rendimiento, identificar tendencias y problemas, y notificar cambios de comportamiento.

Envía registros de auditoría a Cloud Logging

Workflows envía los siguientes tipos de datos de registros de auditoría a Cloud Logging:

Estos registros están inhabilitados de forma predeterminada, ya que pueden ser bastante extensos. Para obtener más información, consulta Habilita los registros de auditoría de acceso a los datos.

Para obtener más información sobre los registros de auditoría en Workflows, consulta lo siguiente:

También puedes enviar registros de ejecución a Cloud Logging.

Envía métricas a Cloud Monitoring

Workflows envía datos de métricas de los recursos supervisados a Google Cloud Observability. Un recurso supervisado en la supervisión representa una entidad física o lógica, como una máquina virtual, una base de datos o una aplicación. Los recursos supervisados contienen un conjunto único de métricas que se pueden explorar, informar a través de un panel o usar para crear alertas. Cada recurso también tiene un conjunto de etiquetas de recursos, que son pares clave-valor que contienen información adicional sobre el recurso. Las etiquetas de recursos están disponibles para todas las métricas asociadas con el recurso.

Para ver todos los tipos de recursos, consulta Tipos de recursos supervisados. Para ver todos los tipos de métricas, consulta Métricas de Google Cloud. Expande lo siguiente para ver una lista de los tipos de métricas que se envían desde Workflows a Google Cloud Observability:

Tipos de métricas de Workflows

Las strings de “tipo de métrica” de esta tabla deben tener el prefijo workflows.googleapis.com/. Este prefijo se omitió en las entradas de la tabla. Cuando consultes una etiqueta, usa el prefijo metric.labels.. Por ejemplo, metric.labels.LABEL="VALUE".

Tipo de métrica Etapa de lanzamiento(niveles de jerarquía de recursos)
Nombre visible
Clase, tipo, unidad
Recursos supervisados
Descripción
Etiquetas
await_callback_step_count GA(project)
Recuento de pasos de espera de devolución de llamada
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de pasos ejecutados que esperan una devolución de llamada. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
callback_requests_count GA(proyecto)
Recuento de solicitudes de devolución de llamada
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de solicitudes realizadas para activar una devolución de llamada. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
callback_timeout_count GA(project)
Recuento de tiempos de espera de devolución de llamada
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de devoluciones de llamada que se agotaron. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
cmek_protected_workflow_count GA(proyecto)
Recuento de flujos de trabajo protegidos por CMEK
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de flujos de trabajo implementados con protección de CMEK. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
compute_slice_count GA(proyecto)
Recuento de secciones de Compute
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de rebanadas de procesamiento ejecutadas. Los pasos se ejecutan en fragmentos de trabajo, que dependen del tipo de pasos que se ejecutan (p.ej., las solicitudes HTTP se ejecutarán por separado de los pasos de "asignación"). Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
type: Es el tipo de fragmento de procesamiento, como "IO_REQUEST" o "WAKEUP".
has_parallel: (BOOL) Indica si el flujo de trabajo usa pasos en paralelo.
compute_slice_latencies GA(proyecto)
Latencias de Compute Slice
DELTADISTRIBUTIONms
workflows.googleapis.com/Workflow
Latencias desde el momento en que se programó una porción de procesamiento hasta el momento en que se ejecutó. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
type: Es el tipo de fragmento de procesamiento, como "IO_REQUEST" o "WAKEUP".
has_parallel: (BOOL) Indica si el flujo de trabajo usa pasos en paralelo.
compute_step_count GA(proyecto)
Recuento de pasos de Compute
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de pasos de procesamiento ejecutados (p.ej., pasos “assign” y “for”). Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
compute_step_latencies GA(proyecto)
Latencias del paso de procesamiento
DELTADISTRIBUTIONms
workflows.googleapis.com/Workflow
Latencias de los pasos de procesamiento ejecutados. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
create_callback_step_count GA(proyecto)
Crea el recuento de pasos de devolución de llamada
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de pasos ejecutados que crean una devolución de llamada. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
method: Es el tipo de método de la devolución de llamada creada, como "POST".
deployment_attempt_count GA(proyecto)
Recuento de intentos de implementación
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de intentos de implementación de flujos de trabajo. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
result: Es el estado de los intentos de implementación.
deployment_latencies GA(proyecto)
Latencias de implementación
DELTADISTRIBUTIONms
workflows.googleapis.com/Workflow
Latencias de los intentos de implementación de flujos de trabajo. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
duplicate_event_count GA(proyecto)
Recuento de eventos duplicados
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de activadores de eventos duplicados recibidos. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
event_type: Es el tipo de evento.
event_time_to_ack_latencies GA(proyecto)
Latencias de tiempo de evento para confirmar la recepción
DELTADISTRIBUTIONms
workflows.googleapis.com/Workflow
Latencias desde el momento en que comienza un evento hasta el momento en que el servicio de flujos de trabajo lo confirma. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
event_type: Es el tipo de evento.
event_trigger_count GA(proyecto)
Recuento de activadores de eventos
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de activadores de eventos recibidos. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
event_type: Es el tipo de evento.
result: Es el resultado del activador de eventos.
execution_backlog_size GA(proyecto)
Tamaño del listado de tareas pendientes de ejecución
GAUGEINT641
workflows.googleapis.com/Workflow
Cantidad de ejecuciones que aún no se iniciaron. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
execution_times BETA(project)
Tiempos de ejecución
DELTADISTRIBUTIONs
workflows.googleapis.com/Workflow
Distribución de los tiempos de ejecución del flujo de trabajo.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
external_step_count BETA(project)
Recuento de pasos externo
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de pasos externos ejecutados para el flujo de trabajo.
finished_execution_count BETA(project)
Recuento de ejecuciones finalizadas
DELTAINT641
workflows.googleapis.com/Workflow
Es el recuento de ejecuciones finalizadas del flujo de trabajo.
status: Es el estado de ejecución del flujo de trabajo.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
internal_execution_error_count GA(project)
Recuento de errores de ejecución interna
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de ejecuciones que fallaron debido a un error interno. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
internal_step_count BETA(proyecto)
Recuento de pasos interno
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de pasos internos ejecutados para el flujo de trabajo.
io_internal_request_count GA(proyecto)
Recuento de solicitudes internas de E/S
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de solicitudes de E/S que realiza un flujo de trabajo a los servicios de Google. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
service_domain: Es el dominio del servicio de Google al que se llama, como "bigquery.googleapis.com".
io_step_count GA(proyecto)
Recuento de pasos de E/S
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de pasos de E/S ejecutados. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
io_result: Es el resultado del paso de E/S.
io_step_type: Es el tipo de paso de E/S.
destination_type: Es el tipo de destino del paso de E/S.
had_system_error: (BOOL) Indica si el paso de E/S tuvo un error del sistema.
io_step_latencies GA(proyecto)
Latencias de pasos de E/S
DELTADISTRIBUTIONms
workflows.googleapis.com/Workflow
Latencias de los pasos de E/S ejecutados. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
io_result: Es el resultado del paso de E/S.
io_step_type: Es el tipo de paso de E/S.
had_system_error: (BOOL) Indica si el paso de E/S tuvo un error del sistema.
kms_decrypt_latencies GA(proyecto)
Latencias de desencriptación de KMS
DELTADISTRIBUTIONms
workflows.googleapis.com/Workflow
Latencias de las solicitudes de desencriptación a KMS por flujos de trabajo para CMEK. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
status: Es el estado de las solicitudes de desencriptación.
attempts: (INT64) Es el recuento de intentos de las solicitudes de desencriptación.
kms_decrypt_request_count GA(proyecto)
Recuento de solicitudes de desencriptación de KMS
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de solicitudes de desencriptación de KMS que realizó el servicio para CMEK. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
status: Es el estado de las solicitudes de desencriptación.
kms_encrypt_latencies GA(proyecto)
Latencias de encriptación de KMS
DELTADISTRIBUTIONms
workflows.googleapis.com/Workflow
Latencias de las solicitudes de encriptación a KMS por flujos de trabajo para CMEK. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
status: Es el estado de las solicitudes de encriptación.
attempts: (INT64) Es el recuento de intentos de las solicitudes de encriptación.
kms_encrypt_request_count GA(proyecto)
Recuento de solicitudes de encriptación de KMS
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de solicitudes de encriptación de KMS que realizó el servicio para CMEK. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
status: Es el estado de las solicitudes de encriptación.
parallel_branch_step_count GA(proyecto)
Recuento de pasos de rama paralela
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de pasos ejecutados con ramas paralelas. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
parallel_branch_substep_count GA(proyecto)
Recuento de pasos secundarios de la rama paralela
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de pasos ejecutados dentro de las ramas paralelas. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
parallel_iteration_step_count GA(proyecto)
Recuento de pasos de iteración en paralelo
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de pasos ejecutados con iteraciones en paralelo. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
parallel_iteration_substep_count GA(proyecto)
Recuento de pasos secundarios de iteración en paralelo
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de pasos ejecutados dentro de las iteraciones en paralelo. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
parallel_unhandled_exceptions_limit_count GA(project)
Recuento del límite de excepciones no controladas en paralelo
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de veces que se alcanzó el límite de excepciones paralelas no controladas. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
pending_io_requests GA(proyecto)
Solicitudes de E/S pendientes
GAUGEINT641
workflows.googleapis.com/Workflow
Cantidad de solicitudes de E/S en curso. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
sent_bytes_count BETA(proyecto)
Bytes de red enviados
DELTAINT64By
workflows.googleapis.com/Workflow
Cantidad de bytes HTTP salientes (URL, encabezados y cuerpo) que envió el flujo de trabajo.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
started_execution_count BETA(proyecto)
Recuento de ejecuciones iniciadas
DELTAINT641
workflows.googleapis.com/Workflow
Es el recuento de ejecuciones iniciadas del flujo de trabajo.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
started_vpcsc_executions_count GA(proyecto)
Recuento de ejecuciones de VPC-SC iniciadas
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de ejecuciones restringidas de VPC-SC iniciadas. Se hace un muestreo cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.
vpcsc_protected_io_count GA(project)
Recuento de operaciones de E/S protegidas por VPC-SC
DELTAINT641
workflows.googleapis.com/Workflow
Cantidad de solicitudes de E/S realizadas con VPC-SC. Se tomaron muestras cada 60 segundos. Luego del muestreo, los datos no son visibles durante un máximo de 120 segundos.
revision_id: Es el ID de revisión del flujo de trabajo ejecutado.

Tabla generada el 26 de noviembre de 2024 a las 17:39:42 UTC.

Lee datos de métricas

Puedes leer datos de métricas, también llamados datos de series temporales, con el método timeSeries.list en la API de Cloud Monitoring. Existen varias formas de llamar al método, como usar una biblioteca cliente específica del lenguaje o crear un gráfico con el Explorador de métricas.También puedes probar el método timeSeries.list con el Explorador de APIs basado en formularios. Para obtener una introducción a las métricas y las series temporales, consulta Métricas, series temporales y recursos. Para aprender a leer los datos de tus métricas, consulta Cómo recuperar datos de series temporales.

Supervisa las métricas de cuota

En el siguiente ejemplo, se muestra cómo usar el Explorador de APIs para consultar la cuota de asignación total consumida para Workflows. Específicamente, usa la métrica serviceruntime.googleapis.com/quota/allocation/usage en el tipo de recurso Consumer Quota. Puedes configurar filtros de etiquetas adicionales (service, quota_metric) para especificar el tipo de cuota. Para obtener más información sobre cómo supervisar las métricas de cuota, incluidos más ejemplos y cómo crear políticas de alertas, consulta Gráficos y supervisión de las métricas de cuota.

  1. Abre la página de referencia de timeSeries.list.

  2. Si no ves el panel Probar este método, haz clic en Probar.

  3. En el campo name, ingresa el ID de tu proyecto de Google Cloud con el siguiente formato:

    projects/PROJECT_ID
    
  4. En el campo filter, especifica un solo tipo de métrica y, de manera opcional, etiquetas de métrica y otra información. Por ejemplo:

    metric.type = "serviceruntime.googleapis.com/quota/allocation/usage" AND resource.labels.service = "workflowexecutions.googleapis.com"
    
  5. En el campo interval.endTime, ingresa una hora de finalización para limitar la cantidad de datos que se muestran y que se aplique a tu uso. Debe tener el formato de una cadena de RFC 3339, por ejemplo, 2024-11-07T03:01:02Z.

  6. En el campo interval.startTime, ingresa una hora de inicio para limitar la cantidad de datos que se muestran y que se aplique a tu uso. Debe tener el formato de una cadena RFC 3339, por ejemplo, 2024-11-07T03:01:00Z.

  7. Haz clic en Ejecutar.

    El resultado debería ser similar al siguiente, con 350 que indica la métrica de cuota de ejecuciones simultáneas.

    {
    "timeSeries": [
       {
          "metric": {
          "labels": {
             "quota_metric": "workflowexecutions.googleapis.com/concurrency"
          },
          "type": "serviceruntime.googleapis.com/quota/allocation/usage"
          },
          "resource": {
          "type": "consumer_quota",
          "labels": {
             "service": "workflowexecutions.googleapis.com",
             "project_id": "PROJECT_ID",
             "location": "europe-west1"
          }
          },
          "metricKind": "GAUGE",
          "valueType": "INT64",
          "points": [
          {
             "interval": {
                "startTime": "2024-11-07T03:01:02Z",
                "endTime": "2024-11-07T03:01:02Z"
             },
             "value": {
                "int64Value": "350"
             }
          }
          ]
       }
    
  8. En el panel lateral colapsado del Explorador de APIs, puedes hacer clic en Pantalla completa para expandir el Explorador de APIs. El panel de pantalla completa muestra un panel adicional que contiene muestras de código, respuestas application/json y respuestas HTTP sin procesar. Por ejemplo, en este caso, puedes ver el comando curl comparable:

    curl \
    'https://monitoring.googleapis.com/v3/projects/PROJECT_ID/timeSeries?filter=metric.type%20%3D%20%22serviceruntime.googleapis.com%2Fquota%2Fallocation%2Fusage%22%20AND%20resource.labels.service%20%3D%20%22workflowexecutions.googleapis.com%22&interval.endTime=2024-11-07T03%3A01%3A02Z&interval.startTime=2024-11-07T03%3A01%3A00Z&key=YOUR_API_KEY' \
       --header 'Authorization: Bearer YOUR_ACCESS_TOKEN' \
       --header 'Accept: application/json' \
       --compressed
    

Usa los paneles y las alertas de Monitoring

Puedes usar los paneles de Monitoring y sus gráficos asociados para visualizar los datos de las métricas de Workflows.

Para supervisar estas métricas en Monitoring, puedes crear paneles personalizados. También puedes agregar alertas en función de estas métricas.

¿Qué sigue?