【Django】古いレコードを定期自動削除する完全ガイド｜カスタムコマンド + cron でデータ保持期間を管理

from django.db import models
from datetime import datetime


class PerfHist(models.Model):
    class Meta:
        verbose_name = 'パフォーマンスデータ履歴情報'
        verbose_name_plural = 'パフォーマンスデータ履歴情報'

    server_name = models.ForeignKey(
        Server, on_delete=models.CASCADE, verbose_name="サーバ名"
    )
    cpu = models.IntegerField(help_text="単位は%", verbose_name="CPU使用率")
    memory = models.IntegerField(help_text="単位は%", verbose_name="メモリ使用率")
    update_time = models.DateTimeField(default=datetime.now, verbose_name="更新日時")

    def __str__(self):
        return str(self.server_name)

from datetime import date, timedelta
from app1.models import PerfHist

# 180 日前の日付を取得
before_180_days = date.today() - timedelta(days=180)

# update_time が 180 日前以前のレコードを全削除
PerfHist.objects.filter(update_time__lte=before_180_days).delete()

qs = PerfHist.objects.filter(update_time__lte=before_180_days)
print(f"削除対象: {qs.count()} 件")
# 想定通りなら実行
# qs.delete()

app1/
├── __init__.py
├── models.py
├── management/                 ← 新規作成
│   ├── __init__.py             ← 空ファイルでOK
│   └── commands/               ← 新規作成
│       ├── __init__.py         ← 空ファイルでOK
│       └── rotate_perfhist.py  ← 本記事のカスタムコマンド

# -*- coding: utf-8 -*-
from django.core.management.base import BaseCommand
from app1.models import PerfHist
from datetime import date, datetime, timedelta
from email.mime.text import MIMEText
import smtplib
import sys
import os
import logging

# ===== 初期設定 =====
LOG_DIR = "/var/log/django_rotate/"  # ログ出力先(環境に合わせて変更)
RETENTION_DAYS = 180                 # データ保持期間(日)

# ===== ログファイル設定 =====
date_name = datetime.now().strftime("%Y%m%d-%H%M%S")
file_name = os.path.join(LOG_DIR, f"{date_name}_ROTATE_PERFHIST.log")
logging.basicConfig(
    filename=file_name,
    level=logging.DEBUG,
    format='%(asctime)s %(message)s',
    datefmt='%Y/%m/%d %H:%M:%S',
)


def send_mail(subject, content):
    """異常終了時の通知メール送信"""
    message = MIMEText(content)
    message['Subject'] = subject
    message['From'] = 'noreply@example.com'
    message['To'] = 'admin@example.com'

    with smtplib.SMTP('mail.example.com') as sender:
        sender.sendmail(message['From'], message['To'], message.as_string())


class Command(BaseCommand):
    help = '180 日以前の PerfHist レコードを削除する'

    def handle(self, *args, **options):
        logging.info('[正常] パフォーマンス履歴データのハウスキープ処理を開始')

        try:
            before_n_days = date.today() - timedelta(days=RETENTION_DAYS)
            qs = PerfHist.objects.filter(update_time__lte=before_n_days)
            count = qs.count()
            logging.info(f'[情報] 削除対象件数: {count} 件')

            deleted_count, _ = qs.delete()
            logging.info(f'[正常] {deleted_count} 件のレコードを削除しました')

        except Exception as e:
            logging.exception('[異常] ハウスキープ処理でエラー発生')
            send_mail(
                subject='【異常終了】PerfHist ハウスキープジョブ',
                content=f'PerfHist ハウスキープでエラー発生。\n詳細: {e}\nログファイル: {file_name}',
            )
            sys.exit(1)

        logging.info('[正常] ハウスキープ処理が正常終了しました')

cd /path/to/your/project
python manage.py rotate_perfhist

# 毎日 午前 3 時に実行
0 3 * * * cd /path/to/your/project && /path/to/venv/bin/python manage.py rotate_perfhist

# 毎週日曜午前 4 時に実行
0 4 * * 0 cd /path/to/your/project && /path/to/venv/bin/python manage.py rotate_perfhist

schtasks /Create /SC DAILY /TN "DjangoRotatePerfhist" /ST 03:00 ^
  /TR "C:\path\to\venv\Scripts\python.exe C:\path\to\project\manage.py rotate_perfhist" ^
  /RL HIGHEST

2026/05/02 03:00:00 [正常] パフォーマンス履歴データのハウスキープ処理を開始
2026/05/02 03:00:00 [情報] 削除対象件数: 14523 件
2026/05/02 03:00:01 [正常] 14523 件のレコードを削除しました
2026/05/02 03:00:01 [正常] ハウスキープ処理が正常終了しました