139 lines
8.2 KiB
MySQL
139 lines
8.2 KiB
MySQL
|
-- -----------------------王立钊2026-04-22 10:00:00-----------------------
|
|||
|
|
|
|||
|
|
--------------------pgsql创建 asynch_models / asynch_task 表语句---------------------------
|
|||
|
|
|
|||
|
|
-- 异步模型表
|
|||
|
|
CREATE TABLE IF NOT EXISTS asynch_models (
|
|||
|
|
-- 基础字段（与现有表保持一致）
|
|||
|
|
id BIGINT PRIMARY KEY, -- 主键ID（非自增）
|
|||
|
|
tenant_id BIGINT NOT NULL DEFAULT 0, -- 租户ID
|
|||
|
|
creator VARCHAR(64) NOT NULL,
|
|||
|
|
created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|||
|
|
updater VARCHAR(64) NOT NULL,
|
|||
|
|
updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|||
|
|
deleted_at timestamp(6),
|
|||
|
|
|
|||
|
|
-- 业务字段
|
|||
|
|
model_name VARCHAR(128) NOT NULL, -- 模型名称（路由键）
|
|||
|
|
base_url VARCHAR(256) NOT NULL, -- 模型服务基础地址（如 http://1.2.3.4:8080）
|
|||
|
|
route VARCHAR(256) NOT NULL DEFAULT '', -- 模型服务路由（如 /v1/infer）
|
|||
|
|
http_method VARCHAR(8) NOT NULL DEFAULT 'POST', -- 请求方式：GET/POST
|
|||
|
|
api_key VARCHAR(256) DEFAULT '', -- 请求密钥绑定（请求头），示例：TTS_API_KEY:your-key
|
|||
|
|
enabled SMALLINT NOT NULL DEFAULT 1, -- 是否启用：1启用/0停用
|
|||
|
|
max_concurrency INT NOT NULL DEFAULT 10, -- 单模型最大并发（worker/队列消费侧应遵守）
|
|||
|
|
queue_limit INT NOT NULL DEFAULT 1000, -- 单模型排队上限（防堆积，可选）
|
|||
|
|
timeout_ms INT NOT NULL DEFAULT 60000, -- 调用模型服务超时（毫秒）
|
|||
|
|
retry_times SMALLINT NOT NULL DEFAULT 0, -- 失败重试次数（0表示不重试）
|
|||
|
|
auto_clean_seconds INT NOT NULL DEFAULT 86400, -- 已下载(state=4)后的保留时间（秒），到期后清理
|
|||
|
|
remark TEXT DEFAULT '' -- 备注
|
|||
|
|
);
|
|||
|
|
|
|||
|
|
-- 索引/约束
|
|||
|
|
CREATE UNIQUE INDEX IF NOT EXISTS uk_asynch_models_tenant_model_name ON asynch_models(tenant_id, model_name);
|
|||
|
|
CREATE INDEX IF NOT EXISTS idx_asynch_models_tenant_id ON asynch_models(tenant_id);
|
|||
|
|
CREATE INDEX IF NOT EXISTS idx_asynch_models_model_name ON asynch_models(model_name);
|
|||
|
|
CREATE INDEX IF NOT EXISTS idx_asynch_models_enabled ON asynch_models(enabled);
|
|||
|
|
CREATE INDEX IF NOT EXISTS idx_asynch_models_deleted_at ON asynch_models(deleted_at);
|
|||
|
|
|
|||
|
|
-- 表和字段注释
|
|||
|
|
COMMENT ON TABLE asynch_models IS '异步模型表（模型服务配置）';
|
|||
|
|
COMMENT ON COLUMN asynch_models.id IS '主键ID（非自增）';
|
|||
|
|
COMMENT ON COLUMN asynch_models.tenant_id IS '租户ID';
|
|||
|
|
COMMENT ON COLUMN asynch_models.creator IS '创建人';
|
|||
|
|
COMMENT ON COLUMN asynch_models.created_at IS '创建时间';
|
|||
|
|
COMMENT ON COLUMN asynch_models.updater IS '更新人';
|
|||
|
|
COMMENT ON COLUMN asynch_models.updated_at IS '更新时间';
|
|||
|
|
COMMENT ON COLUMN asynch_models.deleted_at IS '删除时间（软删）';
|
|||
|
|
COMMENT ON COLUMN asynch_models.model_name IS '模型名称（路由键）';
|
|||
|
|
COMMENT ON COLUMN asynch_models.base_url IS '模型服务基础地址';
|
|||
|
|
COMMENT ON COLUMN asynch_models.route IS '模型服务路由';
|
|||
|
|
COMMENT ON COLUMN asynch_models.http_method IS '请求方式：GET/POST';
|
|||
|
|
COMMENT ON COLUMN asynch_models.api_key IS '请求密钥绑定（请求头），示例：TTS_API_KEY:your-key';
|
|||
|
|
COMMENT ON COLUMN asynch_models.enabled IS '是否启用：1启用/0停用';
|
|||
|
|
COMMENT ON COLUMN asynch_models.max_concurrency IS '单模型最大并发';
|
|||
|
|
COMMENT ON COLUMN asynch_models.queue_limit IS '单模型排队上限';
|
|||
|
|
COMMENT ON COLUMN asynch_models.timeout_ms IS '调用模型服务超时（毫秒）';
|
|||
|
|
COMMENT ON COLUMN asynch_models.retry_times IS '失败重试次数';
|
|||
|
|
COMMENT ON COLUMN asynch_models.auto_clean_seconds IS '已下载(state=4)后的保留时间（秒），到期后清理';
|
|||
|
|
COMMENT ON COLUMN asynch_models.remark IS '备注';
|
|||
|
|
|
|||
|
|
-- 兼容已有库：更新字段注释
|
|||
|
|
COMMENT ON COLUMN asynch_models.auto_clean_seconds IS '已下载(state=4)后的保留时间（秒），到期后清理';
|
|||
|
|
|
|||
|
|
|
|||
|
|
-- 异步任务表
|
|||
|
|
CREATE TABLE IF NOT EXISTS asynch_task (
|
|||
|
|
-- 基础字段（与现有表保持一致）
|
|||
|
|
id BIGINT PRIMARY KEY, -- 主键ID（非自增）
|
|||
|
|
tenant_id BIGINT NOT NULL DEFAULT 0, -- 租户ID
|
|||
|
|
creator VARCHAR(64) NOT NULL,
|
|||
|
|
created_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|||
|
|
updater VARCHAR(64) NOT NULL,
|
|||
|
|
updated_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP,
|
|||
|
|
deleted_at timestamp(6),
|
|||
|
|
|
|||
|
|
-- 任务核心字段
|
|||
|
|
model_name VARCHAR(128) NOT NULL, -- 模型名称
|
|||
|
|
task_id VARCHAR(64) NOT NULL, -- 任务ID（对外返回）
|
|||
|
|
state SMALLINT NOT NULL DEFAULT 0, -- 状态：0排队中/1执行中/2成功/3失败/4已下载
|
|||
|
|
oss_file VARCHAR(512) DEFAULT '', -- OSS文件URL/Key
|
|||
|
|
file_type VARCHAR(32) DEFAULT '', -- 文件类型（如 mp3/mp4/png/pdf/...）
|
|||
|
|
file_size BIGINT NOT NULL DEFAULT 0, -- 文件大小（字节）
|
|||
|
|
error_msg TEXT DEFAULT '', -- 错误信息
|
|||
|
|
|
|||
|
|
-- 执行与清理字段
|
|||
|
|
started_at TIMESTAMP, -- 开始执行时间
|
|||
|
|
finished_at TIMESTAMP, -- 执行结束时间
|
|||
|
|
expire_at TIMESTAMP, -- 过期清理时间（已下载后写入：updated_at + auto_clean_seconds）
|
|||
|
|
retry_count INT NOT NULL DEFAULT 0, -- 已重试次数（不含首次）
|
|||
|
|
enqueue_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP, -- 入队时间（用于排队顺序，重试会更新时间到队尾）
|
|||
|
|
|
|||
|
|
-- 输入信息（用于排障/重放；如不需要可不写入或置空）
|
|||
|
|
input_ref TEXT DEFAULT '', -- 输入引用（如上传文件URL/OSS key/业务侧资源ID）
|
|||
|
|
request_payload JSONB -- 请求参数（可选）
|
|||
|
|
);
|
|||
|
|
|
|||
|
|
-- 索引/约束
|
|||
|
|
CREATE UNIQUE INDEX IF NOT EXISTS uk_asynch_task_tenant_task_id ON asynch_task(tenant_id, task_id);
|
|||
|
|
CREATE INDEX IF NOT EXISTS idx_asynch_task_tenant_id ON asynch_task(tenant_id);
|
|||
|
|
CREATE INDEX IF NOT EXISTS idx_asynch_task_model_name ON asynch_task(model_name);
|
|||
|
|
CREATE INDEX IF NOT EXISTS idx_asynch_task_state ON asynch_task(state);
|
|||
|
|
CREATE INDEX IF NOT EXISTS idx_asynch_task_updated_at ON asynch_task(updated_at);
|
|||
|
|
CREATE INDEX IF NOT EXISTS idx_asynch_task_expire_at ON asynch_task(expire_at);
|
|||
|
|
CREATE INDEX IF NOT EXISTS idx_asynch_task_deleted_at ON asynch_task(deleted_at);
|
|||
|
|
|
|||
|
|
-- 表和字段注释
|
|||
|
|
COMMENT ON TABLE asynch_task IS '异步任务表';
|
|||
|
|
COMMENT ON COLUMN asynch_task.id IS '主键ID（非自增）';
|
|||
|
|
COMMENT ON COLUMN asynch_task.tenant_id IS '租户ID';
|
|||
|
|
COMMENT ON COLUMN asynch_task.creator IS '创建人';
|
|||
|
|
COMMENT ON COLUMN asynch_task.created_at IS '创建时间';
|
|||
|
|
COMMENT ON COLUMN asynch_task.updater IS '更新人';
|
|||
|
|
COMMENT ON COLUMN asynch_task.updated_at IS '更新时间';
|
|||
|
|
COMMENT ON COLUMN asynch_task.deleted_at IS '删除时间（软删）';
|
|||
|
|
COMMENT ON COLUMN asynch_task.model_name IS '模型名称';
|
|||
|
|
COMMENT ON COLUMN asynch_task.task_id IS '任务ID（对外返回）';
|
|||
|
|
COMMENT ON COLUMN asynch_task.state IS '状态：0排队中/1执行中/2成功/3失败/4已下载';
|
|||
|
|
COMMENT ON COLUMN asynch_task.oss_file IS 'OSS文件URL/Key';
|
|||
|
|
COMMENT ON COLUMN asynch_task.file_type IS '文件类型';
|
|||
|
|
COMMENT ON COLUMN asynch_task.file_size IS '文件大小（字节）';
|
|||
|
|
COMMENT ON COLUMN asynch_task.error_msg IS '错误信息';
|
|||
|
|
COMMENT ON COLUMN asynch_task.started_at IS '开始执行时间';
|
|||
|
|
COMMENT ON COLUMN asynch_task.finished_at IS '执行结束时间';
|
|||
|
|
COMMENT ON COLUMN asynch_task.expire_at IS '过期清理时间（已下载后保留到期）';
|
|||
|
|
COMMENT ON COLUMN asynch_task.retry_count IS '已重试次数（不含首次）';
|
|||
|
|
COMMENT ON COLUMN asynch_task.enqueue_at IS '入队时间（用于排队顺序，重试会更新时间到队尾）';
|
|||
|
|
COMMENT ON COLUMN asynch_task.input_ref IS '输入引用（如上传文件URL/OSS key/业务侧资源ID）';
|
|||
|
|
COMMENT ON COLUMN asynch_task.request_payload IS '请求参数（JSON）';
|
|||
|
|
|
|||
|
|
-- 兼容已有库：增量加字段（PostgreSQL 支持 IF NOT EXISTS）
|
|||
|
|
ALTER TABLE asynch_task ADD COLUMN IF NOT EXISTS retry_count INT NOT NULL DEFAULT 0;
|
|||
|
|
ALTER TABLE asynch_task ADD COLUMN IF NOT EXISTS enqueue_at TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP;
|
|||
|
|
COMMENT ON COLUMN asynch_task.retry_count IS '已重试次数（不含首次）';
|
|||
|
|
COMMENT ON COLUMN asynch_task.enqueue_at IS '入队时间（用于排队顺序，重试会更新时间到队尾）';
|
|||
|
|
COMMENT ON COLUMN asynch_task.state IS '状态：0排队中/1执行中/2成功/3失败/4已下载';
|
|||
|
|
COMMENT ON COLUMN asynch_task.expire_at IS '过期清理时间（已下载后保留到期）';
|
|||
|
|
|
|||
|
|
-- 对存量数据进行入队时间回填（只在 enqueue_at 为空时）
|
|||
|
|
UPDATE asynch_task SET enqueue_at = created_at WHERE enqueue_at IS NULL;
|