diff --git a/apps/monitor/tasks.py b/apps/monitor/tasks.py index 7e05f21b..a1cc34c1 100644 --- a/apps/monitor/tasks.py +++ b/apps/monitor/tasks.py @@ -8,11 +8,11 @@ from django.utils import timezone @shared_task(base=CustomTask) -def clear_drf_log(): - """清除7天前的日志记录 +def clear_drf_log(days: int = 7): + """清除N天前的日志记录,默认七天 - 清除7天前的日志记录 + 清除N天前的日志记录 """ now = timezone.now() - days7_ago = now - timedelta(days=7) + days7_ago = now - timedelta(days=days) DrfRequestLog.objects.filter(create_time__lte=days7_ago).delete() diff --git a/apps/third/tasks.py b/apps/third/tasks.py index a1874ffe..a78e779e 100644 --- a/apps/third/tasks.py +++ b/apps/third/tasks.py @@ -11,13 +11,13 @@ from apps.third.speaker import spClient @shared_task(base=CustomTask) -def clear_tlog(): - """清除7天前的日志记录 +def clear_tlog(days: int =7): + """清除N天前的日志记录,默认七天 - 清除7天前的日志记录 + 清除N天前的日志记录 """ now = timezone.now() - days7_ago = now - timedelta(days=7) + days7_ago = now - timedelta(days=days) Tlog.objects.filter(create_time__lte=days7_ago).delete()