pip install django-celery

# celery_config.py
import djcelery
import os

os.environ.setdefault('FORKED_BY_MULTIPROCESSING', '1')
djcelery.setup_loader()

BROKER_URL = 'redis://127.0.0.1:6379/1'
CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/2'

# UTC
CELERY_ENABLE_UTC = True
CELERY_TIMEZONE = 'Asia/Shanghai'

CELERY_IMPORTS = (
 'app.tasks',
)

# 有些情況可以防止死鎖
CELERY_FORCE_EXECV = True

# 設(shè)置并發(fā)的worker數(shù)量
CELERYD_CONCURRENCY = 4

# 任務(wù)發(fā)送完成是否需要確認(rèn)，這一項對性能有一點(diǎn)影響
CELERY_ACKS_LATE = True

# 每個worker執(zhí)行了多少任務(wù)就會銷毀，防止內(nèi)存泄露，默認(rèn)是無限的
CELERYD_MAX_TASKS_PER_CHILD = 40

# 規(guī)定完成任務(wù)的時間
CELERYD_TASK_TIME_LIMIT = 15 * 60 # 在15分鐘內(nèi)完成任務(wù)，否則執(zhí)行該任務(wù)的worker將被殺死，任務(wù)移交給父進(jìn)程

# 設(shè)置默認(rèn)的隊列名稱，如果一個消息不符合其他的隊列就會放在默認(rèn)隊列里面，如果什么都不設(shè)置的話，數(shù)據(jù)都會發(fā)送到默認(rèn)的隊列中
CELERY_DEFAULT_QUEUE = "default"

# 設(shè)置詳細(xì)的隊列
CELERY_QUEUES = {
 "default": { # 這是上面指定的默認(rèn)隊列
  "exchange": "default",
  "exchange_type": "direct",
  "routing_key": "default"
 },
 "beat_queue": {
  "exchange": "beat_queue",
  "exchange_type": "direct",
  "routing_key": "beat_queue"
 }

}

# app/tasks.py
from celery.task import Task
import time

class TestTask(Task):
 name = 'test-task' # 給任務(wù)設(shè)置個自定義名稱

 def run(self, *args, **kwargs):
  print('start test task')
  time.sleep(4)
  print('args={}, kwargs={}'.format(args, kwargs))
  print('end test task')

INSTALLED_APPS = [
 # ...
 'djcelery',
]

# Celery
from learn_django.celery_config import *

# views.py
from django.http import HttpResponse
from app.tasks import TestTask

def test_task(request):
 # 執(zhí)行異步任務(wù)
 print('start do request')
 t = TestTask()
 t.delay()
 print('end do request')
 return HttpResponse('ok')

python manage.py celery worker -l info

CELERYBEAT_SCHEDULE = {
 'task1-every-1-min': { # 自定義名稱
  'task': 'test-task', # 與任務(wù)中name名稱一致
  'schedule': datetime.timedelta(seconds=5),
  'args': (2, 15),
  'options': {
   'queue': 'beat_queue', # 指定要使用的隊列
  }
 },

}

python manage.py celery beat -l info

python manage.py celery flower

# python manage.py celery flower --basic_auth=admin:admin