0

我正在尝试将 beanstalkd 配置为 celery 的代理。我正在使用这个参考。

这是我的代码

from __future__ import absolute_import

from celery import Celery

celery = Celery('test_celery',
    broker='beanstalk://localhost:11300',
            include=['tasks'])

celery.conf.update(
  CELERY_TASK_RESULT_EXPIRES=3600,)

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

运行工作程序时出现以下错误。这发生在甚至没有调用任何任务的情况下。我没有在任何地方指定任何beantalkd管。

[2013-10-30 13:36:49,189: ERROR/MainProcess] consumer: Connection to broker lost.   
Trying to re-establish the connection...
Traceback (most recent call last):
File "/usr/lib/python2.7/site-packages/celery/worker/consumer.py", line 410, in start
self.consume_messages()
File "/usr/lib/python2.7/site-packages/celery/worker/consumer.py", line 904, in    
consume_messages
self.connection.drain_events(timeout=10.0)
File "/usr/lib/python2.7/site-packages/kombu/connection.py", line 281, in drain_events
return self.transport.drain_events(self.connection, **kwargs)
File "/usr/lib/python2.7/site-packages/kombu/transport/virtual/__init__.py", line 763,   
in drain_events
item, channel = get(timeout=timeout)
File "/usr/lib/python2.7/site-packages/kombu/transport/virtual/scheduling.py", line 39, 
in get
return self.fun(resource, **kwargs), resource
File "/usr/lib/python2.7/site-packages/kombu/transport/virtual/__init__.py", line 783, 
in _drain_channel
return channel.drain_events(timeout=timeout)
File "/usr/lib/python2.7/site-packages/kombu/transport/virtual/__init__.py", line 580,   
in drain_events
return self._get_many(self._active_queues, timeout=timeout)
File "/usr/lib/python2.7/site-packages/kombu/transport/beanstalk.py", line 75, in 
_get_many
if active not in watching]
File "build/bdist.linux-x86_64/egg/beanstalkc.py", line 195, in watch
return int(self._interact_value('watch %s\r\n' % name, ['WATCHING']))
File "build/bdist.linux-x86_64/egg/beanstalkc.py", line 107, in _interact_value
return self._interact(command, expected_ok, expected_err)[0]
File "build/bdist.linux-x86_64/egg/beanstalkc.py", line 90, in _interact
raise UnexpectedResponse(command.split()[0], status, results)

UnexpectedResponse: (u'watch', 'BAD_FORMAT', [])

有任何想法吗？

4

0 回答 0