Cách gỡ lỗi các nhiệm vụ Celery/Django chạy cục bộ trong Eclipse

Question

Tôi cần gỡ lỗi nhiệm vụ Celery khỏi trình gỡ lỗi Eclipse. Tôi đang sử dụng Eclipse, PyDev và Django.

Trước tiên, tôi mở dự án của mình trong Eclipse và đặt điểm ngắt ở đầu chức năng nhiệm vụ. Sau đó, tôi bắt đầu công nhân Celery từ Eclipse bằng cách nhấp chuột phải vào manage.py từ trình thám hiểm gói PyDev và chọn "Debug As-> Python Run" và chỉ định "celeryd -l info" làm đối số. Điều này bắt đầu MainThread, Mediator và ba luồng khác có thể nhìn thấy được từ trình gỡ lỗi Eclipse.

Sau đó tôi trở về quan điểm PyDev và khởi động ứng dụng chính bằng cách Right Click vào dự án và chọn Run As/PyDev: Django

vấn đề của tôi là một lần nhiệm vụ được đệ trình bởi mytask.delay() nó không dừng lại trên điểm ngắt. Tôi đặt một số dấu vết với mã nhiệm vụ để tôi có thể thấy rằng nó đã được thực hiện trong một trong các chủ đề công nhân.

Vì vậy, làm thế nào để làm cho trình gỡ rối Eclipse dừng lại trên điểm ngắt được đặt cùng với tác vụ khi nó được thực hiện trong chuỗi công nhân Celery?

Answer 1

Bạn nên xem xét tùy chọn chạy tác vụ cần tây trong cùng một luồng với quy trình chính (thông thường nó chạy trên một quy trình riêng), điều này sẽ làm cho gỡ lỗi dễ dàng hơn nhiều.

Bạn có thể nói với cần tây để chạy các nhiệm vụ đồng bộ bằng cách thêm cài đặt này để mô-đun settings.py của bạn:

CELERY_ALWAYS_EAGER = True 

Lưu ý: đây chỉ có nghĩa là để được sử dụng để gỡ lỗi hoặc phát triển giai đoạn!

Answer 2

Nếu nó chỉ chạy trên một chuỗi khác, nó sẽ hoạt động trên các phiên bản PyDev mới nhất (tôi nghĩ có một vấn đề trước khi một luồng sinh ra không được sửa lỗi, nhưng điều này đã được sửa).

Bây giờ, nếu nó khởi chạy trên một quy trình khác, bạn cần phải sử dụng trình gỡ rối từ xa (ngay cả khi nó nằm trên cùng một máy). Xem: http://pydev.org/manual_adv_remote_debugger.html

Answer 3

CELERYD_POOL mặc định là celery.concurrency.prefork:TaskPool sẽ sinh ra các quy trình riêng biệt cho mỗi công nhân và PyDev không thể nhìn thấy bên trong chúng. Nếu bạn thay đổi nó thành một trong các tùy chọn luồng thì bạn có thể sử dụng trình gỡ rối.

Ví dụ, đối Cần tây 3.1 bạn có thể sử dụng cài đặt này:

CELERYD_POOL = 'celery.concurrency.threads:TaskPool' 

Lưu ý rằng điều này đòi hỏi các module threadpool được cài đặt.

Đồng thời đảm bảo có CELERY_ALWAYS_EAGER = False, nếu không, việc thay đổi lớp của hồ bơi sẽ không có ý nghĩa.

Answer 4

tôi tạo ra một lệnh quản lý với nhiệm vụ kiểm tra .. thấy nó dễ dàng hơn so với chạy nó từ vỏ ..

Answer 5

Bạn có thể làm điều đó bằng cần tây của rdb:

from celery.contrib import rdb 
rdb.set_trace() 

Sau đó, trong một loại thiết bị đầu cuối khác nhau telnet localhost 6900 và bạn sẽ nhận được lời nhắc gỡ lỗi.