使用vue Django的Celery框架来实现定时任务的执行

首先，需要确保你已经安装了Celery和Django-Celery-Beat。接下来，我们可以根据下面的步骤来实现定时任务的执行。

1. 在Django的settings.py文件中添加以下配置：

CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'
CELERY_TIMEZONE = 'Asia/Shanghai'

INSTALLED_APPS = [
    # ...
    'django_celery_beat',
]

其中，`CELERY_BROKER_URL` 和 `CELERY_RESULT_BACKEND` 分别用于指定 Celery 的消息队列和结果存储位置，这里我们使用 Redis 数据库。`CELERY_TIMEZONE` 用于指定时区，这里我们使用了上海时区。同时，需要将 `django_celery_beat` 添加到 `INSTALLED_APPS` 中。

2. 创建定时任务模型

在Django中，我们可以使用模型类来定义定时任务，这样可以方便地进行管理和修改。我们可以在任意一个应用中创建一个名为 `tasks.py` 的文件，然后在其中定义一个模型类，例如：

from django.db import models
from django.utils import timezone
from django_celery_beat.models import PeriodicTask, CrontabSchedule

class MyTask(models.Model):
    name = models.CharField(max_length=255)
    crontab = models.CharField(max_length=255)
    args = models.CharField(max_length=255, blank=True)
    kwargs = models.CharField(max_length=255, blank=True)

    def save(self, *args, **kwargs):
        # 创建或更新定时任务
        crontab, _ = CrontabSchedule.objects.get_or_create(
            minute=self.crontab.split()[0],
            hour=self.crontab.split()[1],
            day_of_week=self.crontab.split()[2],
            day_of_month=self.crontab.split()[3],
            month_of_year=self.crontab.split()[4]
        )
        task, _ = PeriodicTask.objects.get_or_create(
            name=self.name,
            task='myapp.tasks.my_task',
            args=self.args,
            kwargs=self.kwargs,
            crontab=crontab
        )
        super().save(*args, **kwargs)

    def delete(self, *args, **kwargs):
        # 删除定时任务
        task = PeriodicTask.objects.filter(name=self.name)
        task.delete()
        super().delete(*args, **kwargs)

在这个例子中，我们定义了一个名为 `MyTask` 的模型类，其中包含了定时任务的名称、定时规则、参数等信息。在 `save` 方法中，我们使用 `CrontabSchedule` 和 `PeriodicTask` 模型类来创建或更新定时任务。在 `delete` 方法中，我们使用 `PeriodicTask` 模型类来删除定时任务。

3. 编写定时任务函数

在 `MyTask` 模型类中，我们指定了一个名为 `my_task` 的函数作为定时任务的执行函数。我们可以在任意一个应用中创建一个名为 `tasks.py` 的文件，然后在其中定义这个函数，例如：

from celery import shared_task

@shared_task
def my_task(*args, **kwargs):
    print('Hello, world!')

在这个例子中，我们定义了一个名为 `my_task` 的函数，使用 `@shared_task` 装饰器将其转换成 Celery 的任务函数。在这个任务函数中，我们只是简单地打印了一条消息。

4. 启动 Celery 任务队列

在一个终端中，我们可以使用以下命令启动 Celery：

celery -A myproject worker -l info

其中，`myproject` 是你的 Django 项目名称，`-l info` 参数用于指定 Celery 的日志级别。

5. 启动 Celery 定时任务

在另一个终端中，我们可以使用以下命令启动 Celery 的定时任务：

celery -A myproject beat -l info

其中，`myproject` 是你的 Django 项目名称，`-l info` 参数用于指定 Celery 的日志级别。

6. 创建和管理定时任务

现在，我们已经可以通过 `MyTask` 模型类来创建和管理定时任务了。例如，我们可以在 Django shell 中执行以下代码来创建一个每分钟执行一次的定时任务：

from myapp.models import MyTask

task = MyTask(name='my_task_1', crontab='* * * * *', args='', kwargs='')
task.save()

我们也可以在 Django admin 中创建和管理定时任务。只需要在 admin.py 文件中注册 `MyTask` 模型类即可：

from django.contrib import admin
from myapp.models import MyTask

@admin.register(MyTask)
class MyTaskAdmin(admin.ModelAdmin):
    list_display = ('name', 'crontab', 'args', 'kwargs')

现在，我们可以在 Django admin 中创建和管理定时任务了。

总结一下，使用 Celery 和 Django-Celery-Beat 可以方便地实现定时任务的执行。我们只需要定义一个定时任务模型类，然后在其中指定定时规则和执行函数即可。同时，我们也可以使用 Django admin 来创建和管理定时任务，非常方便。