使用云函数来调度云任务,云任务按计划时间触发HTTP端点。到目前为止,使用以下配置创建了一个队列。每秒最大调度:500次最大并发调度:1000次最大尝试:5次
云功能是pub子触发的。在第二个pub中,订阅可能接收到10000条消息,而云功能则相应地扩展,并将创建10000个任务。
问题:如果缩放的云函数必须创建更多的任务并将其分配给不同的队列,那么云功能如何才能最好地决定和创建队列,并将任务分配给不同的队列,同时考虑到冷队列和暖队列的功能,以避免延迟。
我读过这篇官方文档,但对于假人https://cloud.google.com/tasks/docs/manage-cloud-task-scaling#queue来说还不太清楚。
发布于 2021-10-13 16:35:20
回到原来的问题,如果您的流程是时间敏感的,并且需要同时触发500多个请求,则需要创建额外的队列(如文档中提到的)。
要在多个队列中分配AMQP消息,需要定义需要的队列数量和切分键。如果您有一个数字ID,您可以使用模X (X是队列的数目)作为键,并使用相应的队列名。您也可以使用散列或数据。
在您的进程中,如果存在队列,则向其添加任务,或创建任务,然后添加任务。无论如何,您不能有超过1000个队列。
https://stackoverflow.com/questions/69549817
复制相似问题