最近项目中用到celery很多,Django快速接入celery,这里给份教程。
准备
pip安装celery、flower、eventlet
快速接入
1.项目目录的__init__文件
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 .celerypro import app as celery_app
2.celerypro.py文件
from __future__ import absolute_import import os from celery import Celery from django.conf import settings # set the default Django settings module for the 'celery' program. os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'voice_quality_assurance_configure.settings') #修改项目配置文件的地址 app = Celery('voice_quality_assurance_configure') #修改项目目录名称 # Using a string here means the worker will not have to # pickle the object when using Windows. app.config_from_object('voice_quality_assurance_configure.celeryconfig') #修改celery配置文件的地址 app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
3.celeryconfig.py文件,更多配置项,可以查看官方文档。
from kombu import Queue BROKER_URL = 'amqp://用户名:密码@ip:5672'# 指定 Broker CELERY_RESULT_BACKEND = 'rpc://用户名:密码@ip:5672'# 指定 Backend CELERY_TIMEZONE='Asia/Shanghai'# 指定时区,默认是 UTC CELERY_TASK_SERIALIZER = 'pickle' CELERY_RESULT_SERIALIZER = 'pickle' CELERY_ACCEPT_CONTENT = ['pickle', 'json'] CELERY_IGNORE_RESULT = True # CELERY_TIMEZONE='UTC' CELERY_IMPORTS = ( # 指定导入的任务模块 'apps.mission.tasks' ) CELERY_QUEUES = ( Queue('default', routing_key='default'), #声明队列和对应路由键 Queue('worker_queue', routing_key='worker'), #声明队列和对应路由键 ) CELERY_ROUTES = { 'apps.mission.tasks.createsingletask': {'queue': 'worker_queue', 'routing_key': 'worker'}, }
app代码如何使用
app下新建tasks.py文件,名字一定要是tasks。(我这里是mission app下的tasks.py)
from celery import shared_task @shared_task() def createsingletask(): print(test)
app下views调用如下:(我这里是mission app下的views.py)
from .tasks import createsingletask
createsingletask.apply_async(())
快速测试和监控
启动多个celery worker,-A 指定项目目录, -P 指定方式,我这里以协程方式运行, -n指定name
celery worker -A voice_quality_assurance_configure --loglevel=info -P eventlet -n worker1 celery worker -A voice_quality_assurance_configure --loglevel=info -P eventlet -n worker2 celery worker -A voice_quality_assurance_configure --loglevel=info -P eventlet -n worker3 celery worker -A voice_quality_assurance_configure --loglevel=info -P eventlet -n worker4 celery worker -A voice_quality_assurance_configure --loglevel=info -P eventlet -n worker5
启动flower监控
celery flower --broker=amqp://用户名:密码@ip:5672 --broker-api=http://用户名:密码@ip:15672/api/
查看监控,注意这里的监控数据是不持久化的。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?