Vlákno názorů k článku Celery: systém implementující asynchronní fronty úloh pro Python od kallsyms - Dík za článek, zrovna s celery zaobírám. Narazil...

Dík za článek, zrovna s celery zaobírám. Narazil jsem ale na jeden bug, když se použije jako backend rabbitmq a to, že po asi minutě worker přestane odpovídat.

Podle FAQ je to známý bug, prý "někteří AMQP klienti mají problém", ale už není zmíněno, kteří ten problém nemají: http://docs.celeryproject.org/en/latest/faq.html#why-is-task-delay-apply-the-worker-just-hanging

Zkoušel jsem měnit verze amqp, vidím že si to dotáhlo i závislost na kombu, ale nevím, která část ten problém způsobuje. Různé verze akorát generují jiné errory v rabbitmq logu (typicky "client unexpectedly closed TCP connection" nebo ztráta heartbeatu).

Neví někdo, za co teda kombu+amqp vyměnit a jak to nakonfigurovat na celery?

Zkuste možná nějakou kombinaci těchto přepínačů


celery worker -P solo --concurrency=1 --prefetch-multiplier=128 -Ofair --without-gossip --without-mingle --without-heartbeat


pro začátek by to mělo pomoci alespoň s odladěním

Dík, ale nepomohlo. Vypadá to, že budu muset použít jiný backend.