Celery笔记八之数据库操作定时任务

发布网友发布时间：2024-10-07 19:17

共1个回答

热心网友时间：2024-10-07 21:07

Celery在Django系统中进行数据库操作定时任务的笔记，主要涉及将定时任务管理从celery.py的app.conf.beat_schedule扩展到数据库操作。首先，安装django-celery-beat依赖，并将其添加到settings.py的INSTALLED_APPS中，执行migrate操作以在数据库中创建相关表。这些表包括django_celery_beat_crontabschedule（周期任务）和django_celery_beat_intervalschedule（间隔任务），它们分别记录任务的执行策略和时间间隔。beat服务启动时，需要设置时区并指定数据存储在数据库，然后beat会根据这些表中的数据来调度任务。

表django_celery_beat_periodictask汇总了周期和间隔任务的信息，name字段唯一，允许为同一个task制定不同策略。另一个表django_celery_beat_periodictasks记录了系统上一次执行任务的时间。在Django环境中，可以通过定义并写入这些表来手动添加、修改或删除定时任务。例如，可以创建一个每20秒运行一次的add任务，以及一个每天23点15分执行的minus任务。

当任务策略在数据库中改变时，beat会检测到并自动更新任务执行。通过测试，发现name、enabled、one_off等字段的修改都能被系统捕获，其中one_off表示任务是一次性的。所有这些操作都提供了灵活的定时任务管理，便于定制开发。欲了解更多内容，可关注微信公众号【Hunter后端】获取更多相关文章。