# lifecycle_migration.py
import boto3
from datetime import datetime, timedelta
from minio import Minio
from minio.lifecycleconfig import LifecycleConfig, Rule, Expiration, Filter

class StorageManager:
    def __init__(self):
        # 连接两个MinIO实例
        self.hot_client = Minio(
            "hot-minio:9000",
            access_key="hot-access-key",
            secret_key="hot-secret-key",
            secure=False
        )
        self.cold_client = Minio(
            "cold-minio:9000",
            access_key="cold-access-key",
            secret_key="cold-secret-key",
            secure=False
        )
    
    def auto_migrate_old_files(self):
        """自动迁移30天前的文件到冷存储"""
        # 1. 扫描热存储中30天前的文件
        objects = self.hot_client.list_objects("recordings", recursive=True)
        
        for obj in objects:
            if self.is_older_than(obj.last_modified, days=30):
                # 2. 复制到冷存储
                self.copy_to_cold_storage(obj.object_name)
                
                # 3. 从热存储删除（或设置标记）
                self.hot_client.remove_object("recordings", obj.object_name)
                
                print(f"Migrated: {obj.object_name}")