Celery（芹菜）安装配置过程

环境：win10 64；python 3.6.0；Django 2.0.3redis-3.2

开发工具：pycharm

安装包：celery，django-celery，celery-with-redis（使用redis作为消息代理（broker））
项目配置：

首先在"项目\settings.py"下加入celery配置：

# Celery settings
import djcelery
djcelery.setup_loader()
BROKER_URL = 'redis://127.0.0.1:6379/0'
CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/0'
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler'
CELERY_TIMEZONE = 'Asia/Shanghai'
BROKER_TRANSPORT_OPTIONS = {'visibility_timeout': 3600}  # 1 hour.

其次在INSTALL_APPS里面加入celery配置

INSTALLED_APPS = [...'djcelery',
]

新建celery.py，将Django与Celery关联

from __future__ import absolute_importimport os
from celery import Celery
from django.conf import settingsos.environ.setdefault('DJANGO_SETTINGS_MODULE', 'ProjectName.settings')app = Celery('APPName')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))

3. 配置应用：

在应用中新建tasks.py，代码如下：

from celery import task
from time import sleep, time


@task()
def Task_A(message):Task_A.update_state(state='PROGRESS', meta={'progress': 0})sleep(10)Task_A.update_state(state='PROGRESS', meta={'progress': 30})sleep(10)return messagedef get_task_status(task_id):task = Task_A.AsyncResult(task_id)status = task.stateprogress = 0if status == u'SUCCESS':progress = 100elif status == u'FAILURE':progress = 0elif status == 'PROGRESS':progress = task.info['progress']return {'status': status, 'progress': progress}@task
def sendmail(mail):print("++++++++++++++++++++++++++++++++++++")print('sending mail to %s...' % mail['to'])time.sleep(2.0)print('mail sent.')print("------------------------------------")return mail['to']

测试应用：

Django环境下运行celery

python manage.py celeryd -l info

 -------------- celery@mycomputer v3.1.26.post2 (Cipater)
---- **** -----
--- * ***  * -- Windows-10-10.0.15063-SP0
-- * - **** ---
- ** ---------- [config]
- ** ---------- .> app:         default:0x17b6c901240 (djcelery.loaders.DjangoLoader)
- ** ---------- .> transport:   redis://127.0.0.1:6379/0
- ** ---------- .> results:     redis://127.0.0.1:6379/0
- *** --- * --- .> concurrency: 4 (prefork)
-- ******* ----
--- ***** ----- [queues]-------------- .> celery           exchange=celery(direct) key=celery
[tasks]. DocCheck.tasks.Task_A. DocCheck.tasks.sendmail[2018-04-04 15:27:35,018: INFO/MainProcess] Connected to redis://127.0.0.1:6379/0
[2018-04-04 15:27:35,041: INFO/MainProcess] mingle: searching for neighbors
[2018-04-04 15:27:36,067: WARNING/MainProcess] C:\Python36\lib\site-packages\celery\app\contr
ol.py:36: DuplicateNodenameWarning: Received multiple replies from node name: celery@mycomputer
Please make sure you give each node a unique nodename using the `-n` option.pluralize(len(dupes), 'name'), ', '.join(sorted(dupes)),
[2018-04-04 15:27:36,070: INFO/MainProcess] mingle: all alone
[2018-04-04 15:27:36,128: WARNING/MainProcess] C:\Python36\lib\site-packages\djcelery\loaders
.py:133: UserWarning: Using settings.DEBUG leads to a memory leak, never use this setting in
production environments!warn('Using settings.DEBUG leads to a memory leak, never '
[2018-04-04 15:27:36,156: WARNING/MainProcess] celery@mycomputer ready.
[2018-04-04 15:27:36,233: INFO/Worker-1] child process 15852 calling self.run()
[2018-04-04 15:27:36,252: INFO/Worker-1] child process 20336 calling self.run()
[2018-04-04 15:27:36,283: INFO/Worker-1] child process 6920 calling self.run()
[2018-04-04 15:27:36,296: INFO/Worker-1] child process 19668 calling self.run()

成功启动后，在Django manage环境中测试任务执行情况

启动shell：python manage.py shell

>>> from APPName.tasks import *
>>> sendmail.delay(dict(to='aaa@163.com'))

<AsyncResult: 20a8c817-a6fe-434e-8bc4-5efdb5356046>

测试任务执行情况

>>> Task_A.delay("test")
<AsyncResult: c1c7c985-c0c4-48d6-9e21-b71ce87c3eb5>
>>> t = Task_A.delay("test1")
>>> t.ready()
False
>>> t.ready()
True

Broker显示结果如下：

[2018-04-04 15:30:59,903: INFO/MainProcess] Received task: DocCheck.tasks.Task_A[d7315376-5
cc4-4732-b1ea-ccfa513a0f54]
[2018-04-04 15:31:19,914: INFO/MainProcess] Task DocCheck.tasks.Task_A[d7315376-5cc4-4732-b
1ea-ccfa513a0f54] succeeded in 20.0s: test1
[2018-04-04 15:58:29,449: INFO/MainProcess] Received task: DocCheck.tasks.Task_A[39e903d1
-d9c1-4bab-96e4-1b7466538001]
[2018-04-04 15:58:49,673: INFO/MainProcess] Task DocCheck.tasks.Task_A[39e903d1-d9c1-4bab
-96e4-1b7466538001] succeeded in 20.156000000424683s: testget

Celery在Django下安装配置相关推荐

django配置环境linux,linux环境下Django的安装配置详解
linux环境下Django的安装配置详解 1. 下载安装Django pip install Django==1.6.5 测试是否安装成功 >>> import django> ...
怎么检查python是否安装成功-检查python以及django是否安装配置成功
首先说明下,我使用pycharm作为开发的IDE,在第一次创建django项目的时候,会自动安装django包的.(网上也有很多单独安装的方法),环境变量配置成功后,就是用下面的方法检测安装成功与否. ...
在windows下安装配置Ulipad
在windows下安装配置Ulipad 今天推荐一款轻便的文本编辑器Ulipad,用来写一些小的Python脚本非常方便. Ulipad下载地址: https://github.com/limodou ...
Ubuntu下安装配置Open×××
Ubuntu下安装配置Open××× 时间:2009-02-11 21:03来源:http://www.kklinux.com 作者:看看Linux 点击:2664次 1. 安装 Ubuntu中安装O ...
PHP环境搭建:Windows 7下安装配置PHP+Apache+Mysql环境教程（转）
转至:http://www.leapsoul.cn/?p=695 这两天刚装好Windows 7,碰巧前段时间有朋友问我Windows下如何安装搭建PHP环境,所以打算勤劳下,手动一步步搭建PHP环境 ...
Linux服务器下安装配置Nginx的教程
这篇文章主要介绍了Linux服务器下安装配置Nginx服务器的教程,本文给大家介绍的非常详细,具有一定的参考借鉴价值,需要的朋友可以参考下 Nginx("engine x")是一款 ...
Linux 下安装配置C/C++开发环境 Code::Blocks
Linux 下安装配置C开发环境Code::Blocks 一.提前的话要说C语言和Linux的关系大家应该都不会陌生,Linux系统内核就是用C语言开发的,所以所有的Linux系统下面都会有C的编 ...
centos6.4下安装配置JDK+TOMCAT+MYSQL笔记
在公司测试环境,需要在CENTOS6.4下安装配置JDK+TOMCAT+MYSQL,下面是一个安装笔记留存备用. 一.系统环境和软件包 [root@localhost /]# uname -r 2.6 ...
linux下安装配置redis服务
2019独角兽企业重金招聘Python工程师标准>>> linux下安装配置redis服务 2016年03月25日 15:39:31 coding_everyday 阅读数:3530 ...

Celery在Django下安装配置

Celery（芹菜）安装配置过程

Celery在Django下安装配置相关推荐

最新文章

热门文章