resource"google_cloud_tasks_queue""default"{name="cloud-tasks-queue-name"location="us-central1"}

resource"google_service_account""default"{account_id="cloud-run-task-invoker"display_name="Cloud Run Task Invoker"}

resource"google_cloud_run_service_iam_binding""default"{location=google_cloud_run_v2_service.default.locationservice=google_cloud_run_v2_service.default.namerole="roles/run.invoker"members=["serviceAccount:${google_service_account.default.email}"]}

fromtypingimportOptionalfromgoogle.cloudimporttasks_v2defcreate_http_task_with_token(project:str,location:str,queue:str,url:str,payload:bytes,service_account_email:str,audience:Optional[str]=None,)->tasks_v2.Task:"""Create an HTTP POST task with an OIDC token and an arbitrary payload.    Args:        project: The project ID where the queue is located.        location: The location where the queue is located.        queue: The ID of the queue to add the task to.        url: The target URL of the task.        payload: The payload to send.        service_account_email: The service account to use for generating the OIDC token.        audience: Audience to use when generating the OIDC token.    Returns:        The newly created task.    """# Create a client.client=tasks_v2.CloudTasksClient()# Construct the request body.task=tasks_v2.Task(http_request=tasks_v2.HttpRequest(http_method=tasks_v2.HttpMethod.POST,url=url,oidc_token=tasks_v2.OidcToken(service_account_email=service_account_email,audience=audience,),body=payload,),)# Use the client to build and send the task.returnclient.create_task(tasks_v2.CreateTaskRequest(parent=client.queue_path(project,location,queue),task=task,))

google-cloud-tasks==2.18.0

importcom.google.cloud.tasks.v2.CloudTasksClient;importcom.google.cloud.tasks.v2.HttpMethod;importcom.google.cloud.tasks.v2.HttpRequest;importcom.google.cloud.tasks.v2.OidcToken;importcom.google.cloud.tasks.v2.QueueName;importcom.google.cloud.tasks.v2.Task;importcom.google.protobuf.ByteString;importjava.io.IOException;importjava.nio.charset.Charset;publicclassCreateHttpTaskWithToken{publicstaticvoidmain(String[]args)throwsIOException{// TODO(developer): Replace these variables before running the sample.StringprojectId="my-project-id";StringlocationId="us-central1";StringqueueId="my-queue";StringserviceAccountEmail="java-docs-samples-testing@java-docs-samples-testing.iam.gserviceaccount.com";createTask(projectId,locationId,queueId,serviceAccountEmail);}// Create a task with a HTTP target and authorization token using the Cloud Tasks client.publicstaticvoidcreateTask(StringprojectId,StringlocationId,StringqueueId,StringserviceAccountEmail)throwsIOException{// Instantiates a client.try(CloudTasksClientclient=CloudTasksClient.create()){Stringurl="https://example.com/taskhandler";// The full url path that the request will be sent toStringpayload="Hello, World!";// The task HTTP request body// Construct the fully qualified queue name.StringqueuePath=QueueName.of(projectId,locationId,queueId).toString();// Add your service account email to construct the OIDC token.// in order to add an authentication header to the request.OidcToken.BuilderoidcTokenBuilder=OidcToken.newBuilder().setServiceAccountEmail(serviceAccountEmail);// Construct the task body.Task.BuildertaskBuilder=Task.newBuilder().setHttpRequest(HttpRequest.newBuilder().setBody(ByteString.copyFrom(payload,Charset.defaultCharset())).setHttpMethod(HttpMethod.POST).setUrl(url).setOidcToken(oidcTokenBuilder).build());// Send create task request.Tasktask=client.createTask(queuePath,taskBuilder.build());System.out.println("Task created: "+task.getName());}}}

<?xmlversion='1.0'encoding='UTF-8'?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>com.example.tasks</groupId><artifactId>cloudtasks-snippets</artifactId><packaging>jar</packaging><name>GoogleCloudTasksSnippets</name><!--Theparentpomdefinescommonstylechecksandtestingstrategiesforoursamples.Removingorreplacingitshouldnotaffecttheexecutionofthesamplesinanyway.--><parent><groupId>com.google.cloud.samples</groupId><artifactId>shared-configuration</artifactId><version>1.2.0</version></parent><properties><maven.compiler.target>1.8</maven.compiler.target><maven.compiler.source>1.8</maven.compiler.source><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding></properties><dependencyManagement><dependencies><dependency><groupId>com.google.cloud</groupId><artifactId>libraries-bom</artifactId><version>26.32.0</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement><dependencies><dependency><groupId>com.google.cloud</groupId><artifactId>google-cloud-tasks</artifactId></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.13.2</version><scope>test</scope></dependency><dependency><groupId>com.google.truth</groupId><artifactId>truth</artifactId><version>1.4.0</version><scope>test</scope></dependency></dependencies></project>

import("context""fmt"cloudtasks"cloud.google.com/go/cloudtasks/apiv2"taskspb"cloud.google.com/go/cloudtasks/apiv2/cloudtaskspb")// createHTTPTaskWithToken constructs a task with a authorization token// and HTTP target then adds it to a Queue.funccreateHTTPTaskWithToken(projectID,locationID,queueID,url,email,messagestring)(*taskspb.Task,error){// Create a new Cloud Tasks client instance.// See https://godoc.org/cloud.google.com/go/cloudtasks/apiv2ctx:=context.Background()client,err:=cloudtasks.NewClient(ctx)iferr!=nil{returnnil,fmt.Errorf("NewClient: %w",err)}deferclient.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#CreateTaskRequestreq:=&taskspb.CreateTaskRequest{Parent:queuePath,Task:&taskspb.Task{// https://godoc.org/google.golang.org/genproto/googleapis/cloud/tasks/v2#HttpRequestMessageType:&taskspb.Task_HttpRequest{HttpRequest:&taskspb.HttpRequest{HttpMethod:taskspb.HttpMethod_POST,Url:url,AuthorizationHeader:&taskspb.HttpRequest_OidcToken{OidcToken:&taskspb.OidcToken{ServiceAccountEmail:email,},},},},},}// Add a payload message if one is present.req.Task.GetHttpRequest().Body=[]byte(message)createdTask,err:=client.CreateTask(ctx,req)iferr!=nil{returnnil,fmt.Errorf("cloudtasks.CreateTask: %w",err)}returncreatedTask,nil}

// Imports the Google Cloud Tasks library.const{CloudTasksClient}=require('@google-cloud/tasks');// Instantiates a client.constclient=newCloudTasksClient();asyncfunctioncreateHttpTaskWithToken(){// TODO(developer): Uncomment these lines and replace with your values.// const project = 'my-project-id';// const queue = 'my-queue';// const location = 'us-central1';// const url = 'https://example.com/taskhandler';// const serviceAccountEmail = 'client@<project-id>.iam.gserviceaccount.com';// const payload = 'Hello, World!';// Construct the fully qualified queue name.constparent=client.queuePath(project,location,queue);consttask={httpRequest:{headers:{'Content-Type':'text/plain',// Set content type to ensure compatibility your application's request parsing},httpMethod:'POST',url,oidcToken:{serviceAccountEmail,},},};if(payload){task.httpRequest.body=Buffer.from(payload).toString('base64');}console.log('Sending task:');console.log(task);// Send create task request.constrequest={parent:parent,task:task};const[response]=awaitclient.createTask(request);constname=response.name;console.log(`Created task${name}`);}createHttpTaskWithToken();

{"name":"appengine-cloudtasks","description":"Google App Engine Cloud Tasks example.","license":"Apache-2.0","author":"Google Inc.","private":true,"engines":{"node":">=16.0.0"},"files":["*.js"],"scripts":{"test":"c8 mocha -p -j 2 --timeout 30000","start":"node server.js"},"dependencies":{"@google-cloud/tasks":"^5.0.0","express":"^4.16.3"},"devDependencies":{"c8":"^10.0.0","chai":"^4.5.0","mocha":"^10.0.0","uuid":"^10.0.0"}}