doris-sync/jobs/clean_logs.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-
"""
清理旧日志任务
"""

import datetime
from logger.handler import get_logger, clean_old_logs

logger = get_logger("job.clean_logs")


def run(days=30):
    """
    执行日志清理任务

    Args:
        days: 保留最近多少天的日志，默认30天
    """
    logger.info("=" * 50)
    logger.info(f"[日志清理] 开始清理超过 {days} 天的旧日志")
    logger.info("=" * 50)

    try:
        clean_old_logs(days=days)
        logger.info(f"[日志清理] 清理完成，保留最近 {days} 天的日志")
        logger.info("=" * 50)
        return 0
    except Exception as e:
        logger.error(f"[日志清理] 清理失败: {e}")
        logger.info("=" * 50)
        return 1