google-app-engine - Google App Engine - 任务依赖

Question

在我的应用程序中，我有一个很长的任务，所以我将它分成 n 个较小的任务。这n个任务完成后，还要执行另一个任务，这取决于这n个任务的结果。我如何使用 Task API 实现这种依赖关系？即在其他 n 个任务之后执行一个任务。

Answer 1

我认为有两种方法可以解决这个问题。假设任务TD依赖于n个其他任务TA，并且有一个队列Q。

1. 将n个TA任务插入队列Q。当每个任务TA完成后，它检查自己是否是队列Q中的最后一个任务。如果一个TA是队列Q中的最后一个任务，它将TD插入队列问。

2. 将 n 个 TA 任务和 TD 插入 Q 队列。当 TD 运行时，它检查所有 TA 任务是否完成。如果有任何 TA 未完成，TD 通过返回 200-299 范围之外的任何 HTTP 状态代码来取消其执行。

这些方法的关键是获取队列Q中的任务数量。虽然我没有尝试过，但我知道有一个Python API提供了一个实验方法来获取特定队列的TaskQueue资源。 stats.totalTask​​s 属性是队列中的队列总数。

请参阅http://code.google.com/intl/en/appengine/docs/python/taskqueue/rest.html