xiaoxue_admin
/
memoryweave
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(G6.2): LLM model换qwen3.5-122b，deploy service同步更新

This commit is contained in:
xiaowei 2026-05-31 01:25:51 +08:00
parent b175b82b01
commit 0ef3f2f0ba
3 changed files with 17 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
deploy/zhiyid.service
View File

@ -15,7 +15,7 @@ Environment=VLLM_ENDPOINT=https://ai.gitee.com/v1/embeddings
Environment=MOLIFANG_API_KEY=3TSVVXRFFECE4TISXHGE1VXDAXBIPAP6O1VPJK18
Environment=LLM_ENDPOINT=http://127.0.0.1:3000/v1/chat/completions
Environment=LLM_MODEL=qwen/qwen3.5-122b-a10b
Environment=LLM_API_KEY=sk-0ExNiLblJvIWBDpkS50fwOBw4MmqLyKdHJK5iQtlw9dOMWBP
Environment=LLM_API_KEY=0ExNiLblJvIWBDpkS50fwOBw4MmqLyKdHJK5iQtlw9dOMWBP
Environment=RERANK_ENDPOINT=https://ai.gitee.com/v1
Environment=GRAPH_PATH=/var/lib/memoryweave/graph.db
ExecStartPre=/bin/mkdir -p /var/lib/memoryweave

23
go/internal/storage/lancedb_ipc.go
View File

@ -320,7 +320,8 @@ func (rc *RustLanceDBClient) Update(table, id string, fields map[string]any) err
_local.mu.Unlock()
// 2. 通过 IPC 持久化到 Rust LanceDB
// 构建 fields JSON: [{"column":"recall_count","value":"recall_count + 1"}, ...]
// 构建 fields JSON: [{"column":"recall_count","value":"1"}, ...]
// 直接发送增量值（Rust LanceDB update 只接受字面量）
type updateField struct {
Column string `json:"column"`
Value string `json:"value"`
@ -329,16 +330,18 @@ func (rc *RustLanceDBClient) Update(table, id string, fields map[string]any) err
for k, v := range fields {
switch val := v.(type) {
case string:
fieldList = append(fieldList, updateField{k, "'" + strings.ReplaceAll(val, "'", "''") + "'"})
case map[string]string:
if k == "recall_count" {
// $inc 语法 → SQL 表达式
var parsed map[string]string
if json.Unmarshal([]byte(val), &parsed) == nil {
if inc, ok := parsed["$inc"]; ok {
fieldList = append(fieldList, updateField{k, k + " + " + inc})
}
if inc, ok := val["$inc"]; ok {
fieldList = append(fieldList, updateField{k, inc}) // 直接发数值 "1"
}
}
case map[string]interface{}:
if k == "recall_count" {
if inc, ok := val["$inc"]; ok {
fieldList = append(fieldList, updateField{k, fmt.Sprintf("%v", inc)})
}
} else {
fieldList = append(fieldList, updateField{k, "'" + strings.ReplaceAll(val, "'", "''") + "'"})
}
case float64:
fieldList = append(fieldList, updateField{k, fmt.Sprintf("%f", val)})
@ -350,8 +353,10 @@ func (rc *RustLanceDBClient) Update(table, id string, fields map[string]any) err
}
}
}
log.Printf("[ipc] Update: id=%s fields_count=%d", id, len(fieldList))
if len(fieldList) > 0 {
fj, _ := json.Marshal(fieldList)
log.Printf("[ipc] Update fields_json: %s", string(fj))
_, err := rc.rpc(ipcReq{
Type: "lancedb_update",
Table: table,

3
rust/src/lancedb_ops.rs
View File

@ -295,10 +295,11 @@ impl LanceDBOps {
val.to_string()
};
eprintln!("[lancedb] UPDATE col={} val='{}'", col, final_val);
op = op.column(col, &final_val);
}
let updated = rt().block_on(op.execute())?;
eprintln!("[lancedb] update {}: id={} fields={} rows={}", table, id, fields.len(), updated);
eprintln!("[lancedb] UPDATE DONE: id={} fields={} rows={}", id, fields.len(), updated);
Ok(updated)
}