Crea attività target HTTP in modo programmatico

I gestori di Cloud Tasks possono essere eseguiti su qualsiasi endpoint HTTP con un indirizzo IP esterno, ad esempio GKE, Compute Engine o anche un server web on-premise. Le tue attività possono essere eseguite su uno qualsiasi di questi servizi in modo affidabile e configurabile.

Questo documento mostra come creare in modo programmatico attività target HTTP utilizzando le librerie client Cloud Tasks e inserirle nelle code Cloud Tasks. Puoi anche creare attività di destinazione HTTP nella console Google Cloud , utilizzando Google Cloud CLI o inviando una richiesta diretta all'API Cloud Tasks. Per maggiori informazioni, vedi Creare attività.

Per le attività con target HTTP (anziché target App Engine espliciti, che sono meno comuni), esistono due modi per creare attività:

  • Metodo CreateTask:devi creare esplicitamente un oggetto attività. Utilizza questo metodo se le attività nella coda hanno configurazioni di routing diverse. In questo caso, specifichi il routing a livello di attività e non puoi utilizzare il routing a livello di coda. Questo approccio utilizza il metodo CreateTask.

  • Metodo BufferTask:utilizza questo metodo se la coda è configurata per memorizzare nel buffer le attività davanti a un servizio. La coda deve avere un routing a livello di coda. Questo approccio utilizza il metodo BufferTask.

Per indicazioni su come scegliere tra i due metodi per creare attività HTTP, consulta Scegliere il metodo di creazione delle attività.

Crea un'attività utilizzando il metodo CreateTask

Questa sezione descrive la creazione di un'attività tramite la costruzione dell'oggetto attività. Utilizzi il metodo CreateTask.

Quando crei un'attività utilizzando il metodo CreateTask, crei e definisci esplicitamente l'oggetto attività. Devi specificare il servizio e il gestore che elaborano l'attività.

Se vuoi, puoi trasmettere al gestore dati specifici dell'attività. Puoi anche ottimizzare la configurazione per l'attività, ad esempio pianificare un orario futuro in cui deve essere eseguita o limitare il numero di tentativi di esecuzione dell'attività in caso di errore (vedi Configurazione avanzata).

Gli esempi seguenti chiamano il metodo CreateTask per creare un'attività utilizzando le librerie client di Cloud Tasks.

C# 


using Google.Cloud.Tasks.V2;
using Google.Protobuf;
using Google.Protobuf.WellKnownTypes;
using System;

class CreateHttpTask
{
    public string CreateTask(
        string projectId = "YOUR-PROJECT-ID",
        string location = "us-central1",
        string queue = "my-queue",
        string url = "http://example.com/taskhandler",
        string payload = "Hello World!",
        int inSeconds = 0)
    {
        CloudTasksClient client = CloudTasksClient.Create();
        QueueName parent = new QueueName(projectId, location, queue);

        var response = client.CreateTask(new CreateTaskRequest
        {
            Parent = parent.ToString(),
            Task = new Task
            {
                HttpRequest = new HttpRequest
                {
                    HttpMethod = HttpMethod.Post,
                    Url = url,
                    Body = ByteString.CopyFromUtf8(payload)
                },
                ScheduleTime = Timestamp.FromDateTime(
                    DateTime.UtcNow.AddSeconds(inSeconds))
            }
        });

        Console.WriteLine($"Created Task {response.Name}");
        return response.Name;
    }
}

Go 


// Command createHTTPtask constructs and adds a task to a Cloud Tasks Queue.
package main

import (
	"context"
	"fmt"

	cloudtasks "cloud.google.com/go/cloudtasks/apiv2"
	taskspb "cloud.google.com/go/cloudtasks/apiv2/cloudtaskspb"
)

// createHTTPTask creates a new task with a HTTP target then adds it to a Queue.
func createHTTPTask(projectID, locationID, queueID, url, message string) (*taskspb.Task, error) {

	// Create a new Cloud Tasks client instance.
	// See https://godoc.org/cloud.google.com/go/cloudtasks/apiv2
	ctx := context.Background()
	client, err := cloudtasks.NewClient(ctx)
	if err != nil {
		return nil, fmt.Errorf("NewClient: %w", err)
	}
	defer client.Close()

	// Build the Task queue path.
	queuePath := fmt.Sprintf("projects/%s/locations/%s/queues/%s", projectID, locationID, queueID)

	// Build the Task payload.
	// https://godoc.org/google.golang.org/genproto/googleapis/cloud/tasks/v2#CreateTaskRequest
	req := &taskspb.CreateTaskRequest{
		Parent