python - 还有其他人在使用 django-celery 保持 ghettoq 在后台运行时遇到困难吗？

Question

nohup python manage.py celeryd -f queue.log 2>queue.err 1>queue.out &

很好地处理一个请求，然后客户端应用程序将下一个作业发布到队列中失败并出现此回溯。

   tasks.spawn_job.delay(details)

 File "/releases/env/lib/python2.6/site-packages/celery/task/base.py", line 321, in delay
   return self.apply_async(args, kwargs)

 File "/releases/env/lib/python2.6/site-packages/celery/task/base.py", line 337, in apply_async
   return apply_async(self, args, kwargs, **options)

 File "/releases/env/lib/python2.6/site-packages/celery/messaging.py", line 248, in _inner
   return fun(*args, **kwargs)

 File "/releases/env/lib/python2.6/site-packages/celery/execute/__init__.py", line 101, in apply_async
   publisher or publish.close()

 File "/releases/env/lib/python2.6/site-packages/carrot/messaging.py", line 766, in close
   self.backend.close()

 File "/releases/env/lib/python2.6/site-packages/ghettoq/taproot.py", line 188, in close
   for consumer_tag in self._t.consumers.keys():

AttributeError: 'thread._local' object has no attribute 'consumers'

我们正在切换到rabbitMQ，因为它“......正常工作”

Answer 1

切换到 RabbitMQ 可能是个好主意。但请注意，这是在 ghettoq 的 master 分支中修复的错误。