Django中使用Celery执行定时任务问题

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

使用Celery执行定时任务

Django中使用Celery执行异步任务里是引用

这个是接上一个异步任务的代码

定时任务

1. tasks.py中新增两个定时方法

# 定时任务1
@celery_app.task()
def my_crontab(x, y):
    print(x, y)
    print(f'x 和 y 相加 = {x+y}')
    return x + y


# 定时任务2
@celery_app.task()
def my_print():
    print('一生所爱')

2. 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加进去

from datetime import timedelta

# 新增的定时方法案列
# sum-task 名字任意取
app.conf.update(
    CELERYBEAT_SCHEDULE={
        'sum-task': {
            'task': 'CeleryFunc.tasks.my_crontab',
            'schedule':  timedelta(seconds=5),
            'args': (5, 6)
        },

        'sum-task1': {
            'task': 'CeleryFunc.tasks.my_print',
            'schedule':  timedelta(seconds=3),
            'args': ()
        },
    }
)


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

3. 启动

先启动项目,然后分别执行下面两个命令

celery -A DjangoFunction beat -l info
celery -A DjangoFunction worker -l info -P eventlet

celery -A DjangoFunction beat -l info 启动后的视图


在这里插入图片描述

celery -A DjangoFunction worker -l info -P eventlet 启动后的视图


在这里插入图片描述

总结

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

相关文章

  • 用Django写天气预报查询网站

    用Django写天气预报查询网站

    今天小编就为大家分享一篇关于用Django写天气预报查询网站的文章,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧
    2018-10-10
  • python中字符串String及其常见操作指南(方法、函数)

    python中字符串String及其常见操作指南(方法、函数)

    String方法是用来处理代码中的字符串的,它几乎能搞定你所遇到的所有字符串格式,下面这篇文章主要给大家介绍了关于python中字符串String及其常见操作(方法、函数)的相关资料,需要的朋友可以参考下
    2022-04-04
  • python定时采集摄像头图像上传ftp服务器功能实现

    python定时采集摄像头图像上传ftp服务器功能实现

    本文程序实现python定时采集摄像头图像上传ftp服务器功能,大家参考使用吧
    2013-12-12
  • Python新手如何进行闭包时绑定变量操作

    Python新手如何进行闭包时绑定变量操作

    在本篇文章里小编给大家分享的是关于Python新闭包时绑定变量实例,有兴趣的朋友们可以参考下。
    2020-05-05
  • Python 2种方法求某个范围内的所有素数(质数)

    Python 2种方法求某个范围内的所有素数(质数)

    这篇文章主要介绍了Python 2种方法求某个范围内的所有素数(质数),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-01-01
  • Python编码规范摆脱Python编码噩梦

    Python编码规范摆脱Python编码噩梦

    Python 中编码问题,一直是很多 Python 开发者的噩梦,尽管你是工作多年的 Python 开发者,也肯定会经常遇到令人神烦的编码问题,收藏这篇文章以后你可以不用再Google
    2021-10-10
  • Python实现删除重复文件的示例代码

    Python实现删除重复文件的示例代码

    这篇文章主要为大家详细介绍了如何利用Python实现删除重复文件功能,文中的示例代码讲解详细,对我们学习Python有一定的帮助,感兴趣的小伙伴的可以了解一下
    2023-02-02
  • 在python中使用SQLAlchemy查询PostgreSQL视图的流程步骤

    在python中使用SQLAlchemy查询PostgreSQL视图的流程步骤

    作为软件开发人员,查询 PostgreSQL 视图是一项常见任务,使用视图(代表SQL 查询输出的虚拟表)被认为是处理关系数据库时的有效方法,本文介绍如何在 Python 中使用 SQLAlchemy 查询 PostgreSQL 视图,需要的朋友可以参考下
    2023-09-09
  • 解决Django的request.POST获取不到内容的问题

    解决Django的request.POST获取不到内容的问题

    今天小编就为大家分享一篇解决Django的request.POST获取不到内容的问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2018-05-05
  • Python利用3D引擎写一个Pong游戏

    Python利用3D引擎写一个Pong游戏

    之前,我们尝试过用pygame做了一个2D的Pong游戏。本文将利用强大的3D引擎Ursina制作一个3D版的Pong游戏。文中的示例代码讲解详细,感兴趣的可以了解一下
    2023-01-01

最新评论