Monitorare i flussi di lavoro

Google Cloud Observability fornisce strumenti di monitoraggio, logging e diagnostica. Questi strumenti possono aiutarti a monitorare e analizzare le implementazioni e le esecuzioni dei flussi di lavoro, nonché a comprendere il comportamento, l'integrità e le prestazioni delle tue applicazioni.

Per impostazione predefinita, Workflows è configurato per:

  • Invia i dati e gli audit log di sistema a Cloud Logging. Puoi utilizzare i log raccolti per eseguire il debug, risolvere i problemi e ottenere informazioni sulle tue applicazioni.
  • Invia le metriche di sistema e delle risorse a Cloud Monitoring. Puoi utilizzare le metriche raccolte per monitorare l'integrità e le prestazioni, identificare tendenze e problemi e inviare notifiche per le variazioni di comportamento.

Inviare gli audit log a Cloud Logging

Workflows invia i seguenti tipi di dati dei log di controllo a Cloud Logging:

Gli audit log di accesso ai dati sono disabilitati per impostazione predefinita perché possono essere abbastanza grandi. Per ulteriori informazioni, consulta la pagina sulla configurazione degli audit log di accesso ai dati.

Per ulteriori informazioni sui log di controllo in Workflows, consulta quanto segue:

Puoi anche inviare i log di esecuzione a Cloud Logging.

Inviare metriche a Cloud Monitoring

Workflows invia i dati delle metriche dalle risorse monitorate a Google Cloud Observability. Una risorsa monitorata in Monitoraggio rappresenta un'entità logica o fisica, ad esempio una macchina virtuale, un database o un'applicazione. Le risorse monitorate contengono un insieme unico di metriche che possono essere esplorate, registrate tramite una dashboard o utilizzate per creare avvisi. Ogni risorsa ha anche un insieme di etichette, ovvero coppie chiave-valore che contengono informazioni aggiuntive sulla risorsa. Le etichette risorse sono disponibili per tutte le metriche associate alla risorsa.

Per visualizzare tutti i tipi di risorse, consulta Tipi di risorse monitorate. Per visualizzare tutti i tipi di metriche, consulta Metriche di Google Cloud. Espandi quanto segue per visualizzare un elenco dei tipi di metriche inviati da Workflows a Google Cloud Observability:

Tipi di metriche Workflows

Le stringhe "tipo metrica" in questa tabella devono essere precedute dal prefisso workflows.googleapis.com/. Questo prefisso è stato omesso dalle voci della tabella. Quando esegui una query su un'etichetta, utilizza il prefisso metric.labels., ad esempio metric.labels.LABEL="VALUE".

Tipo di metrica Fase di lancio (livelli della gerarchia delle risorse)
Nome visualizzato
Tipo, Tipo, Unità
Risorse monitorate		 Descrizione
Etichette
await_callback_step_count GA  (project)
Conteggio dei passaggi di attesa del callback
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di passaggi eseguiti che attendono un callback. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
callback_requests_count GA  (project)
Conteggio richieste di callback
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di richieste inviate per attivare un callback. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
callback_timeout_count GA  (project)
Conteggio dei timeout della chiamata di callback
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di chiamate di ritorno che hanno superato il tempo di attesa. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
cmek_protected_workflow_count GA  (project)
Conteggio flussi di lavoro protetti da CMEK
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di flussi di lavoro di cui è stato eseguito il deployment con la protezione CMEK. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
compute_slice_count GA  (project)
Conta sezioni di calcolo
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di slice di calcolo eseguiti. I passaggi vengono eseguiti in sezioni di lavoro, che dipendono dal tipo di passaggi in esecuzione (ad es. le richieste HTTP verranno eseguite separatamente dai passaggi di "assegnazione"). Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
type: Il tipo di slice di calcolo, ad esempio "IO_REQUEST" o "WAKEUP".
has_parallel: (BOOL) Indica se il flusso di lavoro utilizza passaggi paralleli.
compute_slice_latencies GA  (project)
Latenze delle sezioni di calcolo
DELTA, DISTRIBUTION, ms
workflows.googleapis.com/Workflow 		Le latenze dal momento della pianificazione di uno slice di calcolo al momento della sua esecuzione. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
type: Il tipo di slice di calcolo, ad esempio "IO_REQUEST" o "WAKEUP".
has_parallel: (BOOL) Indica se il flusso di lavoro utilizza passaggi paralleli.
compute_step_count GA  (project)
Calcolo del numero di passi
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di passaggi di calcolo eseguiti (ad es. passaggi "assign" e "for"). Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
compute_step_latencies GA  (project)
Tempi di latenza del passaggio di calcolo
DELTA, DISTRIBUTION, ms
workflows.googleapis.com/Workflow 		Le latenze dei passaggi di calcolo eseguiti. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
create_callback_step_count GA  (project)
Crea Conteggio dei passaggi di chiamata
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di passaggi eseguiti che creano un callback. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
method: Il tipo di metodo del callback creato, ad esempio "POST".
deployment_attempt_count GA  (project)
Deployment Attempt Count
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di tentativi di deployment del flusso di lavoro. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
result: Lo stato dei tentativi di deployment.
deployment_latencies GA  (project)
Latenze di deployment
DELTA, DISTRIBUTION, ms
workflows.googleapis.com/Workflow 		Latenze dei tentativi di deployment del flusso di lavoro. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
duplicate_event_count GA  (project)
Conteggio eventi duplicati
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di attivatori di eventi duplicati ricevuti. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
event_type: Il tipo di evento.
event_time_to_ack_latencies GA  (project)
Latenze dall'ora dell'evento all'ACK
DELTA, DISTRIBUTION, ms
workflows.googleapis.com/Workflow 		Le latenze dal momento in cui inizia un evento a quello in cui il servizio di flussi di lavoro lo conferma. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
event_type: Il tipo di evento.
event_trigger_count GA  (project)
Conteggio trigger evento
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di attivatori di eventi ricevuti. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
event_type: Il tipo di evento.
result: il risultato dell'attivatore evento.
execution_backlog_size GA  (project)
Dimensione del backlog di esecuzione
GAUGE, INT64, 1
workflows.googleapis.com/Workflow 		Numero di esecuzioni che non sono ancora iniziate. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
execution_times BETA  (project)
Tempi di esecuzione
DELTA, DISTRIBUTION, s
workflows.googleapis.com/Workflow 		Distribuzione dei tempi di esecuzione del flusso di lavoro.
revision_id: l'ID revisione del flusso di lavoro eseguito.
external_step_count BETA  (project)
Conteggio dei passi esterno
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Conteggio dei passaggi esterni eseguiti per il flusso di lavoro.
finished_execution_count BETA  (project)
Numero di esecuzioni completate
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di esecuzioni completate per il flusso di lavoro.
status: lo stato di esecuzione del flusso di lavoro.
revision_id: l'ID revisione del flusso di lavoro eseguito.
internal_execution_error_count GA  (project)
Conteggio errori di esecuzione interni
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di esecuzioni non riuscite con un errore interno. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
internal_step_count BETA  (project)
Conteggio interno dei passi
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Conteggio dei passaggi interni eseguiti per il flusso di lavoro.
io_internal_request_count GA  (project)
Conteggio richieste interne IO
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di richieste I/O effettuate da un flusso di lavoro ai servizi Google. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
service_domain: Il dominio del servizio Google chiamato, ad esempio "bigquery.googleapis.com".
io_step_count GA  (project)
Conteggio passi IO
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di passaggi di I/O eseguiti. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
io_result: Il risultato del passaggio di I/O.
io_step_type: il tipo di passaggio di I/O.
destination_type: Il tipo di destinazione del passaggio di I/O.
had_system_error: (BOOL) Indica se il passaggio di I/O ha avuto un errore di sistema.
io_step_latencies GA  (project)
Latenze dei passaggi IO
DELTA, DISTRIBUTION, ms
workflows.googleapis.com/Workflow 		Latenze dei passaggi di I/O eseguiti. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
io_result: Il risultato del passaggio di I/O.
io_step_type: il tipo di passaggio di I/O.
had_system_error: (BOOL) Indica se il passaggio di I/O ha avuto un errore di sistema.
kms_decrypt_latencies GA  (project)
Tempi di decrittografia KMS
DELTA, DISTRIBUTION, ms
workflows.googleapis.com/Workflow 		Tempi di latenza delle richieste di decrittografia a KMS per flussi di lavoro per CMEK. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
status: lo stato delle richieste di decrittografia.
attempts: (INT64) Il numero di tentativi delle richieste di decrittografia.
kms_decrypt_request_count GA  (project)
Conteggio richieste di decrittografia KMS
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di richieste di decrittografia KMS effettuate dal servizio per CMEK. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
status: lo stato delle richieste di decrittografia.
kms_encrypt_latencies GA  (project)
Tempi di latenza di crittografia KMS
DELTA, DISTRIBUTION, ms
workflows.googleapis.com/Workflow 		Latenze delle richieste di crittografia a KMS per flussi di lavoro per CMEK. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
status: lo stato delle richieste di crittografia.
attempts: (INT64) Il numero di tentativi delle richieste di crittografia.
kms_encrypt_request_count GA  (project)
Conteggio richieste di crittografia KMS
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di richieste di crittografia KMS effettuate dal servizio per CMEK. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
status: lo stato delle richieste di crittografia.
parallel_branch_step_count GA  (project)
Numero di passaggi del ramo parallelo
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di passaggi eseguiti utilizzando rami paralleli. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
parallel_branch_substep_count GA  (project)
Conteggio dei passaggi secondari del ramo parallelo
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di passaggi eseguiti all'interno di rami paralleli. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
parallel_iteration_step_count GA  (project)
Numero di passaggi di iterazione parallela
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di passaggi eseguiti utilizzando iterazioni parallele. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
parallel_iteration_substep_count GA  (project)
Numero di sottopassaggi di iterazione parallela
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di passaggi eseguiti all'interno di iterazioni parallele. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
parallel_unhandled_exceptions_limit_count GA  (project)
Conteggio del limite di eccezioni non gestite parallele
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di volte in cui è stato raggiunto il limite di eccezioni parallele non gestite. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
pending_io_requests GA  (project)
Richieste IO in attesa
GAUGE, INT64, 1
workflows.googleapis.com/Workflow 		Numero di richieste I/O in corso. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
sent_bytes_count BETA  (project)
Byte di rete inviati
DELTA, INT64, By
workflows.googleapis.com/Workflow 		Conteggio dei byte HTTP in uscita (URL, intestazioni e corpo) inviati dal flusso di lavoro.
revision_id: l'ID revisione del flusso di lavoro eseguito.
started_execution_count BETA  (project)
Numero di esecuzioni avviate
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Conteggio delle esecuzioni avviate per il flusso di lavoro.
revision_id: l'ID revisione del flusso di lavoro eseguito.
started_vpcsc_executions_count GA  (project)
Conteggio delle esecuzioni VPC-SC avviate
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di esecuzioni con limitazioni VPC-SC avviate. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.
vpcsc_protected_io_count GA  (project)
Conteggio IO protette VPC-SC
DELTA, INT64, 1
workflows.googleapis.com/Workflow 		Numero di richieste I/O effettuate utilizzando VPC-SC. Campionamento eseguito ogni 60 secondi. Dopo il campionamento, i dati non sono visibili per un massimo di 120 secondi.
revision_id: l'ID revisione del flusso di lavoro eseguito.

Tabella generata il 05/12/2024 alle ore 22:01:39 UTC.

Lettura dei dati delle metriche

Puoi leggere i dati delle metriche, chiamati anche dati delle serie temporali, utilizzando il metodotimeSeries.list nell'API Cloud Monitoring. Esistono diversi modi per chiamare il metodo, ad esempio utilizzando una libreria client specifica per il linguaggio o creando un grafico con Metrics Explorer.Puoi anche provare il metodo timeSeries.list utilizzando Explorer API basato su moduli. Per un'introduzione alle metriche e alle serie temporali, consulta Metriche, serie temporali e risorse. Per scoprire come leggere i dati delle metriche, consulta Recupero dei dati delle serie temporali.

Monitorare le metriche delle quote

L'esempio seguente mostra come utilizzare Explorer API per eseguire query sulla quota di allocazione totale consumata per Workflows. Nello specifico, utilizza la metrica serviceruntime.googleapis.com/quota/allocation/usage sul tipo di risorsa Consumer Quota. Puoi impostare filtri delle etichette aggiuntivi (service, quota_metric) per specificare il tipo di quota. Per ulteriori informazioni su come monitorare le metriche relative alle quote, inclusi ulteriori esempi e come creare criteri di avviso, consulta Graficare e monitorare le metriche relative alle quote.

  1. Apri la timeSeries.list pagina di riferimento.

  2. Se il riquadro Prova questo metodo non è visibile, fai clic su Prova.

  3. Nel campo name, inserisci l'ID del tuo progetto Google Cloud utilizzando il seguente formato:

    projects/PROJECT_ID

  4. Nel campo filter, specifica un singolo tipo di metrica e, facoltativamente, le etichette delle metriche e altre informazioni. Ad esempio:

    metric.type = "serviceruntime.googleapis.com/quota/allocation/usage" AND resource.labels.service = "workflowexecutions.googleapis.com"

  5. Nel campo interval.endTime, inserisci una data e un'ora di fine per limitare la quantità di dati che vengono restituiti e che sono applicabili al tuo utilizzo. Deve essere formattata come stringa RFC 3339, ad esempio 2024-11-07T03:01:02Z.

  6. Nel campo interval.startTime, inserisci un'ora di inizio per limitare la quantità di dati restituiti e applicabile al tuo utilizzo. Deve essere formattato come una stringa RFC 3339, ad esempio 2024-11-07T03:01:00Z.

  7. Fai clic su Execute (Esegui).

    Il risultato dovrebbe essere simile al seguente, con 350 che indica la metrica della quota di esecuzioni simultanee.

    {
"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. Nel riquadro laterale di Explorer API compresso, puoi fare clic su Schermo intero per espandere Explorer API. Il pannello a schermo intero mostra un riquadro aggiuntivo contenente esempi di codice, risposte application/json e risposte HTTP non elaborate. Ad esempio, in questo caso, puoi visualizzare il comando curl equivalente:

    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

Utilizzare le dashboard e gli avvisi di monitoraggio

Puoi utilizzare le dashboard di monitoraggio e i relativi grafici associati per visualizzare i dati relativi alle metriche di Workflows.

Per monitorare queste metriche in Monitoring, puoi creare dashboard personalizzate. Puoi anche aggiungere avvisi in base a queste metriche.

Passaggi successivi