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 中调度一个函数但给出错误

django-celery-beat 垃圾邮件到期任务

我在使用 Celery、Redis 和 Django 时遇到问题

django+celery+rabbitmq 编码错误和 sig-kill