技术方案全景

服务器中转方案：

客户端 → 我的服务器 → OSS

优点：
- 服务器可以对文件做预处理（校验、压缩）
- 可以控制上传权限，更安全
- 上传逻辑集中管理

缺点：
- 服务器带宽是瓶颈（8.7MB 的图片 × 并发上传 = 带宽爆炸）
- 服务器磁盘 I/O 压力大
- 单点故障——服务器挂了就全挂了
- 服务器成本高（需要更大的带宽和磁盘）

客户端直传方案：

客户端 → OSS（服务器只签发上传凭证）

优点：
- 上传流量不经过服务器，节省带宽
- OSS 的上传能力远强于单台服务器（支持分片、断点续传）
- 服务器只做轻量操作（签发凭证），不容易成为瓶颈

缺点：
- 需要设计安全的凭证机制，防止滥用
- 客户端需要集成 OSS SDK
- 服务器无法在上传时预处理

典型实现：

```python
import oss2
import time

def generate_upload_credentials(user_id, file_type):
    """生成临时上传凭证"""
    auth = oss2.StsAuth(
        access_key_id='your_key',
        access_key_secret='your_secret',
        security_token=sts_token
    )
    
    # 生成带签名的上传 URL，15 分钟有效
    bucket = oss2.Bucket(auth, 'oss-cn-beijing.aliyuncs.com', 'my-bucket')
    
    object_key = f'uploads/{user_id}/{uuid.uuid4().hex}.{file_type}'
    
    upload_url = bucket.sign_url('PUT', object_key, 15 * 60)
    
    return {
        'upload_url': upload_url,
        'object_key': object_key,
        'expires_in': 900,
    }

对于图片场景，客户端直传几乎总是更好的选择。 图片文件大，走服务器中转纯属浪费带宽。

我的方案：先审后处理

上传 → 审核 → (通过) → 异步处理 → 存储 → CDN
              → (拒绝) → 删除原图 → 通知用户

原因：

1. 避免资源浪费：如果先处理再审核，违规图片的处理算力白花了。处理 5 种缩略图需要 1~2 秒，如果最终是违规图片，这些算力就浪费了。

2. 避免”违规内容短暂可访问”的问题：如果先处理再审核，在审核完成前，违规图片的缩略图可能已经被 CDN 缓存了。

3. 审核本身很快：云 API 的审核通常在 200ms~1s 内返回结果，不会成为上传流程的瓶颈。

审核通过后的处理流程：

def on_upload_complete(object_key, user_id):
    """图片上传完成后的处理流程"""
    
    # 第一步：审核（同步，快速判断）
    audit_result = content_audit(object_key)
    
    if not audit_result.passed:
        # 审核不通过：删除原图，通知用户
        oss_client.delete_object(object_key)
        notify_user(user_id, "图片内容不符合规范，请修改后重新上传")
        return
    
    # 第二步：审核通过，异步处理
    message_queue.publish({
        'task': 'process_image',
        'object_key': object_key,
        'user_id': user_id,
    })
    
    # 同时更新数据库状态
    db.execute(
        "UPDATE images SET status = 'processing' WHERE object_key = %s",
        (object_key,)
    )


def process_image_async(object_key):
    """异步处理图片"""
    # 下载原图
    image_data = oss_client.get_object(object_key)
    
    # 生成多种尺寸
    thumbnails = generate_thumbnails(image_data)
    
    # 上传缩略图到 OSS
    for size_name, thumb_data in thumbnails.items():
        thumb_key = f'thumbs/{object_key}_{size_name}.webp'
        oss_client.put_object(thumb_key, thumb_data)
    
    # 更新数据库状态
    db.execute(
        "UPDATE images SET status = 'ready', thumbs = %s WHERE object_key = %s",
        (json.dumps(thumbnails), object_key)
    )

极端情况：如果审核漏放了一张违规图片怎么办？

• CDN 层面：支持紧急刷新（purge），可以快速从 CDN 节点删除
• OSS 层面：直接删除源文件，CDN 缓存过期后自动不可访问
• 数据库层面：标记为违规，前端不再展示