pip install celery==4.4.7

CELERY_BROKER_URL = 'redis://127.0.0.1:6379/1'
CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/1'
CELERY_RESULT_SERIALIZER = 'json'

from __future__ import absolute_import, unicode_literals
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', 'DjangoFunction.settings')

app = Celery('test_celery')  # 定義全局的Celery任務(wù) test_celery 隨便寫

# Using a string here means the worker doesn't have to serialize
# the configuration object to child processes.
# - namespace='CELERY' means all celery-related configuration keys
#   should have a `CELERY_` prefix.
app.config_from_object('django.conf:settings', namespace='CELERY')  # 固定配置

# Load task modules from all registered Django app configs.
app.autodiscover_tasks(['CeleryFunc'])  # 把需要用定時(shí)任務(wù)的APP加進(jìn)去


@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))

from __future__ import absolute_import, unicode_literals
from .celery import app as celery_app  # 重命名

__all__ = ['celery_app']  # 把重命名的APP寫進(jìn)去

import time
from loguru import logger
# Django環(huán)境的初始化
# 在任務(wù)處理者一段加這幾句
import os
import django
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'DjangoFunction.settings')
django.setup()
from DjangoFunction import celery_app


# bind=True， 加了這個(gè)就必須加 self， 這個(gè)能打印定時(shí)任務(wù)的信息（這兩個(gè)都可以不加）
@celery_app.task(bind=True)
def my_asynch_task(self):
    """
    我的 異步 任務(wù)
    :return:
    """
    logger.info('開始執(zhí)行異步任務(wù)')
    time.sleep(3)
    print('------', self.request.id)
    logger.info('結(jié)束執(zhí)行異步任務(wù)')
    return 10

from rest_framework.views import APIView
from rest_framework.response import Response
from CeleryFunc.tasks import my_asynch_task
import time

class AsyncAPIView(APIView):
    """
    數(shù)據(jù)集
    """
    def get(self, request, format=None):
        try:
            start_time = time.time()
            # 這兩種方法都可以，不加后面這個(gè)方法就不是異步了
            # result = my_asynch_task.apply_async()  
            result = my_asynch_task.delay()
            print(dir(result))
            print('result.state = ', result.state)
            print('result.status = ', result.status)
            print('result.successful = ', result.successful)
            print('result.result = ', result.result)
            print('result.name = ', result.name)
            resp = {
                'code': 200,
                'message': 'success',
            }
            end_date = time.time()
            print('耗時(shí)： ', end_date - start_time)
        except Exception as e:
            resp = {
                'code': 300,
                'message': str(e),
            }
        return Response(resp)

celery worker -A DjangoFunction -l info -P eventlet