Celery Beat 如何计算 datetime.now() 和下一个预定的周期性任务 django 之间的差异

问题描述

我为每周的第 3 天设置了一个 celery beat cron 时间表。 在 django shell 中，我可以访问这个时间表：

PS ~> 10..1 |sort-objectCustom -Verbose
VERBOSE: Begin was called
VERBOSE: Process was called [InputObject: 10]
VERBOSE: Process was called [InputObject: 9]
VERBOSE: Process was called [InputObject: 8]
VERBOSE: Process was called [InputObject: 7]
VERBOSE: Process was called [InputObject: 6]
VERBOSE: Process was called [InputObject: 5]
VERBOSE: Process was called [InputObject: 4]
VERBOSE: Process was called [InputObject: 3]
VERBOSE: Process was called [InputObject: 2]
VERBOSE: Process was called [InputObject: 1]
VERBOSE: End was called
1
2
3
4
5
6
7
8
9
10

我的问题是，如何计算 datetime.Now() 和下一个 PeriodicTask 之间的时差（以天为单位）？

解决方法

这是我要运行的解决方案：

源自 Celery 文档 celery.schedules

periodic_task = PeriodicTask.objects.get(name="my_task")

time_to_go = periodic_task.schedule.is_due(datetime.now())

time_to_go.next = time to next run in seconds