Django中如何使用Celery执行异步任务

 更新时间:2023年11月24日 09:13:12   作者:G_scsd  
这篇文章主要介绍了Django中如何使用Celery执行异步任务问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

DJango使用Celery异步任务

1. 安装

pip install celery==4.4.7

2. 配置

2.1 setting.py

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

2.2 setting同级目录

  • 2.2.1新建celery.py
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任务 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'])  # 把需要用定时任务的APP加进去


@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))
  • 2.2.2 init.py
from __future__ import absolute_import, unicode_literals
from .celery import app as celery_app  # 重命名

__all__ = ['celery_app']  # 把重命名的APP写进去

3. Django APP 中新建tasks.py文件

import time
from loguru import logger
# Django环境的初始化
# 在任务处理者一段加这几句
import os
import django
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'DjangoFunction.settings')
django.setup()
from DjangoFunction import celery_app


# bind=True, 加了这个就必须加 self, 这个能打印定时任务的信息(这两个都可以不加)
@celery_app.task(bind=True)
def my_asynch_task(self):
    """
    我的 异步 任务
    :return:
    """
    logger.info('开始执行异步任务')
    time.sleep(3)
    print('------', self.request.id)
    logger.info('结束执行异步任务')
    return 10

4. views.py文件

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

class AsyncAPIView(APIView):
    """
    数据集
    """
    def get(self, request, format=None):
        try:
            start_time = time.time()
            # 这两种方法都可以,不加后面这个方法就不是异步了
            # 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('耗时: ', end_date - start_time)
        except Exception as e:
            resp = {
                'code': 300,
                'message': str(e),
            }
        return Response(resp)

后台可以启动这个命令来查看异步任务是否加入和日志

DjangoFunction是项目名称

celery worker -A DjangoFunction -l info -P eventlet

项目结构

在这里插入图片描述

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Python中查找缺失值的三种方法

    Python中查找缺失值的三种方法

    本文主要介绍了Python中查找缺失值的三种方法,包括pandas库的isnull()方法、numpy库的isnan()方法和scikit-learn库的SimpleImputer类,感兴趣的可以了解一下
    2023-11-11
  • Tensorflow实现神经网络拟合线性回归

    Tensorflow实现神经网络拟合线性回归

    这篇文章主要为大家详细介绍了Tensorflow实现神经网络拟合线性回归,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-07-07
  • K近邻法(KNN)相关知识总结以及如何用python实现

    K近邻法(KNN)相关知识总结以及如何用python实现

    这篇文章主要介绍了K近邻法(KNN)相关知识总结以及如何用python实现,帮助大家更好的利用python实现机器学习,感兴趣的朋友可以了解下
    2021-01-01
  • 修改Pandas的行或列的名字(重命名)

    修改Pandas的行或列的名字(重命名)

    这篇文章主要介绍了修改Pandas的行或列的名字(重命名),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-12-12
  • python学习实操案例(五)

    python学习实操案例(五)

    这篇文章主要介绍了pyth学习实操案例,主要分享的小练习有我的咖啡馆你做主、显示2019中超联赛中前五名排行、模拟手机通讯录,适合初学者,需要的小伙伴可以参考一下
    2022-02-02
  • Python matplotlib包和gif包生成gif动画实战对比

    Python matplotlib包和gif包生成gif动画实战对比

    使用matplotlib生成gif动画的方法相信大家应该都看到过,下面这篇文章主要给大家介绍了关于Python matplotlib包和gif包生成gif动画对比的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
    2022-05-05
  • 使用 Python 的 pprint库格式化和输出列表和字典的方法

    使用 Python 的 pprint库格式化和输出列表和字典的方法

    pprint是"pretty-print"的缩写,使用 Python 的标准库 pprint 模块,以干净的格式输出和显示列表和字典等对象,这篇文章主要介绍了如何使用 Python 的 pprint库格式化和输出列表和字典,需要的朋友可以参考下
    2023-05-05
  • python实现贪吃蛇游戏源码

    python实现贪吃蛇游戏源码

    这篇文章主要为大家详细介绍了python实现贪吃蛇游戏,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2020-03-03
  • 分享几道你可能遇到的python面试题

    分享几道你可能遇到的python面试题

    最近去笔试,在面试过程中遇到了几个编程题,比较基础。所以想着总结一下,所以下面这篇文章主要给大家分享了几道你可能遇到的python面试题,文中给出了详细的示例代码供大家参考学习,需要的朋友们下面来一起看看吧。
    2017-07-07
  • 中秋送礼分配不均这款python刮刮卡完美解决问题

    中秋送礼分配不均这款python刮刮卡完美解决问题

    这篇文章主要介绍了用Python实现一个抽奖刮刮卡来解决给小朋友的礼物不均,文中讲解非常细致,代码帮助大家更好的理解和学习,感兴趣的朋友可以了解下
    2021-09-09

最新评论