【原创】 在django中使用celery 任务队列,redis做后端
2012-10-18 12:00
711 查看
1.安装好celery
2.在你的django项目下新建一包queue(包名可以随便启),下面是我的结构
3.context_init.py 这是初始化django 项目环境变量的,在celery启动时会调用,下面是代码:
4.task.py 使用celery的主要代码都在这:
5. 启动celery , celery.sh 脚本:
PROJECT_DIR="/var/project/test/queue"
kill -KILL `ps aux|grep celery|awk '{print $2}'`
cd $PROJECT_DIR
/usr/local/python27/bin/celery -A tasks worker -l info >> /var/project/test/task.log 2>&1 &
echo "celery start..."
6.调用方法:
test.delay()
...
test2.delay(1,2)
完。
2.在你的django项目下新建一包queue(包名可以随便启),下面是我的结构
3.context_init.py 这是初始化django 项目环境变量的,在celery启动时会调用,下面是代码:
from __future__ import absolute_import from django.core.management import setup_environ import sys,os sys.path.insert(0, os.path.dirname(os.path.dirname(os.path.abspath(__file__)))) try: import settings # Assumed to be in the same directory. except ImportError: sys.stderr.write("Error: Can't find the file 'settings.py' in the directory containing %r. It appears you've customized things.\nYou'll have to run django-admin.py, passing it your settings module.\n(If the file settings.py does indeed exist, it's causing an ImportError somehow.)\n" % __file__) sys.exit(1) project_directory = setup_environ(settings) project_name = os.path.basename(project_directory) os.environ['DJANGO_SETTINGS_MODULE'] = "%s.settings" % project_name
4.task.py 使用celery的主要代码都在这:
#coding:utf-8 from __future__ import absolute_import from celery import Celery try: import context_init except ImportError: from queue import context_init import settings from test import * BROKER = 'redis://127.0.0.1:6379/1' celery = Celery('tasks', broker=BROKER) @celery.task def test(): result = 1 + 1 return result @celery.task def test2(a, b): result = a + b return result
5. 启动celery , celery.sh 脚本:
PROJECT_DIR="/var/project/test/queue"
kill -KILL `ps aux|grep celery|awk '{print $2}'`
cd $PROJECT_DIR
/usr/local/python27/bin/celery -A tasks worker -l info >> /var/project/test/task.log 2>&1 &
echo "celery start..."
6.调用方法:
test.delay()
...
test2.delay(1,2)
完。
相关文章推荐
- django使用celery定时任务,使用redis和supervisor。
- 异步任务队列Celery在Django中的使用方法
- 异步任务队列Celery在Django中的使用
- 异步任务队列Celery在Django中的使用
- Django使用Celery异步任务队列
- Django使用Celery异步任务队列的使用
- 异步任务队列Celery在Django中的使用
- Django使用Celery异步任务队列
- 异步任务队列Celery在Django中的使用
- Django 使用 Celery 实现异步任务
- 异步任务利器Celery(二)在django项目中使用Celery
- Django中使用django-celery完成异步任务(1)
- WINDOWS == Django Celery Redis 异步执行任务demo实例
- Django中如何使用django-celery完成异步任务1(转)
- django+celery+redis实现运行定时任务
- Celery异步任务队列/周期任务+ RabbitMQ + Django
- Django中使用Celery,定制应用程序中定义的shared_task未在定期任务管理页面的注册任务中显示
- Python环境下安装使用异步任务队列包Celery的基础教程
- 异步任务利器Celery(二)在django项目中使用Celery
- Django中使用Celery实现定时任务(用djcelery)