您好,登錄后才能下訂單哦!
Django中的異步任務(wù)怎么利用celery實(shí)現(xiàn)?相信很多沒有經(jīng)驗(yàn)的人對此束手無策,為此本文總結(jié)了問題出現(xiàn)的原因和解決方法,通過這篇文章希望你能解決這個(gè)問題。
準(zhǔn)備
pip安裝celery、flower、eventlet
快速接入
1.項(xiàng)目目錄的__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') #修改項(xiàng)目配置文件的地址 app = Celery('voice_quality_assurance_configure') #修改項(xiàng)目目錄名稱 # 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文件,更多配置項(xiàng),可以查看官方文檔。
from kombu import Queue BROKER_URL = 'amqp://用戶名:密碼@ip:5672'# 指定 Broker CELERY_RESULT_BACKEND = 'rpc://用戶名:密碼@ip:5672'# 指定 Backend CELERY_TIMEZONE='Asia/Shanghai'# 指定時(shí)區(qū),默認(rèn)是 UTC CELERY_TASK_SERIALIZER = 'pickle' CELERY_RESULT_SERIALIZER = 'pickle' CELERY_ACCEPT_CONTENT = ['pickle', 'json'] CELERY_IGNORE_RESULT = True # CELERY_TIMEZONE='UTC' CELERY_IMPORTS = ( # 指定導(dǎo)入的任務(wù)模塊 'apps.mission.tasks' ) CELERY_QUEUES = ( Queue('default', routing_key='default'), #聲明隊(duì)列和對應(yīng)路由鍵 Queue('worker_queue', routing_key='worker'), #聲明隊(duì)列和對應(yīng)路由鍵 ) 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調(diào)用如下:(我這里是mission app下的views.py)
from .tasks import createsingletask
createsingletask.apply_async(())
快速測試和監(jiān)控
啟動(dòng)多個(gè)celery worker,-A 指定項(xiàng)目目錄, -P 指定方式,我這里以協(xié)程方式運(yùn)行, -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
啟動(dòng)flower監(jiān)控
celery flower --broker=amqp://用戶名:密碼@ip:5672 --broker-api=http://用戶名:密碼@ip:15672/api/
查看監(jiān)控,注意這里的監(jiān)控?cái)?shù)據(jù)是不持久化的。
看完上述內(nèi)容,你們掌握Django中的異步任務(wù)怎么利用celery實(shí)現(xiàn)的方法了嗎?如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容,歡迎關(guān)注億速云行業(yè)資訊頻道,感謝各位的閱讀!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。