Django：定时删除数据库中过期数据

pip install celery redis

# settings.py

import os

CELERY_BROKER_URL = 'redis://localhost:6379/0'  # Redis 作为消息代理
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0' # Redis 作为结果后端
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = 'Asia/Shanghai'  # 设置时区，根据实际情况修改

# smart_search/tasks.py (假设你的app名字是smart_search)

from celery import shared_task
from django.utils import timezone
from datetime import timedelta
from .models import UserHitCount  # 替换为你的模型

@shared_task
def delete_old_user_hit_counts():
    """
    删除创建时间超过 15 天的 UserHitCount 记录。
    """
    cutoff_date = timezone.now() - timedelta(days=15)
    UserHitCount.objects.filter(created_at__lte=cutoff_date).delete()
    print(f"Deleted UserHitCount records older than {cutoff_date}")

# settings.py

CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers:DatabaseScheduler'  # 使用数据库存储调度信息

CELERY_BEAT_SCHEDULE = {
    'delete-old-user-hit-counts': {
        'task': 'smart_search.tasks.delete_old_user_hit_counts',  # 任务的完整路径
        'schedule': crontab(hour=0, minute=0),  # 每天凌晨 0 点执行
        # 'schedule': timedelta(seconds=30), # 每30秒执行一次，仅用于测试
        'args': (),  # 任务的参数，这里为空
    },
}

celery -A your_project worker -l info  # 启动 Celery Worker，替换 your_project 为你的项目名
celery -A your_project beat -l info -S django_celery_beat.schedulers:DatabaseScheduler # 启动 Celery Beat

pip install django-celery-beat
python manage.py migrate