Una volta che le attività si trovano in una coda in modalità pull, un worker può prenderle in leasing. Una volta elaborate le attività, il lavoratore deve eliminarle.
Prima di iniziare
- Crea una coda in modalità pull.
- Crea attività e aggiungile alla coda in modalità pull.
Contesto importante
- Questo metodo è applicabile solo ai worker in esecuzione all'interno di un servizio nell'ambiente standard.
- Quando utilizzi le code pull, sei responsabile del dimensionamento dei worker in base al volume di elaborazione.
Leasing delle attività
Una volta che le attività sono in coda, un lavoratore può prenderne in affitto una o più utilizzando il metodo leaseTasks()
. Potrebbe verificarsi un breve ritardo prima che le attività aggiunte di recente utilizzando add()
diventino disponibili tramite leaseTasks()
.
Quando richiedi un lease, specifichi il numero di attività da acquisire (fino a un massimo di 1000) e la durata del lease in secondi (fino a un massimo di una settimana). La durata del lease deve essere sufficiente a garantire che l'attività più lenta abbia il tempo di terminare prima della scadenza del periodo di lease. Puoi modificare una concessione di attività utilizzando modifyTaskLease()
.
Il leasing di un'attività la rende non disponibile per l'elaborazione da parte di un altro worker e rimane non disponibile fino alla scadenza del leasing.
Il seguente esempio di codice acquisisce in leasing le attività dalla coda pull-queue
per un'ora:
Raggruppamento con i tag delle attività
Non tutte le attività sono uguali: il codice può "taggare" le attività e poi scegliere quelle da affittare in base al tag. Il tag funge da filtro.
Quindi, acquisisci le attività filtrate:
Regolazione dei tassi di polling
I worker che eseguono il polling della coda per le attività da acquisire devono rilevare se stanno tentando di acquisire attività più velocemente di quanto la coda possa fornirle. Se si verifica questo errore, possono essere generate le seguenti eccezioni da leaseTasks()
:
Il codice deve rilevare queste eccezioni, interrompere la chiamata a leaseTasks()
e riprovare più tardi. Per evitare questo problema, ti consigliamo di impostare un limite RPC più elevato quando chiami leaseTasks()
. Devi anche eseguire il backoff quando una richiesta di lease restituisce un elenco vuoto di attività.
Se generi più di 10 richieste LeaseTasks per coda al secondo, solo le prime 10 richieste restituiranno risultati. Se le richieste superano questo limite, viene restituito OK
con zero risultati.
Monitoraggio delle attività nella console Google Cloud
Per visualizzare informazioni su tutte le attività e le code nella tua applicazione:
Apri la pagina Cloud Tasks nella console Google Cloud e cerca il valore Pull nella colonna Tipo.
Fai clic sul nome della coda che ti interessa per aprire la pagina dei dettagli. Mostra tutte le attività nella coda selezionata.
Eliminazione delle attività
Una volta completata un'attività, il worker deve eliminarla dalla coda. Se vedi attività rimanenti in una coda dopo che un worker ha terminato di elaborarle, è probabile che il worker non sia riuscito a completarle. In questo caso, le attività verranno elaborate da un altro worker.
Puoi eliminare una singola attività o un elenco di attività utilizzando deleteTask()
. Per eliminare un'attività, devi conoscerne il nome. Puoi trovare i nomi delle attività nel Task object
restituito da leaseTasks()
.
Il seguente esempio di codice mostra come eliminare un'attività da una coda: