最近專案中用到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/

檢視監控,注意這裡的監控資料是不持久化的。

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支援我們。