如何在Django Celery中使用Crontab作业

2023-04-11 00:00:00 celery 作业如何在

首先，需要安装django-celery-beat：

pip install django-celery-beat

然后，在Django的settings.py中添加以下配置：

INSTALLED_APPS = (
    ...
    'django_celery_beat',
)

CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers:DatabaseScheduler'

接下来，在您的项目中创建一个名为tasks.py的文件，并添加以下代码：

from celery.task import periodic_task
from celery.schedules import crontab

@periodic_task(run_every=crontab(minute='*/5'))
def my_task():
    print('Hello, pidancode.com!')

上面的代码将创建一个名为“my_task”的周期性任务，并在每5分钟执行一次，输出“Hello, pidancode.com!”。

最后，启动Celery Worker和Celery Beat：

celery -A your_project_name worker -l info
celery -A your_project_name beat -l info

这样，您就可以在Django Celery中使用Crontab作业了。

相关文章