首页 > 其他分享 >django-celery-beat 获取下一次执行时间

django-celery-beat 获取下一次执行时间

时间:2022-09-03 10:02:56浏览次数:94  
标签:task run beat per django celery last logger

前言

因为业务需要获取下一次执行时间在前端展示,查阅百度,谷歌都没能找到实现方式。通过官方文档https://django-celery-beat.readthedocs.io/en/latest/reference/django-celery-beat.tzcrontab.html了解到有相应的实现。

官方文档解读

在django_celery_beat.tzcrontab类下面有个is_due(last_run_at)是计算下一次执行时间的方法,它的返回值是(is_due, next_time_to_check)。
is_due为true时,next_time_to_check是下一次执行时间距离last_run_at秒数。但是当is_due为false时,next_time_to_check是下一次的检查时间,不符合业务需要。

深入源码

  1. 通过查看源码的实现,发现主要实现的逻辑在于这三句话,重点是调用了self.remaining_estimate去计算时间

  2. 时间增量具体计算逻辑实现,通过解析cron表达式去计算下一次执行的时间相距多少。

  3. 以下是remaining_delta的返回值

  4. 拿到remaining_delta的返回值去计算开始时间+增量时间得到下一次执行时间的一个估算。

  5. 代码具体实现

def get_next_time(task_name):
    per_task = celery_models.PeriodicTask.objects.filter(name=task_name).first()
    logger.info(f"per_task:{per_task}")
    if per_task and per_task.enabled:
        # 如果任务存在并且开启,则计算下次执行时间
        # 当前任务没有最后执行时间时,选择当前时间进行计算
        last_run_at = per_task.last_run_at or datetime.now(tz=pytz.timezone('Asia/Shanghai'))
        # per_task.last_run_at
        cron_exp = {
            "minute": per_task.crontab.minute,
            "hour": per_task.crontab.hour,
            "day_of_week": per_task.crontab.day_of_week,
            "day_of_month": per_task.crontab.day_of_month,
            "month_of_year": per_task.crontab.month_of_year,
            "tz": pytz.timezone('Asia/Shanghai')
        }
        tza = TzAwareCrontab(**cron_exp)
        tza.remaining_estimate(last_run_at)
        # 计算下次执行时间
        logger.info(f"任务表达式: {cron_exp}")
        logger.info(f"剩余_增量: {tza.remaining_delta(last_run_at)}")
        next_run_time = datetime.now() + tza.remaining_estimate(last_run_at)
        logger.info(f"【{task_name}】时间:{last_run_at}")
        logger.info(f"【{task_name}】时间差:{tza.remaining_estimate(last_run_at)}")
        logger.info(f"【{task_name}】计算表达式:{cron_exp}")
        logger.info(f"【{task_name}】下次运行时间:{next_run_time}")
        return str(next_run_time)
    else:
        return ''
  1. 时区配置(重新配置时区后需要更新定时任务的时间,具体可以看官方文档,亦或者你把定时任务全删掉,重新添加也可行。)
celery配置文件加入这两行代码

# celery时区设置,建议与Django settings中TIME_ZONE同样时区,防止时差
# Django设置时区需同时设置USE_TZ=True和TIME_ZONE = 'Asia/Shanghai'
timezone = 'Asia/Shanghai'
# 避免时区的问题
enable_utc = True


django settings.py文件加入
TIME_ZONE = 'Asia/Shanghai'
USE_TZ = True
DJANGO_CELERY_BEAT_TZ_AWARE = False

标签:task,run,beat,per,django,celery,last,logger
From: https://www.cnblogs.com/se7enjean/p/16652027.html

相关文章

  • django框架-04
    目录路由层网页伪静态视图层视图函数返回值django序列化方法form表单操作FBV与CBVFBVCBV模板层模板语法传值模板语法过滤器模板语法符号模板语法标签自定义相关功能模板继......
  • Django数据传递与模板语法
    Django数据传递与模板语法视图函数返回值1.视图函数的返回值其实本质上返回的都是HttpResponse对象,HttpResponse其实是一个类,我们最常使用的render和redirect都是这个类......
  • 【Django】 第04回 视图层与模板层
    目录1.网页伪静态2.视图层2.1视图函数的返回值问题2.2视图函数返回json格式数据2.3from表单携带文件数据2.4FEV与CBV2.5CBV源码分析3.模板层3.1模板语法传值3.2......
  • django之视图层与模板层
    一、伪静态网页'''其实就是如果一个网页如果是一个静态网页的话那么浏览器搜索会更容易搜索的到而如果一个动态网页想要让浏览器更容易搜索到的话可以在路由匹配的时......
  • django_响应对象
    Django_响应对象响应对象响应对象有三种形式:HttpResponse()render()Redirect()(1)HttpResponse()django服务器接收到客户端发来的请求之后,会将提交上来的数据封装成......
  • Django初学者介绍和安装
    Django初学者介绍和安装吨他的文章主要关注Django的安装以及如何进行Django开发环境的初始设置。我们还将讨论Django及其特性。在本教程结束时,您将知道如何:如......
  • 【Django】第03回 生命周期、路由匹配、反向解析、名称空间
    目录1.用户数据的增删改查2.Django请求生命周期流程图3.路由匹配3.1path斜杠3.2path转换器3.3正则匹配无名分组、有名分组4.反向解析4.1反向解析语法4.2无名有名......
  • 【django学习-07】视图之HttpResponse
    前言:视图函数通过return方式返回响应数据,然后生成响应的网页内容呈现在浏览器上。视图函数主要有两种返回数据的方法HttpResponse:直接返回数据到浏览器上,不能使用模......
  • django路由匹配、反向解析、无名有名反向解析、路由分发、名称空间
    目录django请求生命周期流程图1.Django请求的生命周期的含义2.Django请求的生命周期图解及流程3.Django的请求生命周期(分布解析)路由层1.路由匹配2.path转换器3.re_path正则......
  • 今日内容 django路由匹配,分组,分发和反向解析
    django请求生命周期流程图浏览器     发送请求(HTTP协议)web服务网关接口:1、请求来的时候解析封装    响应走的时候打包处理2、django默认的wsgi......