Форум сайта python.su
0
Здравствуйте !
Пытаюсь настроить связку 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():
Офлайн
49
MarkHammer
Use the BROKER_URL setting instead
BROKER_URL = 'amqp://pbx:password@localhost:5672//'
Офлайн
0
Спасибо - это помогло решить часть проблемы - к сожалению не основную - остается проблема с запуском celery - та-же ошибка , не могу понять почему в трейсбеке значится брокер kombu - хотя я все упоминания о нем удалил из settings.py в django - помогите плиз …
при всем при этом в конфигурации с kombu - всё работает нормально, а как только пытаюсь запустить celery с rabbitmq - выдает не понятные ошибки…
Офлайн
49
MarkHammer
не могу понять почему в трейсбеке значится брокер kombu
MarkHammer
при всем при этом в конфигурации с kombu - всё работает нормально
Офлайн
39
Alen
RQ во сто раз проще, не рассматривается случаем
Офлайн
49
4kpt_III
Ни в коем случае. Может не работать вообще!!!
4kpt_III
У меня клала задачи в очередь (проверял по redis) и вообще отказывалась их потом из очереди брать.
Офлайн
39
Alen
Сиё лечится простой чисткой базы redis'a. Имеет важность порядок запуска RQ и воркеров.
Тоже в первый день с ней не весело пришлось.

Отредактировано 4kpt_III (Янв. 9, 2015 20:21:49)
Офлайн
49
4kpt_III
Использую в celery в качестве брокера - редис. Никаких проблем пока не замечал.
4kpt_III
По поводу RQ. Не работает и все. Причем настолько все так жестко было, что даже пытался потом просто запустить пример из документации. Ничерта. А я на нем уже нафигачил достаточно много. Просто не мог поверить, что не будет работать. Пол дня коту под хвост!
4kpt_III
P.S. Мы же про это чудо говорим?
Офлайн
39
Alen
Он так кота назвал. Абзец. Такс-менеджер в честь кота. Я думал у меня все плохо, а тут, оказывается, есть еще хуже…
AlenВозможно ось. Какая у Вас?
Но у меня же работает
RQ workers will only run on systems that implement fork(). Most notably, this means it is not possible to run the workers on Windows.
Отредактировано 4kpt_III (Янв. 9, 2015 20:59:45)
Офлайн
49
4kpt_IIIСтандартная hvm Ubuntu LTS 12.04 - 14.04 железо AWS c3.8xlarge (переменное число серверов).
Возможно ось. Какая у Вас?
Офлайн