Jak debugować zadania Celery/Django działające lokalnie w środowisku Eclipse

Question

Potrzebuję debugować zadanie Celery z debugera Eclipse. Używam Eclipse, PyDev i Django.

pierwsze, otwieram mój projekt w Eclipse i umieścić punkt przerwania na początku funkcji zadań.

Następnie uruchamiam pracowników firmy Selector od Eclipse, klikając prawym przyciskiem myszy na manage.py z Eksploratora pakietów PyDev i wybierając "Debuguj jako -> Python Run" i podając jako argument "celeryd -l info". To uruchamia MainThread, Mediator i trzy kolejne wątki widoczne z debugera Eclipse.

Potem wrócić do widoku PyDev i rozpocząć stosowanie przez główny prawym przyciskiem myszy na projekcie i wybierając Run As/PyDev: Django

Moi zagadnienia jest to, że gdy zadanie jest składany przez mytask.delay() nie zatrzymuje się na punkcie przerwania. Umieściłem kilka śladów za pomocą kodu zadań, więc widzę, że zostało wykonane w jednym z wątków roboczych.

Co zrobić, aby debugger Eclipse zatrzymał się na punkcie przerwania umieszczonym przy wykonywaniu zadania w wątku pracowników selera?

Answer 1

Powinieneś rozważyć opcję uruchomienia zadania selera w tym samym wątku co proces główny (zwykle działa on w oddzielnym procesie), co znacznie ułatwia debugowanie.

Można powiedzieć, seler, aby uruchomić zadanie synchronizacji poprzez dodanie tego ustawienia do modułu settings.py:

CELERY_ALWAYS_EAGER = True 

Uwaga: To jest przeznaczona tylko do być używany do debugowania lub rozwojowych etapach!

Answer 2

Jeśli działa tylko w innym wątku, powinien działać na najnowszych wersjach PyDev (wydaje mi się, że był problem przed miejscem, w którym zrodzony wątek nie byłby debugowany, ale zostało to naprawione).

Teraz, jeśli uruchamia się na innym procesie, należy użyć zdalnego debuggera (nawet jeśli jest na tym samym komputerze). Zobacz: http://pydev.org/manual_adv_remote_debugger.html

Answer 3

CELERYD_POOL domyślnie celery.concurrency.prefork:TaskPool, który odradza oddzielne procesy dla każdego pracownika, a PyDev nie widzi w nich. Jeśli zmienisz go na jedną z opcji gwintowanych, możesz użyć debuggera.

Na przykład dla Seler 3.1 można użyć tego ustawienia:

CELERYD_POOL = 'celery.concurrency.threads:TaskPool' 

pamiętać, że wymaga to moduł threadpool zostać zainstalowany.

Upewnij się także, aby mieć CELERY_ALWAYS_EAGER = False, inaczej zmieniając klasa basen nie ma sensu.

Answer 4

utworzyć polecenie zarządzania do zadania testowego .. łatwiej niż uruchomienie go z muszli ..

Answer 5

Można to zrobić przy użyciu Seler na rdb:

from celery.contrib import rdb 
rdb.set_trace() 

Następnie w innego typu terminala telnet localhost 6900, a otrzymasz komunikat debugowania.