Здравствуйте !
Пытаюсь настроить связку windows+rabbitmq+celery
Сервер rabbitmq установил, создал пользователя
в браузере страничка http://localhost:15672/#/
отображается
но запустить celery не получается - выдает ошибку :
[2015-01-09 05:03:52,170: ERROR/MainProcess] Unrecoverable error: InterruptedError(4, 'Interrupted function call')
Traceback (most recent call last):
File "C:\Python33\lib\site-packages\celery-3.1.14-py3.3.egg\celery\worker\consumer.py", line 278, in start
blueprint.start(self)
File "C:\Python33\lib\site-packages\celery-3.1.14-py3.3.egg\celery\bootsteps.py", line 123, in start
step.start(parent)
File "C:\Python33\lib\site-packages\celery-3.1.14-py3.3.egg\celery\worker\consumer.py", line 478, in start
c.connection = c.connect()
File "C:\Python33\lib\site-packages\celery-3.1.14-py3.3.egg\celery\worker\consumer.py", line 375, in connect
callback=maybe_shutdown,
File "C:\Python33\lib\site-packages\kombu-3.0.22-py3.3.egg\kombu\connection.py", line 369, in ensure_connection
interval_start, interval_step, interval_max, callback)
File "C:\Python33\lib\site-packages\kombu-3.0.22-py3.3.egg\kombu\utils__init.py", line 243, in retry_over_time
return fun(args, kwargs)
File "C:\Python33\lib\site-packages\kombu-3.0.22-py3.3.egg\kombu\connection.py", line 237, in connect
return self.connection
File "C:\Python33\lib\site-packages\kombu-3.0.22-py3.3.egg\kombu\connection.py", line 741, in connection
self._connection = self._establish_connection()
File "C:\Python33\lib\site-packages\kombu-3.0.22-py3.3.egg\kombu\connection.py", line 696, in _establish_connectio
conn = self.transport.establish_connection()
File "C:\Python33\lib\site-packages\kombu-3.0.22-py3.3.egg\kombu\transport\pyamqp.py", line 112, in establish_conn
conn = self.Connection(*opts)
File "C:\Python33\lib\site-packages\amqp-2.0.0a1-py3.3.egg\amqp\connection.py", line 217, in init__
self.connect()
File "C:\Python33\lib\site-packages\amqp-2.0.0a1-py3.3.egg\amqp\connection.py", line 236, in connect
self.drain_events()
File "C:\Python33\lib\site-packages\amqp-2.0.0a1-py3.3.egg\amqp\connection.py", line 354, in drain_events
return self.blocking_read(timeout)
File "C:\Python33\lib\site-packages\amqp-2.0.0a1-py3.3.egg\amqp\connection.py", line 359, in blocking_read
return self.on_inbound_frame(read_frame())
File "C:\Python33\lib\site-packages\amqp-2.0.0a1-py3.3.egg\amqp\method_framing.py", line 65, in frame_handler
callback(channel, method_sig, buf, None)
File "C:\Python33\lib\site-packages\amqp-2.0.0a1-py3.3.egg\amqp\connection.py", line 385, in on_inbound_method
method_sig, payload, content,
File "C:\Python33\lib\site-packages\amqp-2.0.0a1-py3.3.egg\amqp\abstract_channel.py", line 124, in dispatch_method
args, _ = loads(amqp_method.args, payload, 4)
File "C:\Python33\lib\site-packages\amqp-2.0.0a1-py3.3.egg\amqp\serialization.py", line 229, in loads
val[key], offset = _read_item(buf, offset)
File "C:\Python33\lib\site-packages\amqp-2.0.0a1-py3.3.egg\amqp\serialization.py", line 154, in _read_item
ftype, type(ftype)))
amqp.exceptions.FrameSyntaxError: Unknown value in table: 70 (<class 'int'>)
не могу понять почему в трейсбеке значится брокер kombu - хотя я все упоминания о нем удалил из settings.py в django - помогите плиз …
при всем при этом в конфигурации с kombu - всё работает нормально, а как только пытаюсь запустить celery с rabbitmq - выдает не понятные ошибки…
