From 5124b4a047f581200a58faeb6c756dbbbd2afc7e Mon Sep 17 00:00:00 2001 From: yumoqing Date: Thu, 11 Jun 2026 14:59:11 +0800 Subject: [PATCH] =?UTF-8?q?docs:=20=E8=A1=A5=E5=85=A8README=20=E2=80=94=20?= =?UTF-8?q?=E5=BC=95=E6=93=8E=E6=9E=B6=E6=9E=84/=E7=8A=B6=E6=80=81/?= =?UTF-8?q?=E5=85=B3=E8=81=94=E4=BB=93=E5=BA=93?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- README.md | 53 ++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 file changed, 52 insertions(+), 1 deletion(-) diff --git a/README.md b/README.md index d2d6caf..37f5b8b 100644 --- a/README.md +++ b/README.md @@ -1,2 +1,53 @@ -# pipeline-service +# Pipeline-Service — 产线任务引擎(早期版本) +KTV/MV 视频制作流水线的后端引擎,负责编排和执行多步骤产线任务。 + +## 功能 + +- **任务存储**:JSON 文件存储产线任务状态 +- **步骤编排**:支持串行/并行步骤执行 +- **状态管理**:pending → running → completed/failed +- **版本追踪**:每个步骤的输入/输出可追溯 + +## 架构 + +```python +pipeline_service/ +├── engine.py # 产线执行引擎(步骤调度) +├── models.py # 数据模型(Task, Step, Node) +├── storage.py # JSON 文件存储层 +└── __init__.py +``` + +## 使用方式 + +```python +from pipeline_service.engine import PipelineEngine + +engine = PipelineEngine(storage_dir="./tasks") +task_id = engine.submit({ + "name": "KTV视频制作", + "steps": [ + {"type": "ai_video", "config": {...}}, + {"type": "demucs", "config": {...}}, + {"type": "asr", "config": {...}}, + {"type": "ffmpeg_compose", "config": {...}} + ] +}) +engine.run(task_id) +``` + +## 当前状态 + +本模块为早期原型,核心引擎已编写但: +- 未与 Sage 平台联调 +- 未部署到生产环境 +- 后续由 pipeline-app 替代为独立服务架构 + +## 相关仓库 + +| 仓库 | 说明 | +|------|------| +| [pipeline-app](https://git.opencomputing.cn/yumoqing/pipeline-app) | 替代方案:独立 ahserver 后端服务 | +| [pipeline](https://git.opencomputing.cn/yumoqing/pipeline) | Sage 前端桥接模块 | +| [showcase](https://git.opencomputing.cn/yumoqing/showcase) | 展示平台(产线产出物展示) |