django-celery部署

Django的setting中添加

djcelery.setup_loader()
BROKER_URL = 'redis://127.0.0.1:6379/0'
BROKER_TRANSPORT = 'redis'
CELERY_IMPORTS = ('register.task')

當djcelery.setup_loader()運行時,
Celery便會去查看INSTALLD_APPS下包含的所有app目錄中的tasks.py文件,找到標記為task的方法,
將它們注冊為celery task。BROKER_URL和CELERY_RESULT_BACKEND分別指代你的
Broker的代理地址以及Backend(result store)數(shù)據(jù)存儲地址。在Django中如果
沒有設置backend,會使用其默認的后臺數(shù)據(jù)庫用來存儲數(shù)據(jù)。
注意,此處backend的設置是通過關鍵字CELERY_RESULT_BACKEND來配置,
與一般的.py文件中實現(xiàn)celery的backend設置方式有所不同。
一般的.py中是直接通過設置backend關鍵字來配置

setting同級celery文件創(chuàng)建

from __future__ import absolute_import
import os
from celery import Celery
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'test_celery.settings')

from django.conf import settings  # noqa

app = Celery('test_celery')

# Using a string here means the worker will not have to
# pickle the object when using Windows.
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

supervisord配置

[program:celeryd]
command=/home/irlans/venv3.5/bin/python manage.py celery worker -l info 
stdout_logfile=/home/irlans/celery.log
stderr_logfile=/home/irlans/celery_err.log
autostart=true
autorestart=true
startsecs=10
stopwaitsecs=600
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
【社區(qū)內容提示】社區(qū)部分內容疑似由AI輔助生成,瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明:文章內容(如有圖片或視頻亦包括在內)由作者上傳并發(fā)布,文章內容僅代表作者本人觀點,簡書系信息發(fā)布平臺,僅提供信息存儲服務。

相關閱讀更多精彩內容

友情鏈接更多精彩內容