Celery-------項目目錄

在實際應用中Celery的目錄是有規則的

要滿足這樣的條件才可以

目錄Celery_task這個名字可以隨意,但是這個目錄下一定要有一個celery.py這個文件

from celery import Celery my_task = Celery('task',broker='redis://127.0.0.1:6379',backend='redis://127.0.0.1:6379',include=["Celery_task.task_1","Celery_task.task_2"]) celery from Celery_task.celery import my_task@my_task.task def func1():return 123@my_task.task def func3():return 789 task_1 from Celery_task.celery import my_task@my_task.task def func2():return 456 task_2 from Celery_task.task_1 import func1 from Celery_task.task_2 import func2func1.delay() func2.delay() my_celery

PS:啟動Worker的時候無需再使用文件啟動,直接啟動你的Celery_task目錄就行了
celery worker -A Celery_task -l INFO -P eventlet

?

posted on 2019-02-18 16:31 徐建0304 閱讀(...) 評論(...) 編輯 收藏

轉載于:https://www.cnblogs.com/Treasuremy/p/10396336.html

總結

以上是生活随笔為你收集整理的Celery-------项目目录的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。