我正在尝试运行 celery -A 项目工作人员 -l 信息。但每次它都会返回一个错误,例如init遇到意外错误。请帮助。提前致谢。
我的设置文件:
CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = 'Africa/Nairobi'
Run Code Online (Sandbox Code Playgroud)
芹菜文件:
from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
# setting the Django settings module.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'project.settings')
app = Celery('project')
app.config_from_object('django.conf:settings', namespace='CELERY')
# Looks up for task modules in Django applications and loads them
app.autodiscover_tasks()
@app.task(bind=True)
def debug_task():
print('Request')
Run Code Online (Sandbox Code Playgroud)
初始化文件
from __future__ import absolute_import
# This will make sure …
Run Code Online (Sandbox Code Playgroud)