python - GAE强制推送任务队列执行下一个任务

Question

我在 GAE 中有速率为 1/s 的推送任务队列。并非该队列上的每个任务都需要执行，但我只能在调用时验证这一点。因此，无论何时调用任务，我都有“if (condition) execute else drop”语句。

现在我的问题是我有太多的任务，其中很多都会被丢弃。我不想只是等待下一秒调用另一个任务，而是想强制我的队列调用下一个任务，这样一秒钟就不会被浪费。

我想问的是 - 是否可以强制队列立即获取另一个任务而不是等待？还是我应该自己实现？

如果不清楚，很抱歉，我会尝试用更好的语言表达。

提前致谢!

Answer 1

您需要使用 pull tasks ，对于每个推送任务队列也是一个拉取任务。当你的推送任务执行时，从拉取队列中租用一批任务并检查它们的条件。
下一步将是丢弃所有不再“有效”的任务并执行单个有效任务。一旦你执行了一个有效的任务，你就会返回所有剩余的任务(将它们的时间租为零)。

如果存在有效任务，此流程应为每个推送任务至少授予一项任务。