检查 Google App Engine 中的队列是否为空

Question

我有一个脚本可以将任务添加到队列中。例如：

api.py:

from google.appengine.api import taskqueue    
[...]
for u in users:
    taskqueue.add(queue_name='mailqueue', url="/api/users/send-notification/%s" % (u.id), method='GET')

我想检查队列是否为空以及所有任务是否正在完成

view.py:

if queue_is_empty:
    print "Your task is finished"

Answer 1

您可以使用 QueueStatistics class

statsList = taskqueue.QueueStatistics.fetch([taskqueue.Queue("foo"), taskqueue.Queue("bar")])

https://cloud.google.com/appengine/docs/python/taskqueue/queue_statistics#QueueStatistics_queue

检查 Google App Engine 中的队列是否为空

Check if a queue is empty in Google App Engine

python

django

google-app-engine

task-queue