pipeline-app/README.md

Pipeline-App — 独立产线后端服务

基于 ahserver 的独立产线管理后端，提供产线定义、运营管理和分销功能。

架构

• 部署模式：独立 ahserver Web 应用（端口 9090）
• 数据库：pipeline（独立数据库，非 sage）
• 认证：复用 Sage RBAC（SAGE_RBAC_DB 环境变量指向 sage 库）
• 模块数：3 个业务模块

业务模块

pipeline_core — 产线核心定义

产线的创建、步骤编排和版本管理。

表	说明
pipelines	产线主表（名称、描述、状态、owner）
pipeline_steps	步骤表（产线下的有序步骤，支持并行/串行）
pipeline_versions	版本表（产线快照，支持发布/回滚）

API 端点：pipelines/pipeline_steps/pipeline_versions 的 CRUD + pipeline_publish（发布版本）

pipeline_ops — 产线运营管理

定价、供应量配置和使用记录。

表	说明
pipeline_pricing	定价表（按产线+步骤+模型定价，单价/包量）
pipeline_capacity	供应量表（产线日/月配额，并发限制）
pipeline_usage_log	使用记录表（调用日志、用量统计）

API 端点：pricing/capacity/usage_log 的 CRUD + get_search_pipeline_id（下拉数据源）

pipeline_dist — 分销管理

分销商管理和独立定价。

表	说明
distributors	分销商表（名称、API 密钥、状态、配额）
distributor_pipeline	分销商-产线关联（独立定价、启用状态）

API 端点：distributors/distributor_pipeline 的 CRUD + generate_key（API 密钥生成）

目录结构

pipeline-app/
├── app/
│   ├── pipeline_app.py          # ahserver 主入口
│   └── global_func.py           # 全局函数（dbname 映射）
├── conf/
│   └── config.json              # 配置文件（端口/数据库/认证）
├── pipeline_core/               # 产线核心模块
│   ├── pipeline_core/           # Python 包
│   ├── models/                  # 3 张表定义
│   ├── json/                    # 3 个 CRUD 定义
│   ├── wwwroot/                 # API 端点 + 前端
│   ├── scripts/load_path.py     # RBAC 注册
│   └── pyproject.toml
├── pipeline_ops/                # 运营模块（同上结构）
├── pipeline_dist/               # 分销模块（同上结构）
├── build.sh                     # 构建脚本（venv + 依赖 + DDL + CRUD）
├── start.sh / stop.sh           # 启停脚本
└── README.md

部署步骤

1. 创建数据库

CREATE DATABASE pipeline CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci;

2. 配置数据库密码

编辑 conf/config.json，将数据库密码替换为实际值（当前为 [REDACTED]）。

3. 构建

cd ~/test/pipeline-app
bash build.sh

build.sh 会：创建 py3 venv → 安装依赖 → json2ddl 生成 DDL → xls2crud 生成 CRUD 界面

4. 建表

# 每个模块分别生成并执行 DDL
cd pipeline_core && ../py3/bin/json2ddl mysql models/ > mysql.ddl.sql
cd pipeline_ops && ../py3/bin/json2ddl mysql models/ > mysql.ddl.sql
cd pipeline_dist && ../py3/bin/json2ddl mysql models/ > mysql.ddl.sql
# 在 MySQL 中执行所有 DDL

5. 初始化 RBAC

# 设置 SAGE_RBAC_DB 环境变量指向 sage 数据库
export SAGE_RBAC_DB=sage
# 运行各模块的 load_path.py
cd pipeline_core && ../py3/bin/python scripts/load_path.py
cd pipeline_ops && ../py3/bin/python scripts/load_path.py
cd pipeline_dist && ../py3/bin/python scripts/load_path.py

6. 启动

cd ~/test/pipeline-app
bash start.sh    # 启动服务（端口 9090）
bash stop.sh     # 停止服务

技术要点

• 数据库名：所有模块共用 pipeline 数据库（通过 global_func.py 映射）
• sqlor API：严格使用 sor.C/U/D/R 模式，sor.U() 只接受 2 个参数（id 在 data 字典中）
• dspy 规范：零 import、零 print、零 uuid，使用预加载全局函数
• 独立部署：与 Sage 解耦，通过 HTTP API 对外提供服务
• 分销密钥：distributor_generate_key.dspy 生成随机 API 密钥供分销商调用

文件统计

• 数据表：8 张（core 3 + ops 3 + dist 2）
• API 端点：29 个 dspy 文件
• CRUD 管理：8 个（自动生成）
• 总文件数：~80 个