60688c3108
事故:cypher-executor/src/actions/execution-logger.ts 舊版每跑完一次 workflow 就
ANALYTICS_KV.put() 一筆新 key(註解寫「避免覆蓋」)= 只增不減,封測者 Evan 處理約 690 個
檔案就把 KV 免費層 1,000 write/日打爆(實測 1,070 write),整個實例 429。
A1 少記:workflow 執行紀錄改走 KBDB template 機制(entries 表 entry_type='execution_log',
kbdb/migrations/0004_execution_log_template.sql 只 seed 一列 template 定義,零建表/改表)。
儲存精神比照既有 recipe_stat(kbdb/src/actions/recipe-stat.ts):template 只負責文件化,
實際一筆執行是 entries 表一列(1 次執行=1 次 D1 寫入,不走 entry_values 全展開)。欄位收斂:
時間/workflow/verdict/duration/錯誤訊息/(可得的)目標;成功記最少,失敗多記(訊息截斷長度
不對稱:200 vs 2000 字)。target 只認 trigger context 的 page_name/path,不整包存 input。
A2 自我降級:D1 額度仍與知識卡共用同一顆 100,000 rows/日,本模組自設 20% 軟上限(可用
EXECUTION_LOG_DAILY_WRITE_LIMIT 覆寫),超過 80% 降成只記失敗、超過 100% 完全停止記錄,
但 workflow 執行永遠照跑(cypher-executor 端 fire-and-forget 永不 throw)。
A7 讀取端:/workflows/:name/executions、/portal/data/workflows 的 last_execution、MCP
list_recent_executions 全部改打 KBDB HTTP API(GET /execution-log、/execution-log/latest),
取代原本的 ANALYTICS_KV list/get(免費層 list 也是 1,000/日)。
架構鐵律修正(本次施工中兩度被抓到走偏,過程留痕於 commit 訊息供後續參考):
- KBDB 三張表打天下(entries/templates/entry_values),永遠不加新 table——新資料類型
一律用 template + entries,不建表、不 ALTER TABLE。
- KBDB = API-as-Wall,零 SQL:cypher-executor 端一律走 KBDB 的 HTTP API(連法比照既有
recordRecipeStats/kbdbFetch 慣例),不直連任何 D1、不對 arcrun-kbdb 下任何原生 SQL。
順帶修復:kbdb/src/actions/entry-crud.ts listEntries 的 ORDER BY 補 `, rowid DESC` 二級
排序——entries.created_at 是 unixepoch() 秒級解析度,高頻寫入(execution_log 一秒內多筆)
常同秒,單靠 created_at DESC 不保證「最新一筆」正確,此為本次測試(latestExecutionLog)
發現的既有潛在缺陷,順手補上決定性排序,不改變任何既有查詢在 created_at 不同時的行為。
隔離:portal-data.ts INTERNAL_ENTRY_TYPES 加入 execution_log/execution_log_usage(與既有
value/workflow 同層級排除),避免用戶知識搜尋混進執行 log;本模組從不設 metadata_json.embed,
故永不進 Vectorize 語意搜尋索引。
不動:registry/src/actions/recordAnalytics.ts(零件市場統計,獨立 Worker、獨立 KV 命名空間、
不同資料模型,非本次事故根因所指範圍);cypher-executor/{wrangler.toml,kbdb/wrangler.toml}
未變動(repo 層級 deny 規則保護這兩個生產設定檔不被 AI 編輯)——ANALYTICS_KV binding
因此仍留在 wrangler.toml 宣告中但程式碼零讀寫點(見 PR 說明的完整 grep 佐證)。
KV 裡既有的 stats:* 舊資料不搬移(是統計不是真相源,維持原樣任其依 90 天 TTL 自然過期)。
測試:kbdb/tests/execution-log.test.ts(13 個,含零建表證明/少記/A2 降級/route)、
cypher-executor/tests/execution-logger.test.ts(payload 正確性/永不 throw)、
cypher-executor/tests/executions-route.test.ts(讀取端轉發)、portal-data.test.ts 對應區塊
改寫。kbdb 全測試 104/104 通過;cypher-executor 320 個測試中 9 個失敗為 main 既有(與本次
改動無關,改動前後 stash 對照確認)。
Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
76 lines
2.5 KiB
TypeScript
76 lines
2.5 KiB
TypeScript
// KBDB Base types. Base depends on D1 only.
|
||
// Optional modules add their own bindings (embed: VECTORIZE+AI). Base never references them.
|
||
|
||
export type Bindings = {
|
||
DB: D1Database;
|
||
ENVIRONMENT: string;
|
||
// Auth guard (t115 二修, fail-closed): provisioned by the installer automatically.
|
||
// NOT set → writes (POST/PATCH/DELETE/PUT) rejected 401; reads pass with a warning
|
||
// (upgrade-window grace so read-only workflows don't break before both workers are
|
||
// updated together).
|
||
// SET → all non-health routes require `Authorization: Bearer <token>`.
|
||
// cypher-executor sends this via kbdbBase(); portal/webhooks/recipes send it inline.
|
||
KBDB_INTERNAL_TOKEN?: string;
|
||
// Optional embed module (issue #7 / SDD T2.4). Present ONLY when the self-host opened
|
||
// semantic search (kbdb_embed:true → deploy injects [[vectorize]] + [ai]). Base never
|
||
// requires them; code checks `if (env.VECTORIZE && env.AI)` before touching embed.
|
||
VECTORIZE?: VectorizeIndex;
|
||
AI?: Ai;
|
||
// 嵌入模型(Arcrun#59)。未設=用 embed.ts 的預設。設成別的模型時,**Vectorize index 的
|
||
// dimensions 必須跟著對**(維度不合 upsert 會被 CF 拒絕),且換模型必須換 index:
|
||
// 不同模型的向量不可共存於同一個 index(比對出來是垃圾),詳見 embed.ts 檔頭。
|
||
EMBED_MODEL?: string;
|
||
// execution_log 每日軟上限(KV 額度事故修復,2026-08-07;A2 自我降級,見
|
||
// kbdb/src/actions/execution-log.ts DEFAULT_DAILY_LIMIT 說明)。未設 → 20000
|
||
// (D1 100,000 rows written/日的 20%,留 80% 給知識卡 entries)。
|
||
EXECUTION_LOG_DAILY_WRITE_LIMIT?: string;
|
||
};
|
||
|
||
export type EntryType =
|
||
| 'block'
|
||
| 'value'
|
||
| 'template'
|
||
| 'slot'
|
||
| 'project'
|
||
| 'workflow'
|
||
| 'recipe_stat'
|
||
| 'execution_log'
|
||
| 'execution_log_usage';
|
||
|
||
export interface Entry {
|
||
id: string;
|
||
content: string | null;
|
||
entry_type: EntryType | string;
|
||
owner_id: string | null;
|
||
parent_id: string | null;
|
||
page_name: string | null;
|
||
refs_json: string;
|
||
tags_json: string;
|
||
task_status: string | null;
|
||
content_hash: string | null;
|
||
is_embedded: number;
|
||
confidence: number | null;
|
||
metadata_json: string | null;
|
||
created_at: number;
|
||
updated_at: number;
|
||
}
|
||
|
||
export interface Template {
|
||
id: string;
|
||
name: string;
|
||
description: string | null;
|
||
slots_json: string;
|
||
created_by: string | null;
|
||
created_at: number;
|
||
updated_at: number;
|
||
}
|
||
|
||
export interface EntryValue {
|
||
id: string;
|
||
record_id: string;
|
||
template_id: string;
|
||
slot_name: string;
|
||
entry_id: string;
|
||
created_at: number;
|
||
}
|