### 1.相關鏈接 celery:[http://docs.celeryproject.org/en/latest/getting-started/first-steps-with-celery.html](http://docs.celeryproject.org/en/latest/getting-started/first-steps-with-celery.html) ### 2.關系  ### 3.安裝&準備 * redis * 安裝celery ``` pip install celery ``` * 在Windows操作系統上，還需要安裝另外一個東西,eventlet ``` pip install eventlet ``` redis:[http://docs.celeryproject.org/en/latest/getting-started/brokers/redis.html\#broker-redis](http://docs.celeryproject.org/en/latest/getting-started/brokers/redis.html#broker-redis) 安裝 ``` pip install -U "celery[redis]" ``` 配置 ``` app.conf.broker_url = 'redis://localhost:6379/0' ------------------------------------------------- redis://:password@hostname:port/db_number ``` ### 4.tasks任務 ``` #celery # pip install celery # 在Windows操作系統上，還需要安裝另外一個東西,eventlet # pip install eventlet # task，任務 # broker(中間人)，存儲任務的隊列(借助redis實現) # worker:真正執行任務的工作者 # backend:用來存儲任務執行后的結果 from celery import Celery import time # 中間人:redis # 存儲結果的位置:backend # Celery("當前模塊的名字",broker="redis://host:port/0",backend="redis://host:port/0",) celery = Celery("tasks",broker="redis://118.24.128.18:6379/0",backend="redis://118.24.128.18:6379/0") @celery.task def send_mail(): print("郵件開始發送") time.sleep(5000) print("郵件發送結束") ``` ### 5.主程序 ``` from tasks import send_mail if __name__ == "__main__": send_mail.delay() # -A:application # celery -A tasks.celery worker -l info -P eventlet ``` 在命令行中運行 ``` celery -A tasks.app worker -loglevel=info ``` 出現以下錯誤 ``` ValueError: not enough values to unpack (expected 3, got 0) ``` 解決 ``` pip install eventlet ``` ``` celery -A <mymodule> worker -l info -P eventlet 或者 celery -A <mymodule>--pool=eventlet worker --loglevel=info ``` ``` celery -A tasks.celery worker -l info -P eventlet ------------------------------------------------- celery -A tasks.celery --pool=eventlet worker --loglevel=info ```