GCP Cloud Tasks：缩短创建先前创建的命名任务的时间

问题描述

我们正在开发基于GCP云任务的队列流程，每当特定的Firestore文档写触发器触发时，该流程就会发送状态电子邮件。我们使用Cloud Tasks的原因是，这样可以在发送电子邮件之前创建延迟（将来使用2分钟的ScheduledTime属性），并控制dedup（通过使用格式为[firestore-collection-name]的任务名称） ]-[doc-id]），因为Firestore文档上的“写入”触发器可以在创建文档时触发多次，然后通过后端云功能快速更新。

一旦达到任务的延迟期限，云任务就会运行，并且会发送包含更新的Firestore文档信息的电子邮件。之后，将任务从队列中删除，一切都很好。

除了：

如果用户更新Firestore文档（例如20或30分钟后），我们希望重新发送状态电子邮件，但无法使用相同的任务名称创建任务。我们收到以下错误：

409 The task cannot be created because a task with this name existed too recently. For more information about task de-duplication see https://cloud.google.com/tasks/docs/reference/rest/v2/projects.locations.queues.tasks/create#body.request_body.FIELDS.task.

这是意外的，因为最后一个任务成功完成，此时队列为空。错误消息中引用的文档说：

如果使用Cloud Tasks创建了任务队列，则另一个任务在原始任务后约1小时内无法创建具有相同名称的已被删除或执行。

问题：是否可以通过减少时间量甚至完全取消限制来绕过此限制？

解决方法

简短的回答是“否”。正如您已经指出的那样，文档对此行为非常清楚，您应该等待1个小时来创建一个与先前创建的名称相同的任务。 API或客户端库不允许减少此时间。

话虽如此，我建议不要使用相同的任务ID，而要对任务使用不同的ID，并在请求的正文中添加一个标识符。例如，使用Python：

from google.cloud import tasks_v2
from google.protobuf import timestamp_pb2
import datetime

def create_task(project,queue,location,payload=None,in_seconds=None):
    client = tasks_v2.CloudTasksClient()

    parent = client.queue_path(project,queue)

    task = {
            'app_engine_http_request': {
                'http_method': 'POST','relative_uri': '/task/'+queue
            }
    }
    if payload is not None:
        converted_payload = payload.encode()

        task['app_engine_http_request']['body'] = converted_payload

    if in_seconds is not None:
        d = datetime.datetime.utcnow() + datetime.timedelta(seconds=in_seconds)

        timestamp = timestamp_pb2.Timestamp()
        timestamp.FromDatetime(d)

        task['schedule_time'] = timestamp

    response = client.create_task(parent,task)

    print('Created task {}'.format(response.name))
    print(response)

#You can change DOCUMENT_ID with USER_ID or something to identify the task
create_task(PROJECT_ID,QUEUE,REGION,DOCUMENT_ID)

google-cloud-platform google-cloud-tasks