Django Q2 - 设置函数调度的基本结构

Question

我对 Django 的使用有点陌生，不同于它的基本范围。我安排了一个每分钟运行一次的函数用于试用。我读了很多次文档，但我仍然不清楚使用 Django Q2 库进行调度的正确方法是什么。

您能帮我澄清一下吗？请注意，我使用的是 DjangoORM。

在我的尝试中，我创建了schedule.py，如下脚本并使其以某种方式工作，但我不确定运行“setup_periodic_tasks”的正确方法是什么。此外，尽管我从任务对象中删除了我运行的早期任务，但每次运行 qcluster 时它们仍然会出现，那么如何才能永久删除它们呢？

def schedule_price_list_status():
    print('PRICE LIST SCHEDULED')

def setup_periodic_tasks(**kwargs):
    print('SETUP TASKS')
    schedule('my_app.schedules.schedule_price_list_status', schedule_type='I', repeats=2, minutes=1)

setup_periodic_tasks()

Answer 1

def setup_periodic_tasks(**kwargs):
    if not Schedule.objects.filter(func='my_app.schedules.schedule_price_list_status').exists():
        print('SETUP TASKS')
        Schedule('my_app.schedules.schedule_price_list_status', schedule_type='I', repeats=2, minutes=1)

执行python manage.py qcluster