Wan2.2-I2V-A14B部署教程：output视频自动上传OSS/MinIO配置方法-编程实验室

Wan2.2-I2V-A14B部署教程：output视频自动上传OSS/MinIO配置方法

1. 镜像概述与环境准备

Wan2.2-I2V-A14B是一款高性能的文生视频模型私有部署镜像，专为RTX 4090D 24GB显存环境优化。本教程将重点介绍如何配置自动上传生成的视频文件到OSS或MinIO对象存储服务。

1.1 硬件与软件要求

显卡：RTX 4090D 24GB显存（必须匹配）
内存：≥120GB
存储：系统盘50GB + 数据盘40GB
软件依赖：
- Python 3.10+
- PyTorch 2.4+
- boto3（AWS SDK）或minio-py（MinIO客户端）

1.2 基础环境检查

在开始配置前，请确保基础服务正常运行：

# 检查GPU驱动版本 nvidia-smi | grep "Driver Version" # 检查CUDA版本 nvcc --version # 检查Python环境 python --version

2. OSS/MinIO存储服务配置

2.1 创建存储桶

无论使用阿里云OSS还是自建MinIO，首先需要创建存储桶：

阿里云OSS：
- 登录OSS控制台
- 创建Bucket，选择与服务器相同地域
- 记录Endpoint、Bucket名称
MinIO：
- 访问MinIO管理界面（通常为http://your-minio-server:9000）
- 创建Bucket
- 记录Endpoint、Bucket名称

2.2 生成访问密钥

两种服务的密钥获取方式：

# 阿里云OSS密钥获取路径： # 控制台 -> 访问控制 -> 用户管理 -> 创建用户 -> 生成AccessKey # MinIO密钥获取路径： # 管理界面 -> 用户管理 -> 创建用户或使用现有用户密钥

3. 自动上传脚本配置

3.1 安装必要依赖

根据选择的存储服务安装对应SDK：

# 阿里云OSS pip install oss2 # MinIO pip install minio

3.2 编写上传脚本

创建upload_to_storage.py脚本：

import os from datetime import datetime import argparse # 根据存储类型选择导入模块 STORAGE_TYPE = "minio" # 可改为"oss" if STORAGE_TYPE == "oss": import oss2 elif STORAGE_TYPE == "minio": from minio import Minio from minio.error import S3Error def upload_to_oss(file_path, endpoint, bucket_name, access_key, secret_key): auth = oss2.Auth(access_key, secret_key) bucket = oss2.Bucket(auth, endpoint, bucket_name) object_name = f"videos/{datetime.now().strftime('%Y%m%d')}/{os.path.basename(file_path)}" bucket.put_object_from_file(object_name, file_path) print(f"Successfully uploaded {file_path} to OSS") def upload_to_minio(file_path, endpoint, bucket_name, access_key, secret_key, secure=False): client = Minio( endpoint, access_key=access_key, secret_key=secret_key, secure=secure ) object_name = f"videos/{datetime.now().strftime('%Y%m%d')}/{os.path.basename(file_path)}" try: client.fput_object(bucket_name, object_name, file_path) print(f"Successfully uploaded {file_path} to MinIO") except S3Error as e: print(f"Error uploading to MinIO: {e}") if __name__ == "__main__": parser = argparse.ArgumentParser() parser.add_argument("--file", type=str, required=True, help="Video file path to upload") parser.add_argument("--type", type=str, default="minio", choices=["oss", "minio"], help="Storage type") parser.add_argument("--endpoint", type=str, required=True, help="Storage endpoint") parser.add_argument("--bucket", type=str, required=True, help="Bucket name") parser.add_argument("--access-key", type=str, required=True, help="Access key ID") parser.add_argument("--secret-key", type=str, required=True, help="Secret access key") args = parser.parse_args() if args.type == "oss": upload_to_oss(args.file, args.endpoint, args.bucket, args.access_key, args.secret_key) else: upload_to_minio(args.file, args.endpoint, args.bucket, args.access_key, args.secret_key)

4. 集成到Wan2.2-I2V-A14B工作流

4.1 修改推理脚本

编辑infer.py，在生成视频后添加上传逻辑：

# 在视频生成代码后添加 output_path = "/workspace/output/video.mp4" # 假设这是生成的视频路径 # 上传到存储 upload_command = f""" python upload_to_storage.py \ --file {output_path} \ --type minio \ --endpoint your-minio-endpoint \ --bucket your-bucket-name \ --access-key your-access-key \ --secret-key your-secret-key """ os.system(upload_command)

4.2 配置环境变量（推荐）

更安全的方式是使用环境变量存储敏感信息：

# 在~/.bashrc或启动脚本中添加 export STORAGE_TYPE="minio" export STORAGE_ENDPOINT="your-minio-endpoint" export STORAGE_BUCKET="your-bucket-name" export STORAGE_ACCESS_KEY="your-access-key" export STORAGE_SECRET_KEY="your-secret-key"

然后修改上传脚本从环境变量读取配置。

5. 测试与验证

5.1 手动测试上传功能

# 生成测试视频 python infer.py --prompt "测试视频" --output test.mp4 --duration 5 --resolution 1280x720 # 手动上传测试 python upload_to_storage.py \ --file test.mp4 \ --type minio \ --endpoint your-minio-endpoint \ --bucket your-bucket-name \ --access-key your-access-key \ --secret-key your-secret-key

5.2 检查上传结果

登录存储服务管理界面
检查对应Bucket中是否出现videos/YYYYMMDD/test.mp4文件
验证视频可正常播放

6. 高级配置与优化

6.1 批量上传配置

如果需要处理批量生成的视频，可以修改start_webui.sh或start_api.sh脚本，添加文件监控逻辑：

import time from watchdog.observers import Observer from watchdog.events import FileSystemEventHandler class VideoHandler(FileSystemEventHandler): def on_created(self, event): if event.src_path.endswith(".mp4"): print(f"New video detected: {event.src_path}") # 调用上传逻辑 time.sleep(5) # 等待文件完全写入 upload_video(event.src_path) def upload_video(file_path): # 实现上传逻辑 pass if __name__ == "__main__": path = "/workspace/output" event_handler = VideoHandler() observer = Observer() observer.schedule(event_handler, path, recursive=False) observer.start() try: while True: time.sleep(1) except KeyboardInterrupt: observer.stop() observer.join()