celery - 将 eventlet.corolocal 与 Celery 一起使用

Question

有没有人有使用 eventlet.corolocal 的经验，尤其是 celery(为 worker 提供 eventlets)？

如果是这样，您能否阐明以下代码示例的问题所在？

...
from eventlet.corolocal import local

...

ev_local = local()

@app.task
def dummy_task(self, a):
  if hasattr(ev_local, a):
    ev_local.a += a
  else:
    ev_local.a = a
  print ev_local.a

if __name__ == '__main__':
  app.start()

如果我现在启动一个具有并发性的 celery worker，比如 5，

celery multi start 1 -A process_mss -l info -P eventlet -c 5 --verbose

并调用任务 (dummy_task) 20 次 -

...

for i in xrange(20):
  dummy_task.delay(1)

我看到 5 个 eventlet 每个处理 4 个任务(使用 id 返回的 eventlet.corolocal.get_ident())。但是，eventlet 总是在不知道变量/属性“a”的情况下找到 ev_local。所以 dummy_task(...) 中的打印语句总是打印 1。

有什么可能出错的提示吗？

Answer 1

这里有个小错别字: 如果 hasattr(ev_local, a):

hasattr 的第二个参数必须是字符串:hasattr(ev_local, 'a')。