默認是進程池方式,進程數以當前機器的CPU核數為參考,每個CPU開四個進程。
如何自己指定進程數: celery worker -A proj --concurrency=4
如何改變進程池方式為協程方式: celery worker -A proj --concurrency=1000 -P eventlet -c 1000
# 安裝eventlet模塊 $ pip install eventlet # 啟用 Eventlet 池 $ celery -A celery_tasks.main worker -l info -P eventlet -c 1000