Chinaunix首页 | 论坛 | 博客
  • 博客访问: 4857520
  • 博文数量: 1602
  • 博客积分: 18684
  • 博客等级: 上将
  • 技术积分: 14880
  • 用 户 组: 普通用户
  • 注册时间: 2010-06-02 10:28
  • 认证徽章:
文章分类

全部博文(1602)

文章存档

2019年(23)

2018年(44)

2017年(50)

2016年(47)

2015年(15)

2014年(21)

2013年(43)

2012年(144)

2011年(236)

2010年(267)

2009年(391)

2008年(250)

2007年(30)

2006年(38)

2005年(2)

2004年(1)

分类: 系统运维

2019-06-10 15:05:31

celery==3.1.26
Django==1.11.21
django-celery==3.3.0
flower==0.9.3
kombu==3.0.37
redis==2.10.6

创建项目
django-admin.py startproject celery_test
创建app
python manange.py startapp kecelety


在app中创建tasks.py
celery_test]# cat kecelety/tasks.py
#!/usr/bin/env python
#coding:utf-8

import django
django.setup()
from celery import task, platforms
import time

# 允许root 用户运行celery
platforms.C_FORCE_ROOT = True

@task
def say_hello():
    #主要是为了测试异步功能,让他休眠5秒再打印,这样就避免打印和views.py中的返回同时执行,
    #其实是异步执行,为了肉眼效果就加上休眠
    time.sleep(5)  
    print "say_hello()..."
    return 0

@task
def add(x,y):
    print(x,y)
    return x+y

@task
def test(arg1, *arg2, **arg3):
    print(arg1, arg2, arg3)
    return 0

添加异步队列
celery_test]# cat kecelety/views.py
# -*- coding: utf-8 -*-
from __future__ import unicode_literals
from django.shortcuts import render
# Create your views here.
from django.http import HttpResponse
from .tasks import say_hello
import json

def hello(request):
    #添加到消息队列中
    r = say_hello.delay()
    #执行成功返回True
    print r.ready()
    print r.successful()
    return HttpResponse(json.dumps({'data':'ddd'}))

urls.py
from kecelety.views import *

urlpatterns = [
    ...
    url(r'^c/hello/', hello),
]


setting.py配置
INSTALLED_APPS = [
    ...
    'djcelery',
    'kecelety',
    'kombu.transport.django', #配合下面的BROKER_URL使用
]
最后添加
import djcelery
djcelery.setup_loader()
CELERY_TIMEZONE = 'Asia/Shanghai'
#息队列界面UI中可以看到
BROKER_URL = 'redis://127.0.0.1:6379/0' #设置redis为celery代理
#设置django为celery代理,此时任务消息存储在数据库中,在admin中注册即可在后台看到
#admin.py:
#from kombu.transport.django import models as kombu_models
#admin.site.register(kombu_models)
#BROKER_URL = 'django://' 
CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler' #定时任务用到
CELERYD_MAX_TASKS_PER_CHILD = 3 #  每个worker最多执行3个任务就会被销毁,可防止内存泄露


开启服务
python manage.py celery worker -c 4 --loglevel=info
python manage.py runserver 0.0.0.0:9004
python manage.py celery flower
python manage.py celery beat

可以在admin上添加定时任务,也可以从网


已知错误
https://www.jianshu.com/p/b95bf142dc1b
django celery运行报错 TypeError: can only concatenate list (not "tuple") to list
\lib\site-packages\djcelery\management\commands\celery.py
14     #    options = (CeleryCommand.options +
15     #           base.get_options() +
16     #           base.preload_options)

https://www.cnblogs.com/cpl9412290130/p/10597291.html
celery:Unrecoverable error: AttributeError("'unicode' object has no attribute 'iteritems')
pip uninstall redis
pip install redis==2.10.6
阅读(7228) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~
评论热议
请登录后评论。

登录 注册