Avvio del flusso e tailing in tempo reale delle voci di log

Questo documento descrive come visualizzare le voci di log in tempo reale tramite e tailing in tempo reale. La funzionalità di streaming dei log ti consente di visualizzare le voci di log in tempo reale ed è disponibile in Esplora log. Il tailing in tempo reale consente di visualizzare le voci di log in tempo reale ed è disponibile come gcloud CLI Comando gcloud alpha logging tail e come metodo API Cloud Logging entries.tail.

Quando visualizzi e analizzi i log utilizzando Esplora log, gcloud logging read o il metodo API entries.list, visualizzi le voci di log memorizzate da Cloud Logging. Quando esegui lo streaming o visualizzi le voci di log in tempo reale, le visualizzi mentre le applicazioni le scrivono nell'API Cloud Logging.

Trasmetti i log in Esplora log

In Esplora log, puoi visualizzare i dati dei log in tempo reale utilizzando Avvia flusso di log. Quando utilizzi Stream log, puoi aggiungere una query per eseguire lo streaming solo dei log corrispondenti alla query. Per eseguire lo streaming dei log:

  1. Nella console Google Cloud, vai alla pagina Esplora log:

    Vai a Esplora log

    Se utilizzi la barra di ricerca per trovare questa pagina, seleziona il risultato con il sottotitolo Logging.

  2. Nella casella di testo Query, inserisci una query e poi fai clic su Stream log.

    Mentre Logging scrive i dati dei log, solo i log che corrispondono alla query vengono visualizzati nel riquadro Risultati delle query. Se non viene fornita una query, Logging mostra la query le voci di log archiviate. Lo streaming dei log continua finché non selezioni la barra di scorrimento nel riquadro dei log. Quando lo streaming è stato interrotto, viene visualizzato il pulsante Riavvia streaming.

    Per informazioni sulle query, consulta Creare query in Esplora log.

Utilizzo del tailing in tempo reale in Google Cloud CLI

Il tailing in tempo reale consente di visualizzare le voci di log in tempo reale come Cloud Logging li scrive utilizzando Google Cloud CLI o l'API Cloud Logging.

Il tailing in tempo reale non è supportato per i bucket di log con controlli di accesso a livello di campo, indipendentemente può eseguire il flusso di log per i bucket in Esplora log.

Per informazioni sul metodo dell'API per il monitoraggio in tempo reale, consulta il metodo entries.tail.

Installazione di gcloud alpha logging tail in corso…

Per utilizzare gcloud alpha logging tail, devi avere installato Python 3 e il pacchetto Python grpcio.

Per istruzioni su come installare Python, consulta pagina Python. Per istruzioni su come installare il gestore dei pacchetti Python, pip, necessario per installare il pacchetto grpcio, consulta la pagina del programma di installazione dei pacchetti Python.

Per installare gcloud alpha logging tail, completa i seguenti passaggi:

  1. Verifica di aver installato Google Cloud CLI. Per istruzioni su come installare Google Cloud CLI, consulta Installazione di Google Cloud CLI.

  2. Verifica di utilizzare la versione 302.0.0 o successiva delle con gcloud CLI.

    gcloud version
    

    Per istruzioni su come aggiornare gcloud CLI, consulta gcloud components update.

  3. Installa i componenti alpha della gcloud CLI:

    gcloud components install alpha
    
  4. Per gli utenti di MacOS, Linux e Cloud Shell:

    1. Installa le librerie client gRPC:

       sudo pip3 install grpcio
      
    2. Imposta la variabile di ambiente CLOUDSDK_PYTHON_SITEPACKAGES su qualsiasi valore:

       export CLOUDSDK_PYTHON_SITEPACKAGES=1
      
  5. Utilizza i seguenti comandi per impostare l'ID progetto Google Cloud e per autenticarti:

    gcloud config set project PROJECT_ID
    gcloud auth login
    

    Per ottenere l'ID progetto, consulta la pagina Creare e gestire progetti.

  6. Verifica che gcloud alpha logging tail sia installato eseguendo questo comando :

    gcloud alpha logging tail
    

    Il comando visualizza il seguente messaggio:

    Initializing tail session.

    Ora visualizzi le voci di log per il tuo progetto Google Cloud man mano che vengono scritte da Logging.

    Registra le voci durante una sessione live-tail.

Per ulteriori informazioni sull'utilizzo del monitoraggio in tempo reale, consulta la guida di riferimento di gcloud alpha logging tail.

Buffering e ordinazione

Poiché Logging può ricevere voci di log in ordine cronologico dell'ordine, il tailing in tempo reale offre un'impostazione di buffer-window in modo da un compromesso tra la visualizzazione delle voci di log mentre vengono scritte visualizzandole in ordine crescente. Puoi impostare la finestra di buffer tra 0 e 60 secondi.

Tieni presente le seguenti caratteristiche della finestra di buffer:

  • La finestra di buffer predefinita è di due secondi.

  • Logging ritardi nella scrittura delle voci di log nei bucket di log per durata della finestra di buffer.

  • Se una voce di log viene scritta al di fuori della finestra del buffer, Logging restituisce le voci di log man mano che vengono ricevute.

Quando configuri la finestra del buffer, devi trovare un compromesso tra visualizzare i log così come sono scritti e le voci in ordine non corretto.

Finestra di buffer Svantaggio
0 secondi Le voci di log più recenti sono state restituite, ma è più probabile che non siano in ordine.
60 secondi Un ritardo di 60 secondi prima di visualizzare le voci restituite, ma la maggior parte dei log viene restituita in ordine crescente.

Limiti e quote

La tabella seguente elenca i limiti e le quote per il monitoraggio in tempo reale:

Limiti e quote Valore
Voci restituite al minuto 60.000
Se più di 60.000 voci corrispondono a un filtro, Il logging restituisce il conteggio delle voci nella risposta.
Sessioni aperte di logging in tempo reale per progetto Google Cloud 10

Limitazioni del client

Per un progetto Google Cloud che scrive molte voci rapidamente, il tuo client potrebbe non essere in grado di utilizzarle così rapidamente come vengono scritte. In questo caso, la registrazione limita il numero totale di voci inviate, dando la priorità alle voci più recenti. Al termine della sessione di coda, Logging restituisce il numero di voci che non sono state visualizzate a causa dei limiti del client.

Utilizza il tailing in tempo reale con le librerie client

Il monitoraggio in tempo reale ti consente di visualizzare le voci di log in tempo reale man mano che vengono scritte da Cloud Logging. Per informazioni sul metodo dell'API per il monitoraggio in tempo reale, consulta il metodo entries.tail.

Il monitoraggio in tempo reale non è supportato per i bucket di log con controlli dell'accesso a livello di campo, ma puoi riprodurre in streaming i log per questi bucket in Esplora log.

Questo esempio mostra le voci di log di tailing in tempo reale di un determinato logger.

Go

Per scoprire come installare e utilizzare la libreria client per Logging, consulta Librerie client di Logging.

Per autenticarti su Logging, configura Credenziali predefinite dell'applicazione. Per maggiori informazioni, consulta Configurare l'autenticazione per un ambiente di sviluppo locale.

import (
	"context"
	"fmt"
	"io"

	logging "cloud.google.com/go/logging/apiv2"
	"cloud.google.com/go/logging/apiv2/loggingpb"
)

// tailLogs creates a channel to stream log entries that were recently ingested for a project
func tailLogs(projectID string) error {
	// projectID := "your_project_id"

	ctx := context.Background()
	client, err := logging.NewClient(ctx)
	if err != nil {
		return fmt.Errorf("NewClient error: %w", err)
	}
	defer client.Close()

	stream, err := client.TailLogEntries(ctx)
	if err != nil {
		return fmt.Errorf("TailLogEntries error: %w", err)
	}
	defer stream.CloseSend()

	req := &loggingpb.TailLogEntriesRequest{
		ResourceNames: []string{
			"projects/" + projectID,
		},
	}
	if err := stream.Send(req); err != nil {
		return fmt.Errorf("stream.Send error: %w", err)
	}

	// read and print two or more streamed log entries
	for counter := 0; counter < 2; {
		resp, err := stream.Recv()
		if err == io.EOF {
			break
		}
		if err != nil {
			return fmt.Errorf("stream.Recv error: %w", err)
		}
		fmt.Printf("received:\n%v\n", resp)
		if resp.Entries != nil {
			counter += len(resp.Entries)
		}
	}
	return nil
}

Java

Per scoprire come installare e utilizzare la libreria client per Logging, consulta Librerie client di Logging.

Per autenticarti in Logging, configura le credenziali predefinite dell'applicazione. Per maggiori informazioni, consulta Configurare l'autenticazione per un ambiente di sviluppo locale.

import com.google.cloud.logging.LogEntry;
import com.google.cloud.logging.LogEntryServerStream;
import com.google.cloud.logging.Logging;
import com.google.cloud.logging.Logging.TailOption;
import com.google.cloud.logging.LoggingOptions;

public class TailLogEntries {

  public static void main(String[] args) throws Exception {
    // TODO(developer): Optionally provide the logname as an argument.
    String logName = args.length > 0 ? args[0] : "";

    LoggingOptions options = LoggingOptions.getDefaultInstance();
    try (Logging logging = options.getService()) {

      // Optionally compose a filter to tail log entries only from specific log
      LogEntryServerStream stream;

      if (logName != "") {
        stream =
            logging.tailLogEntries(
                TailOption.filter(
                    "logName=projects/" + options.getProjectId() + "/logs/" + logName));
      } else {
        stream = logging.tailLogEntries();
      }
      System.out.println("start streaming..");
      for (LogEntry log : stream) {
        System.out.println(log);
        // cancel infinite streaming after receiving first entry
        stream.cancel();
      }
    }
  }
}

Node.js

Per scoprire come installare e utilizzare la libreria client per Logging, consulta Librerie client di Logging.

Per autenticarti in Logging, configura le credenziali predefinite dell'applicazione. Per ulteriori informazioni, vedi Configura l'autenticazione per un ambiente di sviluppo locale.

const {Logging} = require('@google-cloud/logging');
const logging = new Logging();

/**
 * TODO(developer): Replace logName with the name of your log.
 */
const log = logging.log(logName);
console.log('running tail log entries test');

const stream = log
  .tailEntries({
    filter: 'timestamp > "2021-01-01T23:00:00Z"',
  })
  .on('error', console.error)
  .on('data', resp => {
    console.log(resp.entries);
    console.log(resp.suppressionInfo);
    // If you anticipate many results, you can end a stream early to prevent
    // unnecessary processing and API requests.
    stream.end();
  })
  .on('end', () => {
    console.log('log entry stream has ended');
  });

// Note: to get all project logs, invoke logging.tailEntries