django celery使用
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了django celery使用相关的知识,希望对你有一定的参考价值。
版本:celery:3.1.25
django-celery:3.2.2
django:1.8.16
安装celery3
pip install celery==3.1.25 pip install django-celery
celery与django结合使用的配置:
参考文档:http://docs.celeryproject.org/en/3.1/django/first-steps-with-django.html
proj/proj/settings配置:
INSTALLED_APPS = ( 'django.contrib.admin', 'django.contrib.auth', 'django.contrib.contenttypes', 'django.contrib.sessions', 'django.contrib.messages', 'django.contrib.staticfiles', 'study', 'djcelery', )
import djcelery djcelery.setup_loader() BROKER_URL = 'redis://172.16.42.128:6379' CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler' CELERY_RESULT_BACKEND = 'djcelery.backends.database:DatabaseBackend' CELERY_ACCEPT_CONTENT = ['application/json'] CELERY_TASK_SERIALIZER = 'json' CELERY_RESULT_SERIALIZER = 'json' CELERY_TIMEZONE = 'Asia/Shanghai' CELERY_ENABLE_UTC = False CELERYD_CONCURRENCY = 10 CELERYD_MAX_TASKS_PER_CHILD = 5 CELERY_SEND_EVENTS = True
proj/proj/__init__.py
from __future__ import absolute_import # This will make sure the app is always imported when # Django starts so that shared_task will use this app. from .celery import app as celery_app # noqa
proj/proj/celery.py
注意:proj改成你自己项目的名称
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', 'proj.settings') from django.conf import settings # noqa app = Celery('proj') # 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) @app.task(bind=True) def debug_task(self): print('Request: {0!r}'.format(self.request))
demoapp/tasks.py
from __future__ import absolute_import from celery import shared_task @shared_task def add(x, y): return x + y @shared_task def mul(x, y): return x * y @shared_task def xsum(numbers): return sum(numbers)
命令行启动celery
启动celerycam
python manage.py celerycam
启动worker
python manage.py celery worker -l info
启动beat
python manage.py celery beat -l info
以上是关于django celery使用的主要内容,如果未能解决你的问题,请参考以下文章
celery beat 没有发送消息(使用 django-celery-beat)
Celery 在远程任务上使用 Django Result Backend
尝试使用 celery beat 在 django 中调度一个函数但给出错误