1. 首先在项目目录下创建一个异步工作单元文件夹worker

2. 创建init和config文件，内容分别是：

init:

#!/usr/bin/env python
import os

from celery import Celery
from worker import config

# 加载Django的settings
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "social_demo.settings")
# 定义celery
celery_app = Celery('worker')
# config_from_object自动从config模块里面加载配置
celery_app.config_from_object(config)
# 自动发现Django中有哪些任务
celery_app.autodiscover_tasks()

worker:

broker_url = 'redis://127.0.0.1:6379/1'
broker_pool_limit = 100  # Borker 连接池, 默认是10

timezone = 'Asia/Shanghai'
# 处理任务内容的类型
accept_content = ['pickle', 'json']

# redis需要字符串类型才能存储   利用pickle序列化一下
task_serializer = 'pickle'
result_expires = 3600  # 任务过期时间

# 结果保存
result_backend = 'redis://127.0.0.1:6379/1'
result_serializer = 'pickle'
result_cache_max = 10000  # 任务结果最大缓存数量

# 日志级别
worker_redirect_stdouts_level = 'INFO'

3. 然后在用接口函数调用

# 上传头像
def upload_avatar(request):
    avatar_file = request.FILES['avatar']
    # 通过delay让celery异步执行
    logics.upload_avatar.delay(request.user, avatar_file)
    return render_json()

4. 服务器上面开启服务，另外再开启一个celery进程

python manage.py runserver

celery worker -A worker --loglevel=info