django-celery

在settings.py里installed_apps里添加　djcelery

需安装django-celery

在settings末端添加

import djcelery
djcelery.setup_loader()BROKER_URL = 'amqp://guest:guest@localhost:5672//'

CELERY_RESULT_BACKEND = 'amqp://guest:guest@localhost:5672//'

CELERY_TASK_SERIALIZER = 'json'CELERY_RESULT_SERIALIZER = 'json'CELERY_ACCEPT_CONTENT = ['json']

CELERY_IMPORTS = ('hello.tasks', )
CELERY_TIMEZONE = TIME_ZONE
CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'
CELERY_ALWAYS_EAGER = True

新建一个app

里面新建一个tasks.py

from celery import task@task
def add(x, y):return x+y@task
def prints():print 'xiao'

需安装

sudo apt-get install rabbitmq-server

启动rabbitmq-server

关闭rabbitmq-server -detached

查看状态rabbitmqctl status

运行celery

python manage.py celery worker --loglevel=info

或者后台运行celery

$ nohup django-admin.py celeryd worker -B --loglevel=info --settings=settings --pythonpath=. &

celery运行定时任务

python manage.py celery beat

查看celery是否正常运行

$ ps aux | grep celery

关闭celery

ps auxww | grep 'celery worker' | awk '{print $2}' | xargs kill -9

进入Django的admin后台，进入Djcelery栏目，一共有四个选项：

Crontabs

在此选项中，可以创建定时执行的任务需要的定时时间。

Intervals

在此选项中，可以创建间隔执行的任务需要时间间隔。

Periodic tasks

在此选项中，创建一个相应的任务，选择任务，需要定时执行的时间或者时间间隔，并保存。

当然，还有其他一些高级的选项，可以尝试使用。

Tasks
Workers

到此，一个任务便创建成功了。不出意外，创建的任务会如期执行，当然，如果创建的没有如期执行的，应该依次检查前面的步骤，查看celery是否在运行，创建的task是否报错等等，一级一级排除错误。

转载于:https://www.cnblogs.com/tuifeideyouran/p/4191511.html

django-celery相关推荐

django - celery
django - celery 的集成开发 celery 特点 celery 简单.灵活.可靠的分布式系统处理异步任务队列支持任务调度 celery 的组成消息中间件任务执行单元 worker ...
django celery 异步发送邮箱
django + celery + redis 异步发送QQ邮箱 django一般的代码逻辑都需要一步一步执行,这样大大的占用了I/O资源,用户也得不到完美的体验,django-celery可以灵活的 ...
Django + Celery 实现周期任务
1:Celery简介 1.1 异步任务,假设用户发起一个request,并等待request返回.但是在request 经过django一层层处理到达我们的view时,view要进行一次比较耗时的操作 ...
Django Celery定时任务和时间设置
1.Celery加入定时任务 Celery除了可以异步执行任务之外,还可以定时执行任务.在实例代码的基础上写个测试方法: 1 #coding:utf-8 2 from celery.task.sche ...
django celery
基本步骤安装 install redis yum install -y http://rpms.famillecollet.com/enterprise/remi-release-7.rpm yum ...
django+celery+rabitmq
django 项目中的设置(proj代表项目目录) proj settings.py CELERY_BROKER_URL = 'amqp://guest:guest@localhost:5672/' ...
python apply_async执行不了_python – Django Celery apply_async不起作用
我们正在使用django 1.10,Celery 4.1.0 我正在尝试使用apply_async. 这是任务: from celery import Celery app = Celery('my_ ...
Django - Celery使用及介绍
1.Celery介绍 1.1 celery应⽤举例 Celery 是⼀个基于python开发的分布式异步消息任务队列 ,通过它可以轻松的实现任务的异步处理,如果你的业务场景中需要⽤到异步任务,就 ...
【Web系列二十】Django+Celery+Asgiref+Channels+协程锁实现Websocket异步并发
写在前面最近手头有一个项目需要交付,作为web项目,并发问题是不可避免的.对于Django后端,常用的并发实现方案就是Celery,虽然网上已经有不少实施例,但是实际开发过程中遇到一些问题.比如长连 ...
Bamboo Django Celery定时任务和时间设置
1.Celery加入定时任务 Celery除了可以异步执行任务之外,还可以定时执行任务.在实例代码的基础上写个测试方法: 1 #coding:utf-82 from celery.task.sched ...

django-celery

django-celery相关推荐

最新文章

热门文章