Làm cách nào để tự động tải lại các mô-đun nhiệm vụ bằng Celery daemon?

Question

Tôi đang sử dụng Fabric để triển khai một nhà môi giới Celery (chạy RabbitMQ) và nhiều công nhân Celery với celeryd được daemonized qua supervisor. Tôi không thể cho cuộc sống của tôi tìm ra cách tải lại mô-đun tasks.py ngắn để khởi động lại máy chủ.

---

/etc/supervisor/conf.d/celeryd.conf

[program:celeryd] 
directory=/fab-mrv/celeryd 
environment=[RABBITMQ crendentials here] 
command=xvfb-run celeryd --loglevel=INFO --autoreload 
autostart=true 
autorestart=true 

---

celeryconfig.py

import os 

## Broker settings 
BROKER_URL = "amqp://%s:%s@hostname" % (os.environ["RMQU"], os.environ["RMQP"]) 

# List of modules to import when celery starts. 
CELERY_IMPORTS = ("tasks",) 

## Using the database to store task state and results. 
CELERY_RESULT_BACKEND = "amqp" 

CELERYD_POOL_RESTARTS = True 

---

thông tin bổ sung

• celery --version 3.0.19 (Chiastic slide)
• python --version 2.7.3
• lsb_release -a Ubuntu 12.04.2 LTS
• rabbitmqctl status ... 2.7.1 ...

---

Ở đây ar e một số điều tôi đã cố gắng:

• Các celeryd --autoreload cờ
• sudo supervisorctl restart celeryd
• celery.control.broadcast('pool_restart', arguments={'reload': True})
• ps auxww | grep celeryd | grep -v grep | awk '{print $2}' | xargs kill -HUP

Và thật không may, không có gì làm cho người lao động để tải lại các module tasks.py (ví dụ sau khi chạy git pull để cập nhật tệp). Ý chính của các hàm fab thích hợp có sẵn here.

Người môi giới/công nhân chạy tốt sau khi khởi động lại.

Answer 1

Chỉ cần chụp trong bóng tối, với tùy chọn celeryd --autoreload bạn có chắc chắn rằng mình có một trong số file system notification backends không? Nó khuyến cáo PyNotify cho Linux, vì vậy tôi bắt đầu bằng cách đảm bảo rằng bạn đã cài đặt.