Celery目錄結構配置

celery

celery目錄結構

myproject/proj
      ├── __init__.py
      ├── celery.py # 這個必須是celery.py這個名字
      └── tasks.py  # 這個不一定是tasks.py, 但是要和include的一致
      test.py

celery.py

from __future__ import absolute_import # 使用絕對導入
from celery import Celery

app = Celery("proj",
             broker="amqp://guest@localhost//",
             backend="amqp",
             include=["proj.tasks"]
    )

app.conf.update(
    CELERY_ROUTES={
        "proj.tasks.add":{"queue":"hipri"},# 把add任務放入hipri隊列
        # 需要執行時指定隊列 add.apply_async((2, 2), queue='hipri')
        }

    )

if __name__ == "__main__":
    app.start()

絕對引用

順便說一下 from __future__ import absolute_import  
-->這樣以后: 局部的包將不能覆蓋全局的包, 本地的包必須使用相對引用了

如上: 

from celery import Celery 表示引用的全局的

from proj.celery import app 表示引用局部的

啟動是在myproject目錄下執行,而不是proj下

celery -A proj worker -Q hipri # 這個worker只處理hipri這個隊列的任務

啟動終端,切換到Django項目的根目錄下，運行：

# 啟動worker
celery worker -A 項目名 -l info

# 啟動beat
celery beat -A 項目名 -l info