Google utilizza la tecnologia AI per tradurre i contenuti nella tua lingua preferita. Le traduzioni generate dall'AI potrebbero contenere errori.

Migrazione delle code in modalità push a Cloud Tasks (Java)

Prima di eseguire l'upgrade all'ultima versione dell'SDK dei servizi App Engine, consulta la panoramica della migrazione.

Esegui l'upgrade alle librerie client di Cloud Tasks

Se preferisci abbandonare completamente i servizi in bundle legacy, puoi migrare il codice per utilizzare direttamente l'API Cloud Tasks. Ciò richiede il refactoring del codice dell'applicazione.

Cloud Tasks ti consente di accedere allo stesso servizio a cui accedi con l'API RPC Task Queues. Ciò significa che non devi ricreare le code push e le attività push esistenti. Tuttavia, devi eseguire la migrazione del codice che crea o interagisce con le code push o le attività push per utilizzare l'API Cloud Tasks.

Puoi creare e interagire con le code push e le attività push utilizzando le API REST e RPC di Cloud Tasks, la libreria client Cloud Tasks, Google Cloud CLI e la Google Cloud console. Questa pagina fornisce esempi che utilizzano gcloud CLI e la libreria client Cloud Tasks.

Funzionalità non disponibili in Cloud Tasks

Per la migrazione delle librerie client di Cloud Tasks, le seguenti funzionalità non sono disponibili in Cloud Tasks:

Accodamento delle attività nelle transazioni Datastore
Utilizzo della libreria delle attività differite anziché di un servizio di gestione dei worker
Utilizzare le attività nelle applicazioni multi-tenant
Simulazione con il server di sviluppo locale
Aggiunta di attività in modo asincrono

In alternativa, se esegui l'upgrade all'SDK più recente, funzionalità come attività differite, spazi dei nomi e simulazione locale sono supportate tramite il wrapper SDK.

Prezzi e quote

La migrazione delle code in modalità push a Cloud Tasks potrebbe influire sui prezzi e sulle quote della tua app.

Prezzi

Consulta i prezzi di Cloud Tasks per stimare il costo mensile prima della migrazione.

Analogamente a Task Queues, l'invio di richieste alla tua app App Engine con una destinazione push Cloud Tasks è senza costi. Tuttavia, a differenza delle code di attività, Cloud Tasks addebita i costi per l'operazione eseguita, ad esempio la creazione, l'eliminazione o la gestione delle attività. Ciò potrebbe comportare un costo mensile complessivo più elevato rispetto alla coda delle attività di App Engine complementare.

Quote

Anche le richieste Cloud Tasks vengono conteggiate ai fini delle quote di richieste di App Engine.

Come Task Queues, Cloud Tasks ha quote specifiche per il servizio. La migrazione a Cloud Tasks probabilmente cambierà le tue quote.

Prima di iniziare

Le sezioni seguenti descrivono i passaggi di configurazione prima di eseguire la migrazione delle code push a Cloud Tasks.

Esegui la migrazione delle code in modalità pull

Prima di iniziare, migra le code pull prima di seguire le istruzioni riportate in questa guida per migrare le code push. La migrazione delle code pull dopo la migrazione delle code push non è consigliata perché l'utilizzo obbligatorio del file queue.yaml potrebbe causare un comportamento imprevisto con Cloud Tasks.

Proteggere la configurazione delle code

Una volta avviato il processo di migrazione a Cloud Tasks, la modifica del file queue.yaml può causare un comportamento imprevisto e non è consigliata. Proteggi la configurazione della coda dalle modifiche apportate dal file queue.yaml seguendo questi passaggi.

Configura gcloud CLI in modo che ometta il file queue.yaml nei deployment futuri.

Aggiungi il file queue.yaml a un file .gcloudignore. Per verificare se hai già un file .gcloudignore, puoi eseguire il comando seguente nel terminale dalla directory di primo livello dell'app. Questo comando restituirà il nome del file se esiste.
```
ls -a | grep .gcloudignore
```
Per saperne di più sui file .gcloudignore, consulta la documentazione di riferimento su .gcloudignore.
Limita le autorizzazioni per il file queue.yaml.

Segui le best practice descritte nella nostra guida alla configurazione sicura delle code.
Scopri di più su Cloud Tasks e sul file queue.yaml (facoltativo).

Quando utilizzi l'API Cloud Tasks per gestire la configurazione della coda, il deployment di un file queue.yaml sostituisce la configurazione impostata da Cloud Tasks, il che può causare un comportamento imprevisto. Per saperne di più, leggi Gestione delle code e queue.yaml.

Autenticare l'app nell'API Cloud Tasks

Devi autenticare la tua app nell'API Cloud Tasks. Questa sezione descrive l'autenticazione per due diversi casi d'uso.

Per sviluppare o testare la tua app localmente, ti consigliamo di utilizzare un account di servizio. Per istruzioni sulla configurazione di unaccount di serviziot e sul collegamento all'app, leggi Ottenere e fornire manualmente le credenziali deaccount di servizioce account.

Per eseguire il deployment dell'app su App Engine, non è necessario fornire una nuova autenticazione. Le Credenziali predefinite dell'applicazione (ADC) deducono i dettagli di autenticazione per le app App Engine.

Importa le librerie client di Cloud

Per utilizzare la libreria client di Cloud Tasks con la tua app App Engine:

Specifica la dipendenza della libreria client di Cloud Tasks nel file pom.xml:

<dependency>
  <groupId>com.google.cloud</groupId>
  <artifactId>google-cloud-tasks</artifactId>
  <version>1.3.0</version>
</dependency>

Importa le dipendenze della libreria client di Cloud Tasks nei file responsabili della creazione e dell'inserimento in coda delle attività:

import com.google.cloud.tasks.v2.AppEngineHttpRequest;
import com.google.cloud.tasks.v2.CloudTasksClient;
import com.google.cloud.tasks.v2.HttpMethod;
import com.google.cloud.tasks.v2.QueueName;
import com.google.cloud.tasks.v2.Task;

Creare e gestire le code

Questa sezione descrive come creare e gestire le code utilizzando l'API Cloud Tasks.

Con Cloud Tasks, non utilizzi un file queue.yaml per creare o gestire le code. Utilizza invece l'API Cloud Tasks. L'utilizzo sia di un file queue.yaml sia dell'API Cloud Tasks non è consigliato, ma potrebbe essere una parte inevitabile della migrazione da Task Queues a Cloud Tasks a seconda della tua app. Leggi Utilizzo della gestione delle code rispetto a queue.yaml per scoprire le best practice.

Creare code

Leggi questa sezione se la tua app crea code a livello di programmazione o se vuoi creare code aggiuntive dalla riga di comando.

In Cloud Tasks, i nomi delle code hanno il formato projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID. La parte LOCATION_ID del nome della coda corrisponde a una Google Cloud regione. La parte QUEUE_ID del nome della coda equivale al campo name della coda di Task Queues. Il nome della coda viene generato durante la creazione della coda in base al progetto, alla regione e al QUEUE_ID specificati.

In generale, la posizione della coda (ovvero la regione) deve corrispondere a quella della tua app. Le due eccezioni a questa regola riguardano le app che utilizzano la regione europe-west e le app che utilizzano la regione us-central. In Cloud Tasks, queste regioni sono chiamate rispettivamente europe-west1 e us-central1.

Puoi specificare la configurazione della coda facoltativa durante la creazione della coda, ma puoi anche farlo aggiornando la coda dopo la creazione.

Non è necessario ricreare le code esistenti. Esegui invece la migrazione del codice che interagisce con le code esistenti leggendo le parti pertinenti di questa guida.

Riutilizzare i nomi delle code

Devi attendere 7 giorni dopo l'eliminazione di una coda per crearne una con lo stesso ID coda nello stesso progetto e nella stessa località (ovvero regione).

L'esempio seguente crea due code utilizzando Cloud Tasks. La prima coda ha l'ID coda queue-blue ed è configurata per inviare tutte le attività alla versione v2 del servizio task-module a una velocità di 5/s. La seconda coda ha l'ID coda queue-red e invia le attività a una velocità di 1/s. Entrambi vengono creati nel progetto con ID progetto your-project-id nella località us-central1. Si tratta dell'equivalente di Cloud Tasks della creazione di code in Task Queues.

gcloud

gcloud CLI deduce il progetto e la località dalla configurazione di gcloud CLI.

gcloud tasks queues create queue-blue \
    --max-dispatches-per-second=5 \
    --routing-override=service:task-module,version:v2

gcloud tasks queues create queue-red \
    --max-dispatches-per-second=1

libreria client

import com.google.cloud.tasks.v2.AppEngineRouting;
import com.google.cloud.tasks.v2.CloudTasksClient;
import com.google.cloud.tasks.v2.LocationName;
import com.google.cloud.tasks.v2.Queue;
import com.google.cloud.tasks.v2.QueueName;
import com.google.cloud.tasks.v2.RateLimits;

public class CreateQueue {
  public static void createQueue(
      String projectId, String locationId, String queueBlueName, String queueRedName)
      throws Exception {
    try (CloudTasksClient client = CloudTasksClient.create()) {
      // TODO(developer): Uncomment these lines and replace with your values.
      // String projectId = "your-project-id";
      // String locationId = "us-central1";
      // String queueBlueName = "queue-blue";
      // String queueRedName = "queue-red";

      LocationName parent = LocationName.of(projectId, locationId);

      Queue queueBlue =
          Queue.newBuilder()
              .setName(QueueName.of(projectId, locationId, queueBlueName).toString())
              .setRateLimits(RateLimits.newBuilder().setMaxDispatchesPerSecond(5.0))
              .setAppEngineRoutingOverride(
                  AppEngineRouting.newBuilder().setVersion("v2").setService("task-module"))
              .build();

      Queue queueRed =
          Queue.newBuilder()
              .setName(QueueName.of(projectId, locationId, queueRedName).toString())
              .setRateLimits(RateLimits.newBuilder().setMaxDispatchesPerSecond(1.0))
              .build();

      Queue[] queues = new Queue[] {queueBlue, queueRed};
      for (Queue queue : queues) {
        Queue response = client.createQueue(parent, queue);
        System.out.println(response);
      }
    }
  }
}

Per saperne di più, consulta il riferimento di Cloud Tasks Creazione di una coda Cloud Tasks.

Impostare la velocità di elaborazione della coda

La tabella seguente elenca i campi che differiscono da Task Queues a Cloud Tasks.

Campo Code attività	Campo Cloud Tasks	Descrizione
`rate`	`max_dispatches_per_second`	La frequenza massima con cui le attività vengono inviate dalla coda
`max_concurrent_requests`	`max_concurrent_dispatches`	Il numero massimo di attività in parallelo che possono essere inviate dalla coda
`bucket_size`	`max_burst_size`	Cloud Tasks calcola una proprietà di sola lettura `max_burst_size` che limita la velocità di elaborazione delle attività nella coda in base al valore di `max_dispatches_per_second`. Questo campo consente alla coda di avere una frequenza elevata in modo che l'elaborazione inizi poco dopo l'inserimento in coda di un'attività, ma limita comunque l'utilizzo delle risorse quando molte attività vengono inserite in coda in un breve periodo di tempo. Per le code App Engine create o aggiornate utilizzando un file `queue.xml/yaml`, `max_burst_size` è inizialmente uguale a `bucket_size`. Tuttavia, se la coda viene successivamente passata a un comando `update` utilizzando qualsiasi interfaccia Cloud Tasks, `max_burst_size` verrà reimpostato in base al valore di `max_dispatches_per_second`, indipendentemente dal fatto che `max_dispatches_per_second` venga aggiornato.
`total_storage_limit`	Deprecato in Cloud Tasks	Cloud Tasks non supporta l'impostazione di un limite di archiviazione personalizzato

Puoi impostare la velocità di elaborazione della coda quando crei la coda o la aggiorni in un secondo momento. L'esempio seguente utilizza Cloud Tasks per impostare la velocità di elaborazione di una coda denominata queue-blue che è già stata creata. Se queue-blue è stato creato o configurato utilizzando un file queue.yaml, il seguente esempio reimpostamax_burst_size in base al valore max_dispatches_per_second di 20. Questo è l'equivalente di Cloud Tasks dell'impostazione della velocità di elaborazione della coda in Task Queues.

gcloud

gcloud tasks queues update queue-blue \
    --max-dispatches-per-second=20 \
    --max-concurrent-dispatches=10

libreria client

import com.google.cloud.tasks.v2.CloudTasksClient;
import com.google.cloud.tasks.v2.LocationName;
import com.google.cloud.tasks.v2.Queue;
import com.google.cloud.tasks.v2.QueueName;
import com.google.cloud.tasks.v2.RateLimits;
import com.google.cloud.tasks.v2.UpdateQueueRequest;

public class UpdateQueue {
  public static void updateQueue(String projectId, String locationId, String queueId)
      throws Exception {
    try (CloudTasksClient client = CloudTasksClient.create()) {
      // TODO(developer): Uncomment these lines and replace with your values.
      // String projectId = "your-project-id";
      // String locationId = "us-central1";
      // String queueId = "queue-blue";

      LocationName parent = LocationName.of(projectId, locationId);

      Queue queueBlue =
          Queue.newBuilder()
              .setName(QueueName.of(projectId, locationId, queueId).toString())
              .setRateLimits(
                  RateLimits.newBuilder()
                      .setMaxDispatchesPerSecond(20.0)
                      .setMaxConcurrentDispatches(10))
              .build();

      UpdateQueueRequest request = UpdateQueueRequest.newBuilder().setQueue(queueBlue).build();

      Queue response = client.updateQueue(request);
      System.out.println(response);
    }
  }
}

Per scoprire di più, consulta Definire i limiti di frequenza.

Disattivare e riprendere le code

Cloud Tasks utilizza il termine sospensione nello stesso modo in cui Task Queues utilizza il termine disattivazione. La messa in pausa di una coda impedisce l'esecuzione delle attività nella coda fino al ripristino della coda. Tuttavia, puoi continuare ad aggiungere attività a una coda in pausa. Cloud Tasks utilizza il termine riprendi nello stesso modo di Task Queues.

L'esempio seguente mette in pausa una coda con ID coda queueName. Questo è l'equivalente di Cloud Tasks della disattivazione delle code in Task Queues.

gcloud

gcloud tasks queues pause queueName

libreria client

import com.google.cloud.tasks.v2.CloudTasksClient;
import com.google.cloud.tasks.v2.QueueName;

public class PauseQueue {
  public static void pauseQueue(String projectId, String locationId, String queueId)
      throws Exception {
    try (CloudTasksClient client = CloudTasksClient.create()) {
      // TODO(developer): Uncomment these lines and replace with your values.
      // String projectId = "your-project-id";
      // String locationId = "us-central1";
      // String queueId = "foo";

      // Construct the fully qualified queue name.
      String queueName = QueueName.of(projectId, locationId, queueId).toString();

      client.pauseQueue(queueName);
      System.out.println("Queue Paused.");
    }
  }
}

Per saperne di più, consulta il riferimento di Cloud Tasks Messa in pausa delle code.

Elimina code

Una volta eliminata una coda, devi attendere 7 giorni prima di crearne una con lo stesso nome. Se non puoi aspettare 7 giorni, valuta la possibilità di eliminare tutte le attività da una coda e riconfigurarla.

L'esempio seguente elimina la coda con ID coda foo. Questo è l'equivalente di Cloud Tasks dell'eliminazione delle code in Task Queues.

gcloud

gcloud tasks queues delete foo

libreria client

import com.google.cloud.tasks.v2.CloudTasksClient;
import com.google.cloud.tasks.v2.QueueName;

public class DeleteQueue {
  public static void deleteQueue(String projectId, String locationId, String queueId)
      throws Exception {
    try (CloudTasksClient client = CloudTasksClient.create()) {
      // TODO(developer): Uncomment these lines and replace with your values.
      // String projectId = "your-project-id";
      // String locationId = "us-central1";
      // String queueId = "foo";

      // Construct the fully qualified queue name.
      String queueName = QueueName.of(projectId, locationId, queueId).toString();

      client.deleteQueue(queueName);
      System.out.println("Queue Deleted.");
    }
  }
}

Per saperne di più, consulta il riferimento di Cloud Tasks Eliminazione delle code.

Creazione e gestione delle attività

Questa sezione descrive come creare e gestire le attività utilizzando l'API Cloud Tasks.

Creare attività

La tabella seguente elenca i campi che differiscono da Task Queues a Cloud Tasks.

Campo Code attività	Campo Cloud Tasks	Descrizione
N/D	`app_engine_http_request`	Crea una richiesta che ha come target un servizio App Engine. Queste attività sono chiamate attività App Engine.
`method`	`http_method`	Specifica il metodo di richiesta, ad esempio `POST`
`url`	`relative_uri`	Specifica il gestore delle attività. Nota la differenza nell'ultima lettera: `i` per Uniform Resource Identifier anziché `l` per Uniform Resource Locator
`target`	`app_engine_routing`	Facoltativo. Specifica `service`, `version` e `instance` di App Engine per un'attività App Engine. Se non impostati, vengono utilizzati il servizio, la versione e l'istanza predefiniti.

L'esempio seguente crea un'attività che viene indirizzata al gestore /worker sul servizio App Engine predefinito. Questo è l'equivalente di Cloud Tasks per la creazione di attività in code di attività.

gcloud

gcloud tasks create-app-engine-task \
    --queue=default \
    --method=POST \
    --relative-uri=/worker?key=key

libreria client

import com.google.cloud.tasks.v2.AppEngineHttpRequest;
import com.google.cloud.tasks.v2.CloudTasksClient;
import com.google.cloud.tasks.v2.HttpMethod;
import com.google.cloud.tasks.v2.QueueName;
import com.google.cloud.tasks.v2.Task;
import com.google.protobuf.ByteString;
import java.nio.charset.Charset;

public class CreateTask {
  public static void createTask(String projectId, String locationId, String queueId)
      throws Exception {
    try (CloudTasksClient client = CloudTasksClient.create()) {
      // TODO(developer): Uncomment these lines and replace with your values.
      // String projectId = "your-project-id";
      // String locationId = "us-central1";
      // String queueId = "default";
      String key = "key";

      // Construct the fully qualified queue name.
      String queueName = QueueName.of(projectId, locationId, queueId).toString();

      // Construct the task body.
      Task taskParam =
          Task.newBuilder()
              .setAppEngineHttpRequest(
                  AppEngineHttpRequest.newBuilder()
                      .setRelativeUri("/worker?key=" + key)
                      .setHttpMethod(HttpMethod.GET)
                      .build())
              .build();

      Task taskPayload =
          Task.newBuilder()
              .setAppEngineHttpRequest(
                  AppEngineHttpRequest.newBuilder()
                      .setBody(ByteString.copyFrom(key, Charset.defaultCharset()))
                      .setRelativeUri("/worker")
                      .setHttpMethod(HttpMethod.POST)
                      .build())
              .build();

      // Send create task request.
      Task[] tasks = new Task[] {taskParam, taskPayload};
      for (Task task : tasks) {
        Task response = client.createTask(queueName, task);
        System.out.println(response);
      }
    }
  }
}

Per saperne di più, consulta il riferimento di Cloud Tasks Creazione di attività App Engine.

Specifica il servizio di destinazione e il routing

La specifica del servizio, della versione e dell'istanza di destinazione di App Engine per le attività App Engine è facoltativa. Per impostazione predefinita, le attività App Engine vengono indirizzate al servizio, alla versione e all'istanza predefiniti al momento del tentativo di esecuzione dell'attività.

Imposta la proprietà app_engine_routing dell'attività durante la creazione per specificare un servizio, una versione o un'istanza App Engine diversi per l'attività.

Per indirizzare tutte le attività di una determinata coda allo stesso servizio, versione e istanza di App Engine, puoi impostare la proprietà app_engine_routing_override nella coda.

Per saperne di più, consulta il riferimento di Cloud Tasks Configura il routing.

Trasferire i dati al gestore

Come per le code di attività, puoi passare i dati al gestore in due modi utilizzando Cloud Tasks. Puoi trasmettere i dati come parametri di query nell'URI relativo oppure nel corpo della richiesta utilizzando i metodi HTTP POST o PUT.

Cloud Tasks utilizza il termine body nello stesso modo in cui Task Queues utilizza il termine payload. In Cloud Tasks, il tipo di contenuto del corpo predefinito è octet-stream anziché testo normale. Puoi impostare il tipo di contenuto del corpo specificandolo nell'intestazione.

L'esempio seguente passa una chiave al gestore /worker in due modi diversi. Questo è l'equivalente di Cloud Tasks di trasferimento di dati al gestore in Code di attività.

gcloud

gcloud tasks create-app-engine-task \
    --queue=default \
    --method=GET  \
    --relative-uri=/worker?key=blue \
    --routing=service:worker

gcloud tasks create-app-engine-task \
    --queue=default \
    --method=POST \
    --relative-uri=/worker \
    --routing=service:worker \
    --body-content="{'key': 'blue'}"

libreria client

import com.google.cloud.tasks.v2.AppEngineHttpRequest;
import com.google.cloud.tasks.v2.CloudTasksClient;
import com.google.cloud.tasks.v2.HttpMethod;
import com.google.cloud.tasks.v2.QueueName;
import com.google.cloud.tasks.v2.Task;
import com.google.protobuf.ByteString;
import java.nio.charset.Charset;

public class CreateTask {
  public static void createTask(String projectId, String locationId, String queueId)
      throws Exception {
    try (CloudTasksClient client = CloudTasksClient.create()) {
      // TODO(developer): Uncomment these lines and replace with your values.
      // String projectId = "your-project-id";
      // String locationId = "us-central1";
      // String queueId = "default";
      String key = "key";

      // Construct the fully qualified queue name.
      String queueName = QueueName.of(projectId, locationId, queueId).toString();

      // Construct the task body.
      Task taskParam =
          Task.newBuilder()
              .setAppEngineHttpRequest(
                  AppEngineHttpRequest.newBuilder()
                      .setRelativeUri("/worker?key=" + key)
                      .setHttpMethod(HttpMethod.GET)
                      .build())
              .build();

      Task taskPayload =
          Task.newBuilder()
              .setAppEngineHttpRequest(
                  AppEngineHttpRequest.newBuilder()
                      .setBody(ByteString.copyFrom(key, Charset.defaultCharset()))
                      .setRelativeUri("/worker")
                      .setHttpMethod(HttpMethod.POST)
                      .build())
              .build();

      // Send create task request.
      Task[] tasks = new Task[] {taskParam, taskPayload};
      for (Task task : tasks) {
        Task response = client.createTask(queueName, task);
        System.out.println(response);
      }
    }
  }
}

Specifica il nome dell'attività

La specifica del nome dell'attività è facoltativa. Se non specifichi il nome dell'attività, Cloud Tasks lo crea per te generando un ID attività e deducendo il progetto e la località (ovvero la regione) in base alla coda specificata durante la creazione dell'attività.

I nomi delle attività hanno il formato projects/PROJECT_ID/locations/LOCATION_ID/queues/QUEUE_ID/tasks/TASK_ID. La parte TASK_ID del nome dell'attività equivale al campo name dell'attività di code di attività.

Riutilizzare i nomi delle attività

Devi attendere prima di riutilizzare il nome di un'attività. Il periodo di tempo che devi attendere prima di farlo varia a seconda che la coda che distribuisce l'attività sia stata creata in Cloud Tasks o Task Queues.

Per le attività nelle code create utilizzando le code di attività (inclusa la coda predefinita), devi attendere circa 9 giorni dopo l'eliminazione o l'esecuzione dell'attività originale. Per le attività nelle code create utilizzando Cloud Tasks, devi attendere circa un'ora dopo l'eliminazione o l'esecuzione dell'attività originale.

L'esempio seguente crea un'attività con TASK_ID impostato su first-try e la aggiunge alla coda predefinita. Questo è l'equivalente di Cloud Tasks per la denominazione delle attività in Code di attività.

gcloud

gcloud CLI crea il nome del task deducendo il progetto e la località dalla configurazione.

gcloud tasks create-app-engine-task first-try \
    --queue=default \
    --method=GET \
    --relative-uri=/worker

libreria client

Con la libreria client, devi specificare il nome completo dell'attività se vuoi specificare TASK_ID. Il progetto e la località devono corrispondere a quelli della coda a cui viene aggiunto il task.

import com.google.cloud.tasks.v2.AppEngineHttpRequest;
import com.google.cloud.tasks.v2.CloudTasksClient;
import com.google.cloud.tasks.v2.HttpMethod;
import com.google.cloud.tasks.v2.QueueName;
import com.google.cloud.tasks.v2.Task;
import com.google.cloud.tasks.v2.TaskName;

public class CreateTaskWithName {
  public static void createTaskWithName(
      String projectId, String locationId, String queueId, String taskId) throws Exception {
    try (CloudTasksClient client = CloudTasksClient.create()) {
      // TODO(developer): Uncomment these lines and replace with your values.
      // String projectId = "your-project-id";
      // String locationId = "us-central1";
      // String queueId = "default";
      // String taskId = "first-try"

      String queueName = QueueName.of(projectId, locationId, queueId).toString();

      Task.Builder taskBuilder =
          Task.newBuilder()
              .setName(TaskName.of(projectId, locationId, queueId, taskId).toString())
              .setAppEngineHttpRequest(
                  AppEngineHttpRequest.newBuilder()
                      .setRelativeUri("/worker")
                      .setHttpMethod(HttpMethod.GET)
                      .build());

      // Send create task request.
      Task response = client.createTask(queueName, taskBuilder.build());
      System.out.println(response);
    }
  }
}

Riprova le attività non riuscite

Puoi impostare la configurazione dei tentativi di ripetizione delle attività nelle code durante la creazione della coda o aggiornandola. La tabella seguente elenca il campo Task Queues e il campo Cloud Tasks corrispondente.

Campo Code attività	Campo Cloud Tasks
`task_retry_limit`	`max_attempts`
`task_age_limit`	`max_retry_duration`
`min_backoff_seconds`	`min_backoff`
`max_backoff_seconds`	`max_backoff`
`max_doublings`	`max_doublings`

Utilizzare parametri di ripetizione specifici per l'attività

I parametri di ripetizione specifici per le attività configurati in Task Queues funzionano in Cloud Tasks, ma non puoi modificarli o impostarli per nuove attività. Per modificare i parametri di ripetizione per un'attività che ha parametri di ripetizione specifici per l'attività, ricrea l'attività con una coda Cloud Tasks che abbia i parametri di ripetizione desiderati.

L'esempio seguente mostra vari scenari di nuovi tentativi:

In fooqueue, i tentativi di esecuzione delle attività vengono ripetuti fino a sette volte e per un massimo di due giorni dal primo tentativo di esecuzione. Una volta superati entrambi i limiti, l'operazione non va a buon fine in modo permanente.
In barqueue, App Engine tenta di ripetere le attività, aumentando l'intervallo linearmente tra un tentativo e l'altro fino a raggiungere il backoff massimo e riprovando indefinitamente all'intervallo massimo (quindi gli intervalli tra le richieste sono 10 s, 20 s, 30 s, ..., 190 s, 200 s, 200 s, ...).
In bazqueue, l'intervallo tra i tentativi inizia a 10 secondi, poi raddoppia tre volte, aumenta in modo lineare e infine i tentativi vengono eseguiti a intervalli massimi (quindi gli intervalli tra le richieste sono 10 s, 20 s, 40 s, 80 s, 160 s, 240 s, 300 s, 300 s, ...).

Questo è l'equivalente di Cloud Tasks per riprovare le attività� in Code di attività.

gcloud

Quando imposti opzioni che specificano un numero di secondi, devi includere s dopo il numero intero (ad es. 200s e non 200).

gcloud tasks queues create fooqueue \
    --max-attempts=7 \
    --max-retry-duration=172800s  #2*60*60*24 seconds in 2 days

gcloud tasks queues create barqueue \
    --min-backoff=10s \
    --max-backoff=200s \
    --max-doublings=0

gcloud tasks queues create bazqueue \
    --min-backoff=10s \
    --max-backoff=300s \
    --max-doublings=3

libreria client

import com.google.cloud.tasks.v2.CloudTasksClient;
import com.google.cloud.tasks.v2.LocationName;
import com.google.cloud.tasks.v2.Queue;
import com.google.cloud.tasks.v2.QueueName;
import com.google.cloud.tasks.v2.RateLimits;
import com.google.cloud.tasks.v2.RetryConfig;
import com.google.protobuf.Duration;

public class RetryTask {
  public static void retryTask(
      String projectId, String locationId, String fooqueue, String barqueue, String bazqueue)
      throws Exception {
    try (CloudTasksClient client = CloudTasksClient.create()) {
      // TODO(developer): Uncomment these lines and replace with your values.
      // String projectId = "your-project-id";
      // String locationId = "us-central1";
      // String fooqueue = "fooqueue";
      // String barqueue = "barqueue";
      // String bazqueue = "bazqueue";

      LocationName parent = LocationName.of(projectId, locationId);

      Duration retryDuration = Duration.newBuilder().setSeconds(2 * 60 * 60 * 24).build();
      Duration min = Duration.newBuilder().setSeconds(10).build();
      Duration max1 = Duration.newBuilder().setSeconds(200).build();
      Duration max2 = Duration.newBuilder().setSeconds(300).build();

      Queue foo =
          Queue.newBuilder()
              .setName(QueueName.of(projectId, locationId, fooqueue).toString())
              .setRateLimits(RateLimits.newBuilder().setMaxDispatchesPerSecond(1.0))
              .setRetryConfig(
                  RetryConfig.newBuilder().setMaxAttempts(7).setMaxRetryDuration(retryDuration))
              .build();

      Queue bar =
          Queue.newBuilder()
              .setName(QueueName.of(projectId, locationId, barqueue).toString())
              .setRateLimits(RateLimits.newBuilder().setMaxDispatchesPerSecond(1.0))
              .setRetryConfig(
                  RetryConfig.newBuilder()
                      .setMinBackoff(min)
                      .setMaxBackoff(max1)
                      .setMaxDoublings(0))
              .build();

      Queue baz =
          Queue.newBuilder()
              .setName(QueueName.of(projectId, locationId, bazqueue).toString())
              .setRateLimits(RateLimits.newBuilder().setMaxDispatchesPerSecond(1.0))
              .setRetryConfig(
                  RetryConfig.newBuilder()
                      .setMinBackoff(min)
                      .setMaxBackoff(max2)
                      .setMaxDoublings(3))
              .build();

      Queue[] queues = new Queue[] {foo, bar, baz};
      for (Queue queue : queues) {
        Queue response = client.createQueue(parent, queue);
        System.out.println(response);
      }
    }
  }
}

Per saperne di più, consulta la documentazione di riferimento di Cloud Tasks Impostare i parametri di ripetizione.

Eliminare attività da una coda

Quando elimini un'attività, devi attendere 9 giorni prima di crearne una con lo stesso nome se l'attività si trovava in una coda creata utilizzando un file queue.yaml oppure 1 ora se l'attività si trovava in una coda creata utilizzando Cloud Tasks.

L'esempio seguente elimina l'attività con ID attività foo dalla coda con ID coda queue1. Questo è l'equivalente di Cloud Tasks dell'eliminazione delle attività� in Task Queues.

gcloud

Il progetto e la località dell'attività vengono dedotti dal progetto predefinito di gcloud CLI.

gcloud tasks delete foo --queue=queue1

libreria client

import com.google.cloud.tasks.v2.CloudTasksClient;
import com.google.cloud.tasks.v2.TaskName;

public class DeleteTask {
  public static void deleteTask(String projectId, String locationId, String queueId, String taskId)
      throws Exception {
    try (CloudTasksClient client = CloudTasksClient.create()) {
      // TODO(developer): Uncomment these lines and replace with your values.
      // String projectId = "your-project-id";
      // String locationId = "us-central1";
      // String queueId = "queue1";
      // String taskId = "foo";

      // Construct the fully qualified queue name.
      String taskName = TaskName.of(projectId, locationId, queueId, taskId).toString();

      client.deleteTask(taskName);
      System.out.println("Task Deleted.");
    }
  }
}

Per saperne di più, consulta il riferimento di Cloud Tasks Eliminare un'attività da una coda.

Eliminare definitivamente le attività

L'esempio seguente elimina definitivamente tutte le attività dalla coda con ID coda foo. Questo è l'equivalente di Cloud Tasks dell'eliminazione definitiva delle attività in code di attività.

gcloud

Il progetto e la località della coda vengono dedotti dal progetto predefinito di gcloud CLI.

gcloud tasks queues purge foo

libreria client

import com.google.cloud.tasks.v2.CloudTasksClient;
import com.google.cloud.tasks.v2.QueueName;

public class PurgeQueue {
  public static void purgeQueue(String projectId, String locationId, String queueId)
      throws Exception {
    try (CloudTasksClient client = CloudTasksClient.create()) {
      // TODO(developer): Uncomment these lines and replace with your values.
      // String projectId = "your-project-id";
      // String locationId = "us-central1";
      // String queueId = "foo";

      // Construct the fully qualified queue name.
      String queueName = QueueName.of(projectId, locationId, queueId).toString();

      client.purgeQueue(queueName);
      System.out.println("Queue Purged.");
    }
  }
}

Per saperne di più, consulta il riferimento di Cloud Tasks Eliminazione di tutte le attività da una coda.

Esempio di Cloud Tasks Java 8

L'esempio seguente è una configurazione di base per creare una coda e accodare un'attività con Cloud Tasks. Presuppone che lo sviluppatore abbia creato un file pom.xml per specificare la dipendenza di Cloud Tasks come descritto nella sezione Importazione della libreria client. Questo è l'equivalente di Cloud Tasks di un esempio di coda di attività Java 8 in Task Queues.

Il file responsabile della creazione e dell'inserimento in coda dell'attività crea un'attività e la aggiunge alla coda predefinita utilizzando la libreria client Cloud Tasks:

import com.google.cloud.tasks.v2.AppEngineHttpRequest;
import com.google.cloud.tasks.v2.CloudTasksClient;
import com.google.cloud.tasks.v2.HttpMethod;
import com.google.cloud.tasks.v2.QueueName;
import com.google.cloud.tasks.v2.Task;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

@WebServlet(
    name = "TaskEnqueue",
    description = "Enqueue a task targeted at endpoint '/cloudtasks/worker'",
    urlPatterns = "/cloudtasks/enqueue")
public class Enqueue extends HttpServlet {

  // TODO(developer): Replace these variables before running the sample.
  static final String projectId = "my-project-id";
  static final String locationId = "us-central1";

  // Function creates Cloud Tasks from form submissions.
  protected void doPost(HttpServletRequest request, HttpServletResponse response)
      throws ServletException, IOException {
    String key = request.getParameter("key");

    try (CloudTasksClient client = CloudTasksClient.create()) {
      // Construct the fully qualified queue name.
      String queueName = QueueName.of(projectId, locationId, "default").toString();

      // Construct the task body.
      Task task =
          Task.newBuilder()
              .setAppEngineHttpRequest(
                  AppEngineHttpRequest.newBuilder()
                      .setRelativeUri("/cloudtasks/worker?key=" + key)
                      .setHttpMethod(HttpMethod.POST)
                      .build())
              .build();

      // Add the task to the default queue.
      Task taskResponse = client.createTask(queueName, task);
      System.out.println("Task created: " + taskResponse.getName());
    }

    response.sendRedirect("/");
  }
}

Il file che definisce il worker gestisce l'attività:

import java.io.IOException;
import java.util.logging.Logger;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

@WebServlet(
    name = "TaskWorker",
    description = "Endpoint to process Cloud Task requests",
    urlPatterns = "/cloudtasks/worker"
)
public class Worker extends HttpServlet {

  private static final Logger log = Logger.getLogger(Worker.class.getName());

  // Worker function to process POST requests from Cloud Tasks targeted at the
  // '/cloudtasks/worker' endpoint.
  protected void doPost(HttpServletRequest request, HttpServletResponse response)
      throws ServletException, IOException {
    String key = request.getParameter("key");
    log.info("Worker is processing " + key);
  }
}

Passaggi successivi

Documentazione di Cloud Tasks
Libreria client Cloud Tasks
Panoramica del riferimento REST di Cloud Tasks
Panoramica del riferimento RPC di Cloud Tasks

Migrazione delle code in modalità push a Cloud Tasks (Java) Mantieni tutto organizzato con le raccolte Salva e classifica i contenuti in base alle tue preferenze.

Esegui l'upgrade alle librerie client di Cloud Tasks

Funzionalità non disponibili in Cloud Tasks

Prezzi e quote

Prezzi

Quote

Prima di iniziare

Esegui la migrazione delle code in modalità pull

Proteggere la configurazione delle code

Autenticare l'app nell'API Cloud Tasks

Importa le librerie client di Cloud

Creare e gestire le code

Creare code

Riutilizzare i nomi delle code

gcloud

libreria client

Impostare la velocità di elaborazione della coda

gcloud

libreria client

Disattivare e riprendere le code

gcloud

libreria client

Elimina code

gcloud

libreria client

Creazione e gestione delle attività

Creare attività

gcloud

libreria client

Specifica il servizio di destinazione e il routing

Trasferire i dati al gestore

gcloud

libreria client

Specifica il nome dell'attività

Riutilizzare i nomi delle attività

gcloud

libreria client

Riprova le attività non riuscite

Utilizzare parametri di ripetizione specifici per l'attività

gcloud

libreria client

Eliminare attività da una coda

gcloud

libreria client

Eliminare definitivamente le attività

gcloud

libreria client

Esempio di Cloud Tasks Java 8

Passaggi successivi

Migrazione delle code in modalità push a Cloud Tasks (Java)