启动时创建任务时的 DeadlineExceededException答案

【问题标题】：DeadlineExceededException when creating tasks on startup启动时创建任务时的 DeadlineExceededException
【发布时间】：2021-04-25 07:31:30
【问题描述】：

我在 Google Cloud Run 上部署了一个 Spring Boot 2.4.5 应用程序（使用 Jib 创建的图像）。启动时我想创建一个云任务，但我得到一个DeadlineExceededException。

如果我运行任务创建代码但由 HTTP 请求触发，则创建任务。并且应该在启动时创建的任务也被创建。就像启动时缺少某些东西，阻止创建任务一样。

启动事件

@EventListener(ApplicationReadyEvent.class)
public void doSomethingAfterStartup()  {
    LOGGER.info("ApplicationReadyEvent");
    String message = "GCP New Instance Start " + Instant.now();
    cloudTasksService.createTask("xxxx", "us-central1", "xxxx", message, 60);
}

任务创建代码

public void createTask(String projectId, String locationId, String queueId, String message, Integer delay) throws IOException {
    try (CloudTasksClient client = CloudTasksClient.create()) {
        LOGGER.info("Client created");
        String url = "xxxxxxxxx";
        String payload = String.format("{ \"text\": \"%s\"}", message);

        String queuePath = QueueName.of(projectId, locationId, queueId).toString();
        Instant eta = Instant.now().plusSeconds(delay);
        Task.Builder taskBuilder =
                Task.newBuilder()
                        .setScheduleTime(Timestamp.newBuilder().setSeconds(eta.getEpochSecond()).build())
                        .setHttpRequest(
                                HttpRequest.newBuilder()
                                        .setBody(ByteString.copyFrom(payload, Charset.defaultCharset()))
                                        .setUrl(url)
                                        .setHttpMethod(HttpMethod.POST)
                                        .build());
        LOGGER.info("TaskBuilder ready");
        Task task = client.createTask(queuePath, taskBuilder.build());
        LOGGER.info("Task created: {}", task.getName());
    }
}

HTTP 端点

@GetMapping("/tasks")
public ResponseEntity<Void> task(@RequestParam Integer delay) throws IOException {
    cloudTasksService.createTask("xxxx", "us-central1", "xxxx", "using HTTP request", delay);
    return ResponseEntity.accepted().build();
}

例外情况

com.google.api.gax.rpc.DeadlineExceededException: io.grpc.StatusRuntimeException: DEADLINE_EXCEEDED: Deadline exceeded after 5.200272920s. 
    at com.google.api.gax.rpc.ApiExceptionFactory.createException(ApiExceptionFactory.java:51)
    at com.google.api.gax.grpc.GrpcApiExceptionFactory.create(GrpcApiExceptionFactory.java:72)
    at com.google.api.gax.grpc.GrpcApiExceptionFactory.create(GrpcApiExceptionFactory.java:60)
    at com.google.api.gax.grpc.GrpcExceptionCallable$ExceptionTransformingFuture.onFailure(GrpcExceptionCallable.java:97)
    at com.google.api.core.ApiFutures$1.onFailure(ApiFutures.java:68)
    at com.google.common.util.concurrent.Futures$CallbackListener.run(Futures.java:1074)
    at com.google.common.util.concurrent.DirectExecutor.execute(DirectExecutor.java:30)
    at com.google.common.util.concurrent.AbstractFuture.executeListener(AbstractFuture.java:1213)
    at com.google.common.util.concurrent.AbstractFuture.addListener(AbstractFuture.java:724)
    at com.google.common.util.concurrent.ForwardingListenableFuture.addListener(ForwardingListenableFuture.java:45)
    at com.google.api.core.ApiFutureToListenableFuture.addListener(ApiFutureToListenableFuture.java:52)
    at com.google.common.util.concurrent.Futures.addCallback(Futures.java:1047)
    at com.google.api.core.ApiFutures.addCallback(ApiFutures.java:63)
    at com.google.api.gax.grpc.GrpcExceptionCallable.futureCall(GrpcExceptionCallable.java:67)
    at com.google.api.gax.rpc.UnaryCallable$1.futureCall(UnaryCallable.java:126)
    at com.google.api.gax.tracing.TracedUnaryCallable.futureCall(TracedUnaryCallable.java:75)
    at com.google.api.gax.rpc.UnaryCallable$1.futureCall(UnaryCallable.java:126)
    at com.google.api.gax.rpc.UnaryCallable.futureCall(UnaryCallable.java:87)
    at com.google.api.gax.rpc.UnaryCallable.call(UnaryCallable.java:112)
    at com.google.cloud.tasks.v2.CloudTasksClient.createTask(CloudTasksClient.java:1915)
    at com.google.cloud.tasks.v2.CloudTasksClient.createTask(CloudTasksClient.java:1885)
    at com.sps.playground.CloudTasksService.createTask(CloudTasksService.java:55)

【问题讨论】：

标签： google-cloud-platform google-cloud-run

【解决方案1】：

当任务排队时，工作人员似乎还没有准备好。我建议在启动时创建任务，因为这种情况经常发生，因为工作人员在处理任务时没有通过就绪检查，然后它就失败了。这也解释了为什么任务在被 HTTP 触发时正常运行。

您可以通过减少recommendations 之后的启动时间来解决此问题。此外，由于您将 Java 与 Springboot 一起使用，因此可能值得检查 Reducing startup tasks 的建议。

【讨论】：