Пытаюсь настроить связку 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'>)
Что может быть не так ?
CELERYBEAT_SCHEDULER="djcelery.schedulers.DatabaseScheduler" BROKER_HOST = "localhost" BROKER_PORT = 5672 BROKER_USER = "pbx" BROKER_PASSWORD = "password" BROKER_VHOST = "myvhost" и почему-то ругается на формат конфига : C:\Program Files\Apache Software Foundation\Apache2.4\htdocs\mysite>celery -A mysite worker --loglevel=info --concurrency 4 C:\Python33\lib\site-packages\celery-3.1.14-py3.3.egg\celery\app\defaults.py:246: CPendingDeprecationWarning: The 'BROKER_PASSWORD' setting is scheduled for deprecation in version 2.5 and removal in version v4.0. Use the BROKER_URL setting instead alternative='Use the {0.alt} instead'.format(opt)) C:\Python33\lib\site-packages\celery-3.1.14-py3.3.egg\celery\app\defaults.py:246: CPendingDeprecationWarning: The 'BROKER_VHOST' setting is scheduled for deprecation in version 2.5 and removal in version v4.0. Use the BROKER_URL setting instead alternative='Use the {0.alt} instead'.format(opt)) C:\Python33\lib\site-packages\celery-3.1.14-py3.3.egg\celery\app\defaults.py:246: CPendingDeprecationWarning: The 'BROKER_PORT' setting is scheduled for deprecation in version 2.5 and removal in version v4.0. Use the BROKER_URL setting instead alternative='Use the {0.alt} instead'.format(opt)) C:\Python33\lib\site-packages\celery-3.1.14-py3.3.egg\celery\app\defaults.py:246: CPendingDeprecationWarning: The 'BROKER_HOST' setting is scheduled for deprecation in version 2.5 and removal in version v4.0. Use the BROKER_URL setting instead alternative='Use the {0.alt} instead'.format(opt)) C:\Python33\lib\site-packages\celery-3.1.14-py3.3.egg\celery\app\defaults.py:246: CPendingDeprecationWarning: The 'BROKER_USER' setting is scheduled for deprecation in version 2.5 and removal in version v4.0. Use the BROKER_URL setting instead alternative='Use the {0.alt} instead'.format(opt)) C:\Python33\lib\site-packages\win32\lib\pywintypes.py:39: DeprecationWarning: imp.get_suffixes() is deprecated; use the constants defined on importlib.machinery instead for suffix_item in imp.get_suffixes():
