Initial commit: MiniMax Tools for Hugging Face Space

Dockerfile

@@ -0,0 +1,27 @@
+FROM python:3.11-slim
+
+# 设置工作目录
+WORKDIR /app
+
+# 安装系统依赖
+RUN apt-get update && apt-get install -y \
+    curl \
+    && rm -rf /var/lib/apt/lists/*
+
+# 复制需求文件
+COPY requirements.txt .
+
+# 安装Python依赖
+RUN pip install --no-cache-dir -r requirements.txt
+
+# 复制应用代码
+COPY app/ ./
+
+# 创建临时目录（使用标准 /tmp）
+RUN mkdir -p /tmp
+
+# 暴露端口（Hugging Face Space 使用 7860）
+EXPOSE 7860
+
+# 启动命令
+CMD ["uvicorn", "main:app", "--host", "0.0.0.0", "--port", "7860"]

README.md

@@ -0,0 +1,72 @@
+---
+title: MiniMax Tools
+emoji: 🎵
+colorFrom: blue
+colorTo: purple
+sdk: docker
+app_port: 7860
+pinned: false
+---
+
+# MiniMax Tools
+
+基于 MiniMax API 的一站式工具集合，包含音乐生成、图片生成、图像分析和语音设计四大功能。
+
+## 🌟 功能特性
+
+- **🎵 音乐生成**：根据文本提示和歌词生成音乐
+- **🖼️ 图片生成**：基于文本描述生成高质量图片
+- **👁️ 图像分析**：使用视觉语言模型分析图片内容
+- **🔊 语音设计**：根据描述设计个性化语音
+- **📊 统一监控**：实时查看使用统计和性能指标
+- **🔒 数据安全**：用户数据自动清理，无长期存储
+- **⚡ 限流保护**：内置限流机制，防止API过度调用
+
+## 🚀 使用说明
+
+1. 访问对应功能页面
+2. 输入您的 MiniMax API Key
+3. 填写相关参数
+4. 提交请求即可
+
+## 📋 API端点
+
+- `GET /` - 主页
+- `GET /music` - 音乐生成页面
+- `POST /music/generate` - 生成音乐
+- `GET /image-generation` - 图片生成页面
+- `POST /image-generation/generate` - 生成图片
+- `GET /vlm` - 图像分析页面
+- `POST /vlm/analyze` - 分析图像
+- `GET /voice-design` - 语音设计页面
+- `POST /voice-design/design` - 设计语音
+- `GET /admin` - 监控面板
+
+## 🔧 限流策略
+
+- **音乐生成**: 5分钟5次
+- **图片生成**: 5分钟5次
+- **图像分析**: 5分钟10次
+- **语音设计**: 5分钟5次
+
+## 🛡️ 数据安全
+
+- 用户上传的文件在1小时后自动删除
+- 不存储用户的API Key
+- 仅保留API调用统计数据
+- 所有临时数据定期清理
+
+## 🆘 常见问题
+
+### Q: 如何获取 MiniMax API Key？
+A: 访问 [MiniMax 官网](https://api.minimaxi.com) 注册账户并获取 API Key。
+
+### Q: 文件上传失败怎么办？
+A: 检查文件格式是否正确，确保网络连接稳定。
+
+### Q: API 调用被限流怎么办？
+A: 等待限流时间窗口结束，或联系管理员调整限流策略。
+
+## 📄 License
+
+MIT License

app/main.py

@@ -0,0 +1,49 @@
+from fastapi import FastAPI, Request
+from fastapi.staticfiles import StaticFiles
+from fastapi.templating import Jinja2Templates
+from fastapi.responses import HTMLResponse
+import os
+
+from routes import music, vlm, voice_design, image_generation
+from utils.monitor import setup_monitoring
+from utils.cleanup import start_cleanup_task
+
+app = FastAPI(title="MiniMax Tools", version="1.0.0")
+
+# 静态文件和模板
+# 检查 static 目录是否存在
+if os.path.exists("static"):
+    app.mount("/static", StaticFiles(directory="static"), name="static")
+templates = Jinja2Templates(directory="templates")
+
+# 设置监控
+setup_monitoring(app)
+
+# 启动清理任务
+start_cleanup_task()
+
+# 注册路由
+app.include_router(music.router, prefix="/music", tags=["Music"])
+app.include_router(vlm.router, prefix="/vlm", tags=["VLM"])
+app.include_router(voice_design.router, prefix="/voice-design", tags=["Voice Design"])
+app.include_router(image_generation.router, prefix="/image-generation", tags=["Image Generation"])
+
+
+@app.get("/", response_class=HTMLResponse)
+async def home(request: Request):
+    return templates.TemplateResponse("index.html", {"request": request})
+
+@app.get("/admin", response_class=HTMLResponse)
+async def admin(request: Request):
+    from utils.monitor import get_stats
+    stats = get_stats()
+    return templates.TemplateResponse("admin.html", {"request": request, "stats": stats})
+
+@app.get("/health")
+async def health_check():
+    return {"status": "healthy", "service": "minimax-tools"}
+
+if __name__ == "__main__":
+    import uvicorn
+    port = int(os.getenv("PORT", 7860))
+    uvicorn.run(app, host="0.0.0.0", port=port)

app/routes/__init__.py

@@ -0,0 +1 @@
+# Routes package

app/routes/image_generation.py

@@ -0,0 +1,71 @@
+from fastapi import APIRouter, HTTPException, Request, Form
+from fastapi.responses import HTMLResponse
+from fastapi.templating import Jinja2Templates
+import requests
+import json
+from utils.rate_limiter import check_rate_limit
+
+router = APIRouter()
+templates = Jinja2Templates(directory="templates")
+
+@router.get("/", response_class=HTMLResponse)
+async def image_generation_page(request: Request):
+    return templates.TemplateResponse("image_generation.html", {"request": request})
+
+@router.post("/generate")
+async def generate_image(
+    request: Request,
+    api_key: str = Form(...),
+    prompt: str = Form(...),
+    aspect_ratio: str = Form("1:1"),
+    n: int = Form(3),
+    prompt_optimizer: bool = Form(True)
+):
+    # 限流检查
+    check_rate_limit(request, max_requests=5, window_seconds=300)  # 5分钟5次
+    
+    try:
+        url = "https://api.minimaxi.com/v1/image_generation"
+        
+        payload = json.dumps({
+            "model": "image-01",
+            "prompt": prompt,
+            "aspect_ratio": aspect_ratio,
+            "response_format": "url",
+            "n": n,
+            "prompt_optimizer": prompt_optimizer
+        })
+        
+        headers = {
+            'Authorization': f'Bearer {api_key}',
+            'Content-Type': 'application/json'
+        }
+        
+        response = requests.post(url, headers=headers, data=payload)
+        
+        # 获取 trace_id
+        trace_id = response.headers.get('Trace-ID', '')
+        
+        if response.status_code != 200:
+            raise HTTPException(status_code=response.status_code, detail="API调用失败")
+        
+        result = response.json()
+        
+        # 检查返回格式
+        if 'data' not in result or 'image_urls' not in result['data']:
+            raise HTTPException(status_code=400, detail="API返回数据格式错误：缺少image_urls")
+        
+        return {
+            "status": "success",
+            "message": "图片生成成功",
+            "id": result.get('id', ''),
+            "image_urls": result['data']['image_urls'],
+            "metadata": result.get('metadata', {}),
+            "base_resp": result.get('base_resp', {}),
+            "trace_id": trace_id
+        }
+        
+    except requests.RequestException as e:
+        raise HTTPException(status_code=500, detail=f"网络请求错误: {str(e)}")
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"处理错误: {str(e)}")

app/routes/music.py

@@ -0,0 +1,118 @@
+from fastapi import APIRouter, HTTPException, Request, Form
+from fastapi.responses import HTMLResponse, FileResponse
+from fastapi.templating import Jinja2Templates
+import requests
+import json
+import subprocess
+import time
+import os
+from utils.rate_limiter import check_rate_limit
+from utils.cleanup import create_user_session_dir
+
+router = APIRouter()
+templates = Jinja2Templates(directory="templates")
+
+def audio_play_and_save(data: str, session_dir: str) -> str:
+    """处理音频数据并保存"""
+    # 转换hex为bytes
+    audio_bytes = bytes.fromhex(data)
+    
+    # 保存文件
+    timestamp = int(time.time())
+    file_name = f'music_{timestamp}.mp3'
+    file_path = os.path.join(session_dir, file_name)
+    
+    with open(file_path, 'wb') as file:
+        file.write(audio_bytes)
+    
+    return file_path
+
+@router.get("/", response_class=HTMLResponse)
+async def music_page(request: Request):
+    return templates.TemplateResponse("music.html", {"request": request})
+
+@router.post("/generate")
+async def generate_music(
+    request: Request,
+    api_key: str = Form(...),
+    prompt: str = Form(...),
+    lyrics: str = Form(...)
+):
+    # 限流检查
+    check_rate_limit(request, max_requests=5, window_seconds=300)  # 5分钟5次
+    
+    # 创建用户会话目录
+    session_dir, session_id = create_user_session_dir()
+    
+    try:
+        url = "https://api.minimaxi.com/v1/music_generation"
+        
+        payload = json.dumps({
+            "model": "music-1.5",
+            "prompt": prompt,
+            "lyrics": lyrics,
+            "audio_setting": {
+                "sample_rate": 44100,
+                "bitrate": 256000,
+                "format": "mp3"
+            }
+        })
+        
+        headers = {
+            'Authorization': 'Bearer ' + api_key,
+            'Content-Type': 'application/json'
+        }
+        
+        response = requests.post(url, headers=headers, data=payload)
+        
+        if response.status_code != 200:
+            raise HTTPException(status_code=response.status_code, detail="API调用失败")
+        
+        result = response.json()
+        
+        if 'data' not in result or 'audio' not in result['data']:
+            raise HTTPException(status_code=400, detail="API返回数据格式错误")
+        
+        # 处理音频数据
+        audio_hex = result['data']['audio']
+        file_path = audio_play_and_save(audio_hex, session_dir)
+        
+        return {
+            "status": "success",
+            "message": "音乐生成成功",
+            "file_url": f"/music/download/{session_id}/{os.path.basename(file_path)}",
+            "stream_url": f"/music/stream/{session_id}/{os.path.basename(file_path)}",
+            "trace_id": result.get('trace_id', ''),
+            "base_resp": result.get('base_resp', {})
+        }
+        
+    except requests.RequestException as e:
+        raise HTTPException(status_code=500, detail=f"网络请求错误: {str(e)}")
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"处理错误: {str(e)}")
+
+@router.get("/download/{session_id}/{filename}")
+async def download_music(session_id: str, filename: str):
+    temp_base = os.getenv("TMPDIR", "/tmp")
+    file_path = os.path.join(temp_base, session_id, filename)
+    if os.path.exists(file_path):
+        return FileResponse(file_path, media_type="audio/mpeg", filename=filename)
+    else:
+        raise HTTPException(status_code=404, detail="文件不存在或已过期")
+
+@router.get("/stream/{session_id}/{filename}")
+async def stream_music(session_id: str, filename: str):
+    """流式播放音频文件"""
+    temp_base = os.getenv("TMPDIR", "/tmp")
+    file_path = os.path.join(temp_base, session_id, filename)
+    if os.path.exists(file_path):
+        return FileResponse(
+            file_path, 
+            media_type="audio/mpeg",
+            headers={
+                "Accept-Ranges": "bytes",
+                "Content-Disposition": "inline"
+            }
+        )
+    else:
+        raise HTTPException(status_code=404, detail="文件不存在或已过期")

app/routes/vlm.py

@@ -0,0 +1,117 @@
+from fastapi import APIRouter, HTTPException, Request, Form, File, UploadFile
+from fastapi.responses import HTMLResponse
+from fastapi.templating import Jinja2Templates
+import base64
+import requests
+import os
+from utils.rate_limiter import check_rate_limit
+from utils.cleanup import create_user_session_dir
+
+router = APIRouter()
+templates = Jinja2Templates(directory="templates")
+
+@router.get("/", response_class=HTMLResponse)
+async def vlm_page(request: Request):
+    return templates.TemplateResponse("vlm.html", {"request": request})
+
+@router.post("/analyze")
+async def analyze_image(
+    request: Request,
+    api_key: str = Form(...),
+    question: str = Form(...),
+    image_url: str = Form(None),
+    image_file: UploadFile = File(None)
+):
+    # 限流检查
+    check_rate_limit(request, max_requests=10, window_seconds=300)  # 5分钟10次
+    
+    try:
+        # 处理图像输入
+        image_content = None
+        
+        if image_file:
+            # 上传文件处理
+            session_dir, session_id = create_user_session_dir()
+            file_path = os.path.join(session_dir, image_file.filename)
+            
+            content = await image_file.read()
+            with open(file_path, "wb") as f:
+                f.write(content)
+            
+            # 转换为base64
+            image_data = base64.b64encode(content).decode('utf-8')
+            image_content = {
+                "type": "image_url",
+                "image_url": {
+                    "url": f"data:image/{image_file.content_type.split('/')[-1]};base64,{image_data}"
+                }
+            }
+        elif image_url:
+            # URL形式
+            image_content = {
+                "type": "image_url",
+                "image_url": {
+                    "url": image_url
+                }
+            }
+        else:
+            raise HTTPException(status_code=400, detail="请提供图片URL或上传图片文件")
+        
+        # 构建请求
+        url = "https://api.minimaxi.com/v1/chat/completions"
+        
+        headers = {
+            'Authorization': 'Bearer ' + api_key,
+            'Content-Type': 'application/json'
+        }
+        
+        messages = [
+            {
+                "role": "system",
+                "content": "MM智能助理是一款由MiniMax自研的，没有调用其他产品的接口的大型语言模型。MiniMax是一家中国科技公司，一直致力于进行大模型相关的研究。"
+            },
+            {
+                "role": "user",
+                "name": "用户",
+                "content": [
+                    {
+                        "type": "text",
+                        "text": question
+                    },
+                    image_content
+                ]
+            }
+        ]
+        
+        payload = {
+            "model": "MiniMax-Text-01",
+            "messages": messages,
+            "max_tokens": 4096
+        }
+        
+        response = requests.post(url, headers=headers, json=payload)
+        
+        # 获取 trace_id
+        trace_id = response.headers.get('Trace-ID', '')
+        print("Trace-ID:", trace_id)
+        
+        if response.status_code != 200:
+            raise HTTPException(status_code=response.status_code, detail="API调用失败")
+        
+        result = response.json()
+        
+        if 'choices' not in result or not result['choices']:
+            raise HTTPException(status_code=400, detail="API返回数据格式错误")
+        
+        return {
+            "status": "success",
+            "message": "图像分析完成",
+            "response": result['choices'][0]['message']['content'],
+            "usage": result.get('usage', {}),
+            "trace_id": trace_id
+        }
+        
+    except requests.RequestException as e:
+        raise HTTPException(status_code=500, detail=f"网络请求错误: {str(e)}")
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"处理错误: {str(e)}")

app/routes/voice_design.py

@@ -0,0 +1,118 @@
+from fastapi import APIRouter, HTTPException, Request, Form
+from fastapi.responses import HTMLResponse, FileResponse
+from fastapi.templating import Jinja2Templates
+import requests
+import json
+import base64
+import time
+import os
+from utils.rate_limiter import check_rate_limit
+from utils.cleanup import create_user_session_dir
+
+router = APIRouter()
+templates = Jinja2Templates(directory="templates")
+
+def audio_save_from_hex(audio_hex: str, session_dir: str) -> str:
+    """从hex编码保存音频文件"""
+    # 转换hex为bytes
+    audio_bytes = bytes.fromhex(audio_hex)
+    
+    # 保存文件
+    timestamp = int(time.time())
+    file_name = f'voice_design_{timestamp}.mp3'
+    file_path = os.path.join(session_dir, file_name)
+    
+    with open(file_path, 'wb') as file:
+        file.write(audio_bytes)
+    
+    return file_path
+
+@router.get("/", response_class=HTMLResponse)
+async def voice_design_page(request: Request):
+    return templates.TemplateResponse("voice_design.html", {"request": request})
+
+@router.post("/design")
+async def design_voice(
+    request: Request,
+    api_key: str = Form(...),
+    prompt: str = Form(...),
+    preview_text: str = Form(...)
+):
+    # 限流检查
+    check_rate_limit(request, max_requests=5, window_seconds=300)  # 5分钟5次
+    
+    # 创建用户会话目录
+    session_dir, session_id = create_user_session_dir()
+    
+    try:
+        url = "https://api.minimaxi.com/v1/voice_design"
+        
+        payload = {
+            "prompt": prompt,
+            "preview_text": preview_text
+        }
+        
+        headers = {
+            'Content-Type': 'application/json',
+            'Authorization': f'Bearer {api_key}',
+        }
+        
+        response = requests.post(url, headers=headers, json=payload)
+        
+        # 获取 trace_id
+        trace_id = response.headers.get('Trace-ID', '')
+        
+        if response.status_code != 200:
+            raise HTTPException(status_code=response.status_code, detail="API调用失败")
+        
+        result = response.json()
+        
+        # 检查返回格式并处理trial_audio
+        if 'trial_audio' not in result:
+            raise HTTPException(status_code=400, detail="API返回数据格式错误：缺少trial_audio")
+        
+        # 处理音频数据
+        trial_audio_hex = result['trial_audio']
+        file_path = audio_save_from_hex(trial_audio_hex, session_dir)
+        
+        return {
+            "status": "success",
+            "message": "语音设计完成",
+            "voice_id": result.get('voice_id', ''),
+            "file_url": f"/voice-design/download/{session_id}/{os.path.basename(file_path)}",
+            "stream_url": f"/voice-design/stream/{session_id}/{os.path.basename(file_path)}",
+            "base_resp": result.get('base_resp', {}),
+            "trace_id": trace_id
+        }
+        
+    except requests.RequestException as e:
+        raise HTTPException(status_code=500, detail=f"网络请求错误: {str(e)}")
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"处理错误: {str(e)}")
+
+@router.get("/download/{session_id}/{filename}")
+async def download_voice(session_id: str, filename: str):
+    """下载语音文件"""
+    temp_base = os.getenv("TMPDIR", "/tmp")
+    file_path = os.path.join(temp_base, session_id, filename)
+    if os.path.exists(file_path):
+        return FileResponse(file_path, media_type="audio/mpeg", filename=filename)
+    else:
+        raise HTTPException(status_code=404, detail="文件不存在或已过期")
+
+@router.get("/stream/{session_id}/{filename}")
+async def stream_voice(session_id: str, filename: str):
+    """流式播放语音文件"""
+    temp_base = os.getenv("TMPDIR", "/tmp")
+    file_path = os.path.join(temp_base, session_id, filename)
+    if os.path.exists(file_path):
+        return FileResponse(
+            file_path, 
+            media_type="audio/mpeg",
+            headers={
+                "Accept-Ranges": "bytes",
+                "Content-Disposition": "inline"
+            }
+        )
+    else:
+        raise HTTPException(status_code=404, detail="文件不存在或已过期")

app/templates/admin.html

@@ -0,0 +1,77 @@
+{% extends "base.html" %}
+
+{% block title %}监控面板 - MiniMax Tools{% endblock %}
+
+{% block content %}
+<h2>📊 监控面板</h2>
+<p>查看系统使用统计和性能指标</p>
+
+<div style="display: grid; grid-template-columns: repeat(auto-fit, minmax(200px, 1fr)); gap: 20px; margin-bottom: 30px;">
+    <div style="background: #e3f2fd; padding: 20px; border-radius: 8px; text-align: center;">
+        <h3 style="margin: 0; color: #1976d2;">{{ stats.total_calls }}</h3>
+        <p style="margin: 5px 0 0 0; color: #666;">总调用次数</p>
+    </div>
+    
+    <div style="background: #e8f5e8; padding: 20px; border-radius: 8px; text-align: center;">
+        <h3 style="margin: 0; color: #388e3c;">{{ stats.calls_24h }}</h3>
+        <p style="margin: 5px 0 0 0; color: #666;">24小时调用</p>
+    </div>
+    
+    <div style="background: #fff3e0; padding: 20px; border-radius: 8px; text-align: center;">
+        <h3 style="margin: 0; color: #f57c00;">{{ stats.error_count }}</h3>
+        <p style="margin: 5px 0 0 0; color: #666;">错误次数</p>
+    </div>
+    
+    <div style="background: #fce4ec; padding: 20px; border-radius: 8px; text-align: center;">
+        <h3 style="margin: 0; color: #c2185b;">{{ stats.error_rate }}%</h3>
+        <p style="margin: 5px 0 0 0; color: #666;">错误率</p>
+    </div>
+</div>
+
+<div style="background: white; padding: 20px; border-radius: 8px; border: 1px solid #ddd;">
+    <h3>各端点使用统计 (24小时)</h3>
+    {% if stats.endpoint_stats %}
+    <table style="width: 100%; border-collapse: collapse; margin-top: 15px;">
+        <thead>
+            <tr style="background: #f8f9fa;">
+                <th style="padding: 12px; text-align: left; border-bottom: 1px solid #ddd;">端点</th>
+                <th style="padding: 12px; text-align: right; border-bottom: 1px solid #ddd;">调用次数</th>
+                <th style="padding: 12px; text-align: right; border-bottom: 1px solid #ddd;">平均响应时间(s)</th>
+            </tr>
+        </thead>
+        <tbody>
+            {% for endpoint, count, avg_time in stats.endpoint_stats %}
+            <tr>
+                <td style="padding: 10px; border-bottom: 1px solid #eee;">{{ endpoint }}</td>
+                <td style="padding: 10px; text-align: right; border-bottom: 1px solid #eee;">{{ count }}</td>
+                <td style="padding: 10px; text-align: right; border-bottom: 1px solid #eee;">{{ "%.3f"|format(avg_time) }}</td>
+            </tr>
+            {% endfor %}
+        </tbody>
+    </table>
+    {% else %}
+    <p style="color: #666; margin-top: 15px;">暂无数据</p>
+    {% endif %}
+</div>
+
+<div style="margin-top: 20px; padding: 15px; background: #f8f9fa; border-radius: 8px;">
+    <h4>系统信息</h4>
+    <ul style="margin: 10px 0 0 20px;">
+        <li>数据自动清理：每15分钟清理过期文件</li>
+        <li>限流策略：各功能模块独立限流</li>
+        <li>数据保留：用户文件1小时后自动删除</li>
+        <li>监控数据：永久保存API调用统计</li>
+    </ul>
+</div>
+
+<div style="text-align: center; margin-top: 30px;">
+    <button onclick="location.reload()" style="background: #28a745;">刷新数据</button>
+</div>
+
+<script>
+// 每30秒自动刷新数据
+setInterval(function() {
+    location.reload();
+}, 30000);
+</script>
+{% endblock %}

app/templates/base.html

@@ -0,0 +1,178 @@
+<!DOCTYPE html>
+<html lang="zh-CN">
+<head>
+    <meta charset="UTF-8">
+    <meta name="viewport" content="width=device-width, initial-scale=1.0">
+    <title>{% block title %}MiniMax Tools{% endblock %}</title>
+    <style>
+        * {
+            margin: 0;
+            padding: 0;
+            box-sizing: border-box;
+        }
+        
+        body {
+            font-family: -apple-system, BlinkMacSystemFont, "Segoe UI", Roboto, sans-serif;
+            line-height: 1.6;
+            color: #333;
+            background-color: #f5f5f5;
+        }
+        
+        .container {
+            max-width: 800px;
+            margin: 0 auto;
+            padding: 20px;
+        }
+        
+        .header {
+            background: white;
+            padding: 20px;
+            border-radius: 8px;
+            margin-bottom: 20px;
+            box-shadow: 0 2px 4px rgba(0,0,0,0.1);
+        }
+        
+        .nav {
+            display: flex;
+            gap: 15px;
+            margin-top: 15px;
+        }
+        
+        .nav a {
+            color: #007bff;
+            text-decoration: none;
+            padding: 8px 16px;
+            border-radius: 4px;
+            transition: background-color 0.2s;
+        }
+        
+        .nav a:hover {
+            background-color: #e9ecef;
+        }
+        
+        .content {
+            background: white;
+            padding: 30px;
+            border-radius: 8px;
+            box-shadow: 0 2px 4px rgba(0,0,0,0.1);
+        }
+        
+        .form-group {
+            margin-bottom: 20px;
+        }
+        
+        label {
+            display: block;
+            margin-bottom: 5px;
+            font-weight: 500;
+        }
+        
+        input, textarea, select {
+            width: 100%;
+            padding: 10px;
+            border: 1px solid #ddd;
+            border-radius: 4px;
+            font-size: 14px;
+        }
+        
+        textarea {
+            height: 100px;
+            resize: vertical;
+        }
+        
+        button {
+            background: #007bff;
+            color: white;
+            border: none;
+            padding: 12px 24px;
+            border-radius: 4px;
+            cursor: pointer;
+            font-size: 16px;
+            transition: background-color 0.2s;
+        }
+        
+        button:hover {
+            background: #0056b3;
+        }
+        
+        button:disabled {
+            background: #6c757d;
+            cursor: not-allowed;
+        }
+        
+        .result {
+            margin-top: 20px;
+            padding: 15px;
+            border-radius: 4px;
+            background: #d4edda;
+            border: 1px solid #c3e6cb;
+        }
+        
+        .error {
+            background: #f8d7da;
+            border: 1px solid #f5c6cb;
+            color: #721c24;
+        }
+        
+        .loading {
+            display: none;
+            text-align: center;
+            margin: 20px 0;
+        }
+        
+        .spinner {
+            border: 3px solid #f3f3f3;
+            border-top: 3px solid #007bff;
+            border-radius: 50%;
+            width: 30px;
+            height: 30px;
+            animation: spin 1s linear infinite;
+            margin: 0 auto;
+        }
+        
+        @keyframes spin {
+            0% { transform: rotate(0deg); }
+            100% { transform: rotate(360deg); }
+        }
+    </style>
+</head>
+<body>
+    <div class="container">
+        <div class="header">
+            <h1>MiniMax Tools</h1>
+            <nav class="nav">
+                <a href="/">首页</a>
+                <a href="/music">音乐生成</a>
+                <a href="/image-generation">图片生成</a>
+                <a href="/vlm">图像分析</a>
+                <a href="/voice-design">语音设计</a>
+            </nav>
+        </div>
+        
+        <div class="content">
+            {% block content %}{% endblock %}
+        </div>
+    </div>
+    
+    <script>
+        function showLoading() {
+            document.querySelector('.loading').style.display = 'block';
+            document.querySelector('button[type="submit"]').disabled = true;
+        }
+        
+        function hideLoading() {
+            document.querySelector('.loading').style.display = 'none';
+            document.querySelector('button[type="submit"]').disabled = false;
+        }
+        
+        function showResult(message, isError = false) {
+            const resultDiv = document.getElementById('result');
+            if (resultDiv) {
+                resultDiv.className = isError ? 'result error' : 'result';
+                resultDiv.textContent = message;
+                resultDiv.style.display = 'block';
+            }
+        }
+    </script>
+</body>
+</html>

app/templates/image_generation.html

@@ -0,0 +1,160 @@
+{% extends "base.html" %}
+
+{% block title %}图片生成 - MiniMax Tools{% endblock %}
+
+{% block content %}
+<h2>🖼️ 图片生成</h2>
+<p>使用 MiniMax API 根据文本描述生成高质量图片</p>
+
+<form id="imageForm" onsubmit="generateImage(event)">
+    <div class="form-group">
+        <label for="api_key">API Key *</label>
+        <input type="password" id="api_key" name="api_key" required 
+               placeholder="请输入您的 MiniMax API Key">
+    </div>
+    
+    <div class="form-group">
+        <label for="prompt">图片描述 *</label>
+        <textarea id="prompt" name="prompt" required
+                  placeholder="详细描述您想要生成的图片，如风格、内容、场景等">men Dressing in white t shirt, full-body stand front view image :25, outdoor, Venice beach sign, full-body image, Los Angeles, Fashion photography of 90s, documentary, Film grain, photorealistic</textarea>
+    </div>
+    
+    <div class="form-group">
+        <label for="aspect_ratio">宽高比</label>
+        <select id="aspect_ratio" name="aspect_ratio">
+            <option value="1:1" selected>1:1 (正方形)</option>
+            <option value="16:9">16:9 (宽屏)</option>
+            <option value="9:16">9:16 (竖屏)</option>
+            <option value="4:3">4:3 (标准)</option>
+            <option value="3:2">3:2 (经典)</option>
+            <option value="2:3">2:3 (竖版经典)</option>
+            <option value="3:4">3:4 (竖版标准)</option>
+            <option value="21:9">21:9 (超宽屏)</option>
+        </select>
+    </div>
+    
+    <div class="form-group">
+        <label for="n">生成数量</label>
+        <select id="n" name="n">
+            <option value="1">1张</option>
+            <option value="2">2张</option>
+            <option value="3" selected>3张</option>
+            <option value="4">4张</option>
+        </select>
+    </div>
+    
+    <div class="form-group">
+        <label>
+            <input type="checkbox" id="prompt_optimizer" name="prompt_optimizer" checked>
+            启用提示词优化
+        </label>
+        <small style="color: #666; display: block; margin-top: 5px;">
+            自动优化您的提示词以获得更好的生成效果
+        </small>
+    </div>
+    
+    <button type="submit">生成图片</button>
+</form>
+
+<div class="loading">
+    <div class="spinner"></div>
+    <p>正在生成图片，请稍候...</p>
+</div>
+
+<div id="result" style="display: none;"></div>
+
+<script>
+async function generateImage(event) {
+    event.preventDefault();
+    showLoading();
+    
+    const formData = new FormData(event.target);
+    
+    try {
+        const response = await fetch('/image-generation/generate', {
+            method: 'POST',
+            body: formData
+        });
+        
+        const result = await response.json();
+        
+        if (response.ok) {
+            const resultDiv = document.getElementById('result');
+            resultDiv.className = 'result';
+            
+            let imagesHtml = '';
+            if (result.image_urls && result.image_urls.length > 0) {
+                imagesHtml = result.image_urls.map((url, index) => `
+                    <div style="margin-bottom: 15px;">
+                        <p style="font-weight: bold; margin-bottom: 8px;">图片 ${index + 1}:</p>
+                        <img src="${url}" alt="生成的图片 ${index + 1}" 
+                             style="max-width: 100%; height: auto; border-radius: 8px; box-shadow: 0 2px 8px rgba(0,0,0,0.1);">
+                        <div style="margin-top: 8px;">
+                            <a href="${url}" target="_blank" 
+                               style="color: #007bff; text-decoration: none; background: #e9ecef; padding: 6px 12px; border-radius: 4px; font-size: 14px; margin-right: 10px;">
+                                🔗 查看原图
+                            </a>
+                            <button onclick="downloadImage('${url}', 'generated_image_${index + 1}.jpg')" 
+                                    style="background: #28a745; color: white; border: none; padding: 6px 12px; border-radius: 4px; cursor: pointer; font-size: 14px;">
+                                📥 下载图片
+                            </button>
+                        </div>
+                    </div>
+                `).join('');
+            }
+            
+            resultDiv.innerHTML = `
+                <p style="color: green; font-weight: bold;">✅ 图片生成成功！</p>
+                
+                ${result.id ? `
+                <div style="background: #e7f3ff; padding: 12px; border-radius: 6px; margin: 15px 0; border-left: 4px solid #007bff;">
+                    <p style="margin: 0; font-weight: bold; color: #007bff;">🆔 生成ID</p>
+                    <p style="margin: 5px 0 0 0; font-family: monospace; font-size: 14px; background: white; padding: 8px; border-radius: 4px;">${result.id}</p>
+                </div>
+                ` : ''}
+                
+                <div style="background: #f8f9fa; padding: 15px; border-radius: 8px; margin: 15px 0;">
+                    <p style="margin-bottom: 15px;"><strong>🖼️ 生成结果：</strong></p>
+                    ${imagesHtml}
+                </div>
+                
+                ${result.metadata ? `
+                <div style="background: #d4edda; padding: 10px; border-radius: 4px; margin: 10px 0; border: 1px solid #c3e6cb;">
+                    <p style="margin: 0; color: #155724; font-size: 14px;">
+                        📊 生成统计: 成功 ${result.metadata.success_count || 0} 张，失败 ${result.metadata.failed_count || 0} 张
+                    </p>
+                </div>
+                ` : ''}
+                
+                ${result.base_resp && result.base_resp.status_code === 0 ? `
+                <div style="background: #d4edda; padding: 10px; border-radius: 4px; margin: 10px 0; border: 1px solid #c3e6cb;">
+                    <p style="margin: 0; color: #155724; font-size: 14px;">
+                        ✅ API状态: ${result.base_resp.status_msg || 'success'}
+                    </p>
+                </div>
+                ` : ''}
+                
+                ${result.trace_id ? `<p style="font-size: 12px; color: #6c757d;">追踪ID: ${result.trace_id}</p>` : ''}
+            `;
+            resultDiv.style.display = 'block';
+        } else {
+            showResult(`错误: ${result.detail}`, true);
+        }
+    } catch (error) {
+        showResult(`网络错误: ${error.message}`, true);
+    } finally {
+        hideLoading();
+    }
+}
+
+function downloadImage(url, filename) {
+    const link = document.createElement('a');
+    link.href = url;
+    link.download = filename;
+    link.target = '_blank';
+    document.body.appendChild(link);
+    link.click();
+    document.body.removeChild(link);
+}
+</script>
+{% endblock %}

app/templates/index.html

@@ -0,0 +1,47 @@
+{% extends "base.html" %}
+
+{% block title %}MiniMax Tools - 首页{% endblock %}
+
+{% block content %}
+<h2>欢迎使用 MiniMax Tools</h2>
+<p>这是一个基于 MiniMax API 的工具集合，包含以下功能：</p>
+
+<div style="display: grid; grid-template-columns: repeat(auto-fit, minmax(300px, 1fr)); gap: 20px; margin-top: 30px;">
+    <div style="border: 1px solid #ddd; padding: 20px; border-radius: 8px;">
+        <h3>🎵 音乐生成</h3>
+        <p>基于文本提示和歌词生成音乐</p>
+        <a href="/music" style="color: #007bff; text-decoration: none;">开始使用 →</a>
+    </div>
+    
+    <div style="border: 1px solid #ddd; padding: 20px; border-radius: 8px;">
+        <h3>🖼️ 图片生成</h3>
+        <p>基于文本描述生成高质量图片</p>
+        <a href="/image-generation" style="color: #007bff; text-decoration: none;">开始使用 →</a>
+    </div>
+    
+    <div style="border: 1px solid #ddd; padding: 20px; border-radius: 8px;">
+        <h3>👁️ 图像分析</h3>
+        <p>使用视觉语言模型分析图片内容</p>
+        <a href="/vlm" style="color: #007bff; text-decoration: none;">开始使用 →</a>
+    </div>
+    
+
+    <div style="border: 1px solid #ddd; padding: 20px; border-radius: 8px;">
+        <h3>🔊 语音设计</h3>
+        <p>根据描述设计定制化语音</p>
+        <a href="/voice-design" style="color: #007bff; text-decoration: none;">开始使用 →</a>
+    </div>
+    
+
+</div>
+
+<div style="margin-top: 40px; padding: 20px; background: #e3f2fd; border-radius: 8px;">
+    <h3>使用说明</h3>
+    <ul style="margin-left: 20px; margin-top: 10px;">
+        <li>所有功能都需要您提供自己的 MiniMax API Key</li>
+        <li>用户数据会在使用后自动清理，无长期存储</li>
+        <li>本工具仅供测试，随时可能停服更新，如需商用请自行部署</li>
+        <li>开源版本：<a href="https://github.com/backearth1/minimax-tools.git" target="_blank" style="color: #007bff;">https://github.com/backearth1/minimax-tools.git</a></li>
+    </ul>
+</div>
+{% endblock %}

app/templates/music.html

@@ -0,0 +1,96 @@
+{% extends "base.html" %}
+
+{% block title %}音乐生成 - MiniMax Tools{% endblock %}
+
+{% block content %}
+<h2>🎵 音乐生成</h2>
+<p>使用 MiniMax API 根据提示词和歌词生成音乐</p>
+
+<form id="musicForm" onsubmit="generateMusic(event)">
+    <div class="form-group">
+        <label for="api_key">API Key *</label>
+        <input type="password" id="api_key" name="api_key" required 
+               placeholder="请输入您的 MiniMax API Key">
+    </div>
+    
+    <div class="form-group">
+        <label for="prompt">音乐风格描述 *</label>
+        <input type="text" id="prompt" name="prompt" required
+               placeholder="例如：独立民谣,忧郁,内省,渴望,独自漫步,咖啡馆"
+               value="独立民谣,忧郁,内省,渴望,独自漫步,咖啡馆">
+    </div>
+    
+    <div class="form-group">
+        <label for="lyrics">歌词 *</label>
+        <textarea id="lyrics" name="lyrics" required 
+                  placeholder="请输入歌词，支持 [verse]、[chorus] 等标记">[verse]
+街灯微亮晚风轻抚
+影子拉长独自漫步
+旧外套裹着深深忧郁
+不知去向渴望何处
+[chorus]
+推开木门香气弥漫
+熟悉的角落陌生人看</textarea>
+    </div>
+    
+    <button type="submit">生成音乐</button>
+</form>
+
+<div class="loading">
+    <div class="spinner"></div>
+    <p>正在生成音乐，请稍候...</p>
+</div>
+
+<div id="result" style="display: none;"></div>
+
+<script>
+async function generateMusic(event) {
+    event.preventDefault();
+    showLoading();
+    
+    const formData = new FormData(event.target);
+    
+    try {
+        const response = await fetch('/music/generate', {
+            method: 'POST',
+            body: formData
+        });
+        
+        const result = await response.json();
+        
+        if (response.ok) {
+            showResult(`音乐生成成功！`, false);
+            
+            // 显示播放器和下载链接
+            const resultDiv = document.getElementById('result');
+            resultDiv.innerHTML = `
+                <p style="color: green; font-weight: bold;">✅ 音乐生成成功！</p>
+                
+                <div style="background: #f8f9fa; padding: 15px; border-radius: 8px; margin: 15px 0;">
+                    <p style="margin-bottom: 10px;"><strong>🎵 在线播放：</strong></p>
+                    <audio controls style="width: 100%; margin-bottom: 10px;">
+                        <source src="${result.stream_url}" type="audio/mpeg">
+                        您的浏览器不支持音频播放。
+                    </audio>
+                    
+                    <div style="display: flex; gap: 10px; align-items: center;">
+                        <a href="${result.file_url}" download style="color: #007bff; text-decoration: none; background: #e9ecef; padding: 8px 16px; border-radius: 4px; font-size: 14px;">
+                            📥 下载音乐文件
+                        </a>
+                        <span style="color: #6c757d; font-size: 12px;">文件将在1小时后自动删除</span>
+                    </div>
+                </div>
+                
+                ${result.trace_id ? `<p style="font-size: 12px; color: #6c757d;">追踪ID: ${result.trace_id}</p>` : ''}
+            `;
+        } else {
+            showResult(`错误: ${result.detail}`, true);
+        }
+    } catch (error) {
+        showResult(`网络错误: ${error.message}`, true);
+    } finally {
+        hideLoading();
+    }
+}
+</script>
+{% endblock %}

app/templates/vlm.html

@@ -0,0 +1,111 @@
+{% extends "base.html" %}
+
+{% block title %}图像分析 - MiniMax Tools{% endblock %}
+
+{% block content %}
+<h2>👁️ 图像分析</h2>
+<p>使用 MiniMax 视觉语言模型分析图片内容</p>
+
+<form id="vlmForm" onsubmit="analyzeImage(event)">
+    <div class="form-group">
+        <label for="api_key">API Key *</label>
+        <input type="password" id="api_key" name="api_key" required 
+               placeholder="请输入您的 MiniMax API Key">
+    </div>
+    
+    <div class="form-group">
+        <label for="question">问题 *</label>
+        <input type="text" id="question" name="question" required
+               placeholder="请描述您想了解图片的哪些内容"
+               value="这个图代表的是什么呢">
+    </div>
+    
+    <div style="display: grid; grid-template-columns: 1fr 1fr; gap: 20px; margin-bottom: 20px;">
+        <div class="form-group">
+            <label for="image_url">图片URL</label>
+            <input type="url" id="image_url" name="image_url"
+                   placeholder="https://example.com/image.jpg">
+        </div>
+        
+        <div class="form-group">
+            <label for="image_file">或上传图片</label>
+            <input type="file" id="image_file" name="image_file" 
+                   accept="image/*">
+        </div>
+    </div>
+    
+    <p style="font-size: 14px; color: #666; margin-bottom: 20px;">
+        * 请提供图片URL或上传图片文件（二选一）
+    </p>
+    
+    <button type="submit">分析图像</button>
+</form>
+
+<div class="loading">
+    <div class="spinner"></div>
+    <p>正在分析图像，请稍候...</p>
+</div>
+
+<div id="result" style="display: none;"></div>
+
+<script>
+async function analyzeImage(event) {
+    event.preventDefault();
+    showLoading();
+    
+    const formData = new FormData(event.target);
+    const imageUrl = formData.get('image_url');
+    const imageFile = formData.get('image_file');
+    
+    // 验证输入
+    if (!imageUrl && (!imageFile || imageFile.size === 0)) {
+        showResult('请提供图片URL或上传图片文件', true);
+        hideLoading();
+        return;
+    }
+    
+    try {
+        const response = await fetch('/vlm/analyze', {
+            method: 'POST',
+            body: formData
+        });
+        
+        const result = await response.json();
+        
+        if (response.ok) {
+            const resultDiv = document.getElementById('result');
+            resultDiv.className = 'result';
+            resultDiv.innerHTML = `
+                <p style="color: green; font-weight: bold;">✅ 图像分析完成！</p>
+                <div style="background: #f8f9fa; padding: 15px; border-radius: 4px; margin-top: 10px;">
+                    <strong>分析结果：</strong>
+                    <p style="margin-top: 8px; line-height: 1.6;">${result.response}</p>
+                </div>
+                ${result.usage ? `<p><small>使用情况: ${JSON.stringify(result.usage)}</small></p>` : ''}
+                ${result.trace_id ? `<p><small>追踪ID: ${result.trace_id}</small></p>` : ''}
+            `;
+            resultDiv.style.display = 'block';
+        } else {
+            showResult(`错误: ${result.detail}`, true);
+        }
+    } catch (error) {
+        showResult(`网络错误: ${error.message}`, true);
+    } finally {
+        hideLoading();
+    }
+}
+
+// 当选择文件时清空URL，反之亦然
+document.getElementById('image_file').addEventListener('change', function() {
+    if (this.files.length > 0) {
+        document.getElementById('image_url').value = '';
+    }
+});
+
+document.getElementById('image_url').addEventListener('input', function() {
+    if (this.value) {
+        document.getElementById('image_file').value = '';
+    }
+});
+</script>
+{% endblock %}

app/templates/voice_design.html

@@ -0,0 +1,106 @@
+{% extends "base.html" %}
+
+{% block title %}语音设计 - MiniMax Tools{% endblock %}
+
+{% block content %}
+<h2>🔊 语音设计</h2>
+<p>根据描述设计个性化语音，打造独特的语音风格</p>
+
+<form id="voiceDesignForm" onsubmit="designVoice(event)">
+    <div class="form-group">
+        <label for="api_key">API Key *</label>
+        <input type="password" id="api_key" name="api_key" required 
+               placeholder="请输入您的 MiniMax API Key">
+    </div>
+    
+    <div class="form-group">
+        <label for="prompt">语音风格描述 *</label>
+        <textarea id="prompt" name="prompt" required
+                  placeholder="详细描述您想要的语音特征，如音色、语速、情感等">讲述悬疑故事的播音员，声音低沉富有磁性，语速时快时慢，营造紧张神秘的氛围。</textarea>
+    </div>
+    
+    <div class="form-group">
+        <label for="preview_text">预览文本 *</label>
+        <textarea id="preview_text" name="preview_text" required
+                  placeholder="用于预览语音效果的文本内容">夜深了，古屋里只有他一人。窗外传来若有若无的脚步声，他屏住呼吸，慢慢地，慢慢地，走向那扇吱呀作响的门……</textarea>
+    </div>
+    
+    <button type="submit">设计语音</button>
+</form>
+
+<div class="loading">
+    <div class="spinner"></div>
+    <p>正在设计语音，请稍候...</p>
+</div>
+
+<div id="result" style="display: none;"></div>
+
+<script>
+async function designVoice(event) {
+    event.preventDefault();
+    showLoading();
+    
+    const formData = new FormData(event.target);
+    
+    try {
+        const response = await fetch('/voice-design/design', {
+            method: 'POST',
+            body: formData
+        });
+        
+        const result = await response.json();
+        
+        if (response.ok) {
+            const resultDiv = document.getElementById('result');
+            resultDiv.className = 'result';
+            resultDiv.innerHTML = `
+                <p style="color: green; font-weight: bold;">✅ 语音设计完成！</p>
+                
+                ${result.voice_id ? `
+                <div style="background: #e7f3ff; padding: 12px; border-radius: 6px; margin: 15px 0; border-left: 4px solid #007bff;">
+                    <p style="margin: 0; font-weight: bold; color: #007bff;">🎤 Voice ID</p>
+                    <p style="margin: 5px 0 0 0; font-family: monospace; font-size: 14px; background: white; padding: 8px; border-radius: 4px;">${result.voice_id}</p>
+                </div>
+                ` : ''}
+                
+                <div style="background: #f8f9fa; padding: 15px; border-radius: 8px; margin: 15px 0;">
+                    <p style="margin-bottom: 10px;"><strong>🔊 试听预览：</strong></p>
+                    <audio controls style="width: 100%; margin-bottom: 10px;">
+                        <source src="${result.stream_url}" type="audio/mpeg">
+                        您的浏览器不支持音频播放。
+                    </audio>
+                    
+                    <div style="display: flex; gap: 10px; align-items: center;">
+                        <a href="${result.file_url}" download style="color: #007bff; text-decoration: none; background: #e9ecef; padding: 8px 16px; border-radius: 4px; font-size: 14px;">
+                            📥 下载音频文件
+                        </a>
+                        <span style="color: #6c757d; font-size: 12px;">文件将在1小时后自动删除</span>
+                    </div>
+                </div>
+                
+                ${result.base_resp && result.base_resp.status_code === 0 ? `
+                <div style="background: #d4edda; padding: 10px; border-radius: 4px; margin: 10px 0; border: 1px solid #c3e6cb;">
+                    <p style="margin: 0; color: #155724; font-size: 14px;">
+                        ✅ API状态: ${result.base_resp.status_msg || 'success'}
+                    </p>
+                </div>
+                ` : ''}
+                
+                ${result.trace_id ? `<p style="font-size: 12px; color: #6c757d;">追踪ID: ${result.trace_id}</p>` : ''}
+                
+                <p style="margin-top: 15px; color: #666; font-size: 14px;">
+                    💡 语音设计完成，您可以使用生成的 Voice ID 进行语音合成
+                </p>
+            `;
+            resultDiv.style.display = 'block';
+        } else {
+            showResult(`错误: ${result.detail}`, true);
+        }
+    } catch (error) {
+        showResult(`网络错误: ${error.message}`, true);
+    } finally {
+        hideLoading();
+    }
+}
+</script>
+{% endblock %}

app/utils/__init__.py

@@ -0,0 +1 @@
+# Utils package

app/utils/cleanup.py

@@ -0,0 +1,66 @@
+import os
+import shutil
+import time
+import threading
+from datetime import datetime, timedelta
+import asyncio
+
+def cleanup_user_data(max_age_hours: int = 1):
+    """清理用户临时数据
+    
+    Args:
+        max_age_hours: 文件最大保存时间(小时)
+    """
+    temp_dir = os.getenv("TMPDIR", "/tmp")
+    if not os.path.exists(temp_dir):
+        return
+    
+    cutoff_time = time.time() - (max_age_hours * 3600)
+    cleaned_count = 0
+    
+    try:
+        for item in os.listdir(temp_dir):
+            item_path = os.path.join(temp_dir, item)
+            
+            # 检查文件/目录的修改时间
+            if os.path.getmtime(item_path) < cutoff_time:
+                if os.path.isdir(item_path):
+                    shutil.rmtree(item_path)
+                else:
+                    os.remove(item_path)
+                cleaned_count += 1
+                
+        print(f"[{datetime.now()}] 清理完成: 删除了 {cleaned_count} 个过期文件/目录")
+        
+    except Exception as e:
+        print(f"[{datetime.now()}] 清理任务出错: {e}")
+
+def periodic_cleanup():
+    """定期清理任务"""
+    while True:
+        try:
+            cleanup_user_data()
+            # 清理限流记录
+            from .rate_limiter import cleanup_expired_records
+            cleanup_expired_records()
+            
+            # 每15分钟清理一次
+            time.sleep(900)
+        except Exception as e:
+            print(f"定期清理任务出错: {e}")
+            time.sleep(900)
+
+def start_cleanup_task():
+    """启动清理任务"""
+    cleanup_thread = threading.Thread(target=periodic_cleanup, daemon=True)
+    cleanup_thread.start()
+    print("清理任务已启动")
+
+def create_user_session_dir():
+    """为用户会话创建临时目录"""
+    import uuid
+    session_id = str(uuid.uuid4())
+    temp_base = os.getenv("TMPDIR", "/tmp")
+    session_dir = os.path.join(temp_base, session_id)
+    os.makedirs(session_dir, exist_ok=True)
+    return session_dir, session_id

app/utils/monitor.py

@@ -0,0 +1,106 @@
+import sqlite3
+import time
+from datetime import datetime, timedelta
+from contextlib import contextmanager
+from fastapi import Request, Response
+import os
+
+DB_PATH = os.path.join(os.getenv("TMPDIR", "/tmp"), "monitor.db")
+
+def init_db():
+    """初始化监控数据库"""
+    conn = sqlite3.connect(DB_PATH)
+    cursor = conn.cursor()
+    cursor.execute("""
+        CREATE TABLE IF NOT EXISTS api_calls (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            endpoint TEXT NOT NULL,
+            ip_address TEXT NOT NULL,
+            user_agent TEXT,
+            status_code INTEGER,
+            response_time REAL,
+            timestamp DATETIME DEFAULT CURRENT_TIMESTAMP
+        )
+    """)
+    conn.commit()
+    conn.close()
+
+@contextmanager
+def get_db():
+    """数据库连接上下文管理器"""
+    conn = sqlite3.connect(DB_PATH)
+    try:
+        yield conn
+    finally:
+        conn.close()
+
+def log_api_call(endpoint: str, ip: str, user_agent: str, status_code: int, response_time: float):
+    """记录API调用"""
+    with get_db() as conn:
+        cursor = conn.cursor()
+        cursor.execute("""
+            INSERT INTO api_calls (endpoint, ip_address, user_agent, status_code, response_time)
+            VALUES (?, ?, ?, ?, ?)
+        """, (endpoint, ip, user_agent, status_code, response_time))
+        conn.commit()
+
+def get_stats():
+    """获取统计数据"""
+    with get_db() as conn:
+        cursor = conn.cursor()
+        
+        # 总调用次数
+        cursor.execute("SELECT COUNT(*) FROM api_calls")
+        total_calls = cursor.fetchone()[0]
+        
+        # 24小时内调用次数
+        yesterday = datetime.now() - timedelta(hours=24)
+        cursor.execute("SELECT COUNT(*) FROM api_calls WHERE timestamp > ?", (yesterday,))
+        calls_24h = cursor.fetchone()[0]
+        
+        # 各端点统计
+        cursor.execute("""
+            SELECT endpoint, COUNT(*) as count, AVG(response_time) as avg_time
+            FROM api_calls 
+            WHERE timestamp > ?
+            GROUP BY endpoint
+            ORDER BY count DESC
+        """, (yesterday,))
+        endpoint_stats = cursor.fetchall()
+        
+        # 错误统计
+        cursor.execute("""
+            SELECT COUNT(*) FROM api_calls 
+            WHERE status_code >= 400 AND timestamp > ?
+        """, (yesterday,))
+        error_count = cursor.fetchone()[0]
+        
+        return {
+            "total_calls": total_calls,
+            "calls_24h": calls_24h,
+            "endpoint_stats": endpoint_stats,
+            "error_count": error_count,
+            "error_rate": round(error_count / max(calls_24h, 1) * 100, 2)
+        }
+
+def setup_monitoring(app):
+    """设置监控中间件"""
+    init_db()
+    
+    @app.middleware("http")
+    async def monitor_middleware(request: Request, call_next):
+        start_time = time.time()
+        response = await call_next(request)
+        process_time = time.time() - start_time
+        
+        # 记录API调用
+        log_api_call(
+            endpoint=request.url.path,
+            ip=request.client.host,
+            user_agent=request.headers.get("user-agent", ""),
+            status_code=response.status_code,
+            response_time=process_time
+        )
+        
+        response.headers["X-Process-Time"] = str(process_time)
+        return response

app/utils/rate_limiter.py

@@ -0,0 +1,53 @@
+import time
+from collections import defaultdict
+from fastapi import HTTPException, Request
+import threading
+
+# 内存中的限流计数器
+rate_limit_store = defaultdict(list)
+lock = threading.Lock()
+
+def check_rate_limit(request: Request, max_requests: int = 10, window_seconds: int = 60):
+    """检查限流
+    
+    Args:
+        request: FastAPI请求对象
+        max_requests: 时间窗口内最大请求数
+        window_seconds: 时间窗口(秒)
+    """
+    client_ip = request.client.host
+    current_time = time.time()
+    
+    with lock:
+        # 清理过期记录
+        rate_limit_store[client_ip] = [
+            timestamp for timestamp in rate_limit_store[client_ip]
+            if current_time - timestamp < window_seconds
+        ]
+        
+        # 检查是否超过限制
+        if len(rate_limit_store[client_ip]) >= max_requests:
+            raise HTTPException(
+                status_code=429,
+                detail=f"Rate limit exceeded. Max {max_requests} requests per {window_seconds} seconds."
+            )
+        
+        # 记录当前请求
+        rate_limit_store[client_ip].append(current_time)
+
+def cleanup_expired_records():
+    """清理过期的限流记录"""
+    current_time = time.time()
+    with lock:
+        expired_keys = []
+        for ip, timestamps in rate_limit_store.items():
+            # 保留1小时内的记录
+            recent_timestamps = [t for t in timestamps if current_time - t < 3600]
+            if recent_timestamps:
+                rate_limit_store[ip] = recent_timestamps
+            else:
+                expired_keys.append(ip)
+        
+        # 删除完全过期的IP记录
+        for ip in expired_keys:
+            del rate_limit_store[ip]

requirements.txt

@@ -0,0 +1,8 @@
+fastapi==0.104.1
+uvicorn==0.24.0
+jinja2==3.1.2
+python-multipart==0.0.6
+requests==2.31.0
+aiofiles==23.2.1
+httpx==0.25.2
+pillow==10.1.0