Creazione code in modalità push

In questa pagina viene descritto come creare e personalizzare una coda in modalità push ed esaminare i contenuti di una coda.

Utilizzo di un file di configurazione delle code per creare code

Per elaborare un'attività, devi aggiungerla a una coda in modalità push. App Engine fornisce una coda in modalità push predefinita, denominata default, che è configurata e pronta per l'utilizzo con le impostazioni predefinite. Se vuoi, puoi semplicemente aggiungere tutte le attività alla coda predefinita, senza dover creare e configurare altre code.

Per aggiungere code o cambiare la configurazione predefinita, modifica il file di configurazione della coda per l'applicazione che carichi in App Engine. Puoi creare fino a 100 code. Le code non possono essere create in modo dinamico.

Questo file di configurazione delle code definisce due code:

queue:
- name: queue-blue
  target: v2.task-module
  rate: 5/s

- name: queue-red
  rate: 1/s

Per caricare il file:

gcloud app deploy queue.yaml

Tutte le attività aggiunte a queue-blue vengono inviate al modulo di destinazione v2.task-module. La frequenza di aggiornamento di queue-red cambia da 5/s a 1/s. Le attività verranno eliminate in coda e inviate alle rispettive destinazioni alla velocità di 1 attività al secondo.

Se elimini una coda, devi attendere circa 7 giorni prima di crearne una nuova con lo stesso nome.

Esistono molti altri parametri che possono essere aggiunti al file di configurazione per personalizzare il comportamento di una coda in modalità push. Per ulteriori informazioni, consulta la documentazione di riferimento sui file di configurazione della coda.

Definizione della frequenza di elaborazione delle coda in modalità push

Puoi controllare la frequenza con cui le attività vengono elaborate in ciascuna delle tue code definendo altre istruzioni, come rate, bucket_size e max_concurrent_requests.

La coda di attività utilizza i bucket token per controllare la frequenza di esecuzione delle attività. Ogni coda denominata ha un token bucket che contiene i token, fino al limite massimo specificato da bucket_size o un massimo di 5 token se non specifichi la dimensione del bucket.

Ogni volta che l'applicazione esegue un'attività, un token viene rimosso dal bucket. L'app continua a elaborare le attività in coda fino all'esaurimento dei token del bucket della coda. App Engine ricarica il bucket con nuovi token continuamente in base al valore rate specificato per la coda.

Se la coda contiene attività da elaborare e il bucket della coda contiene token, App Engine elabora contemporaneamente tutte le attività esistenti. Ciò può portare a burst di elaborazione, consumo di risorse di sistema e concorrenza con le richieste di distribuzione degli utenti.

Se vuoi impedire l'esecuzione di troppe attività contemporaneamente o impedire la contesa del datastore, utilizza max_concurrent_requests.

L'esempio seguente mostra come impostare max_concurrent_requests per limitare le attività, nonché come regolare la dimensione e la frequenza del bucket in base alle esigenze e alle risorse disponibili della tua applicazione:

queue:
- name: queue-blue
  rate: 20/s
  bucket_size: 40
  max_concurrent_requests: 10

Impostazione dei limiti di spazio di archiviazione per tutte le code

Puoi utilizzare il file di configurazione delle code per definire la quantità totale di spazio di archiviazione che i dati delle attività possono utilizzare in tutte le code. Per definire il limite di spazio di archiviazione totale, includi un elemento denominato total_storage_limit al livello superiore:

# Set the total storage limit for all queues to 120MB
total_storage_limit: 120M
queue:
- name: queue-blue
  rate: 35/s

Il valore è un numero seguito da un'unità: B per byte, K per kilobyte, M per megabyte, G per gigabyte, T per terabyte. Ad esempio, 100K specifica un limite di 100 kilobyte. Se con l'aggiunta di un'attività la coda supera il limite di spazio di archiviazione, la chiamata per aggiungere l'attività non andrà a buon fine. Il limite predefinito è 500M (500 megabyte) per le app gratuite. Per le app fatturate non esiste un limite finché non ne imposti esplicitamente uno. Puoi utilizzare questo limite per proteggere la tua app da un errore di programmazione fork bomb in cui ogni attività aggiunge più altre attività durante la sua esecuzione.

Se la tua app riceve errori per quota insufficiente quando aggiungi attività, puoi aumentare il limite di spazio di archiviazione totale. Se utilizzi questa funzionalità, ti consigliamo vivamente di impostare un limite corrispondente allo spazio di archiviazione necessario per attività di diversi giorni. In questo modo è possibile eseguire il backup temporaneo delle code e continuare ad accettare nuove attività mentre si lavora sul backlog, pur continuando a essere protetti da un errore di programmazione fork bomb.

Monitoraggio delle code nella console Google Cloud

  1. Nella console Google Cloud, vai alla pagina Cloud Tasks.

    Vai a Cloud Tasks

    Tieni presente che se vai alla pagina Coda attività di App Engine, troverai istruzioni che ti guideranno alla pagina Cloud Tasks. Questo aggiornamento nella console Google Cloud non modifica il funzionamento delle code delle attività.

  2. Abilita l'API Cloud Tasks.

  3. Nella pagina Cloud Tasks, vedrai un elenco di tutte le code nell'applicazione. Se fai clic sul nome di una coda, viene visualizzata la pagina Dettagli coda, in cui sono mostrate tutte le attività della coda selezionata.

Passaggi successivi

Scopri di più sulla creazione di attività.