谷歌应用引擎任务队列

Question

在谷歌应用引擎中使用任务队列时遇到一些问题。我尝试在这个网站上做同样的事情： https://developers.google.com/appengine/docs/python/taskqueue/overview-push

但似乎我的任务从未执行，我收到此错误：

警告 2012-11-25 15:29:21,258 taskqueue_stub.py:1978] 任务 task1 未能执行。此任务将在 12.800 秒后重试

除了这些之外，代码基本相同：

class CounterWorker(webapp.RequestHandler):
  def init(self): # should run at most 1/s
    def txn():
      logging.info("bla")
    db.run_in_transaction(txn)

我只是像这样添加任务：

taskqueue.add(url='/worker')

我真正想要的只是运行一段不会超时的代码。所以我读到我可以使用任务队列。但我似乎无法让它工作。

Answer 1

默认情况下，任务队列将 POST 请求发送到映射到 URL 的任何处理程序（在您的情况下是 /worker，它应该映射到 CounterWorker）。因此，您需要在 CounterWorker 方法中定义一个 post 方法。

class CounterWorker(webapp.RequestHandler):
  def post(self):
    def txn():
      logging.info("bla")
    db.run_in_transaction(txn)

您的评论表明任务应该只运行 1/s。您可以在 queue.yaml config file 中定义它。

另外，任务队列有 10 分钟的超时时间，所以它们不会永远运行。要纠正这个问题，请尝试链接它们或使用deferred API。对于长时间运行的进程，backends API 可能更合适。

Answer 2

如果您只想执行“普通”任务，请查看延迟函数。

Background work with the deferred library

from google.appengine.ext import deferred

  def do_something_expensive(a, b, c=None):
      logging.info("Doing something expensive!")
      # Do your work here

  # Somewhere else
  deferred.defer(do_something_expensive, "Hello, world!", 42, c=True)

您不需要 url/webapp 处理程序，因为您可以直接传递函数。