【免費下載鏈接】rocketride-serverHigh-performance AI pipeline engine with a C core and 50 Python-extensible nodes. Build, debug, and scale LLM workflows with 13 model providers, 8 vector databases, and agent orchestration, all from your IDE. Includes VS Code extension, TypeScript/Python SDKs, and Docker deployment.項目地址https://gitcode.com/gh_mirrors/ro/rocketride-server點擊查看免費下載本篇技術指南圍繞 RocketRide 倉庫中 TypeScript 客戶端 SDK 的client.log運行日志 API見 docs/public/typescript/logs.md展開。它講解一次任務一條連續(xù) JSONL 事件流run-log continuum的存儲模型、以openEventStream()為核心的 DVR 會話回放協(xié)議seed-then-stream、chapters/read/segment/delete四種讀取與維護操作以及底層的rrext_logDAP 線與權限邊界。讀完你將掌握如何用幾行代碼復現(xiàn)任意歷史運行的完整過程、如何將回放與實時監(jiān)控無縫銜接、如何按需批量導出日志以及如何在團隊部署場景中正確選擇流的作用域scope。核心概念一次任務一條流一次運行一個章節(jié)在 RocketRide 的日志體系里沒有每次運行一個日志文件這種模型。每一個任務身份identity都對應一條連續(xù)的事件流continuum即一個按行追加的 JSONL 事件流而每次運行只是這條流里的一個章節(jié)chapter / track。流的身份由如下元組唯一確定// 流身份LogStreamRef { projectId: string; // 項目 ID source: string; // 源任務ID teamId?: string; // 可選指向某個團隊的 DEPLOY 連續(xù)流 runKind?: dev | deploy; // 可選無 teamId 時的個人作用域選擇 }作用域scope規(guī)則在 類型定義 中有精確定義帶teamId指向該團隊的DEPLOY 連續(xù)流。部署運行以團隊身份執(zhí)行并寫入團隊日志樹任何擁有 monitor 權限的隊友都可以讀取與回放參見 deploy.md 中Scheduled runs execute as the team…readable by teammates viaclient.logwithteamId。不帶teamId指向你自己的流此時可選的runKind在兩條個人連續(xù)流之間選擇省略或dev你的開發(fā)dev流默認值deploy你的個人me部署流——這是teamId存在時無法表達的唯一種類deploy 屬性但用戶私有。// 你自己的 dev 流 const stream { projectId: proj-1, source: chat_1 }; // 若要讀某個團隊的部署連續(xù)流 const teamStream { projectId: proj-1, source: chat_1, teamId: team-prod };流由身份元組尋址永遠不用任務 token。token 是憑據(jù)絕不進入日志系統(tǒng)。這條流具備以下持久性特性見原文檔 logs.md跨斷線、跨服務重啟存活流寫入由引擎持久化斷線/重啟不丟數(shù)據(jù)回放與實時同源過去運行的回放與實時監(jiān)控走同一批面板與同一套 API保留策略retention環(huán)形緩沖ring約最近 1 GB疊加歷史時長dev 流 7 天 / deploy 流 30 天。DVR 會話openEventStream()與 seed-then-stream 協(xié)議client.log.openEventStream(stream)在某個源連續(xù)流上打開一個DVR 會話實現(xiàn)類為LogEventStream見 log-stream.ts。會話讓使用者只思考時間線上的位置position存儲細節(jié)segments 分段、keyframes 關鍵幀、deltas 增量全部不可見會話交付的每個事件都是完全重建后的完整事件。協(xié)議seed-then-streamseek(pos)將會話定位到某個位置pos為 epoch 秒或字符串liveget*()系列調(diào)用以該位置時刻的狀態(tài)填充你的面板console、status、tracesplay(pos, speed, cb)只流式投遞嚴格晚于種子所覆蓋范圍的事件——無縫隙no gap、無重復no duplicate。關鍵語義源碼注釋 log-stream.ts 與文檔一致速度speed0 盡可能快flat-out1 實時速度10 10 倍速自動追平auto-pin從過去位置回放時一旦追上墻鐘wall clock會自動釘住實時live實時并不是一種獨立模式它就是釘在 now 上的位置seek(live)。const stream { projectId: proj-1, source: chat_1 }; const session client.log.openEventStream(stream); // 標準啟動流程定位、播種面板、然后滾動。 await session.seek(live); const status await session.getStatus(); // 該位置時刻的狀態(tài)快照 const consoleLines await session.getConsole(500); // 該時刻 console 實際顯示的內(nèi)容 const traces await session.getTraces(50); // 所有在途 trace 最近關閉的 50 條 await session.play(undefined, 0, ({ event }) fold(event)); // 從某次過去運行的起點以 10 倍速回放。 const [first] await session.getChapters(); await session.play(first.beginTime, 10, ({ event }) fold(event)); // 深入某一條 trace調(diào)用樹從恰好包含它的 segments 稀疏拉取。 const detail await session.getTrace(traces.closed[0].beginSeq); session.pause(); // 凍結位置 session.closeEventStream(); // 釋放會話會話 API 的邊界與細節(jié)getTraces(n)的窗口約束n 50時拋錯MAX_TRACES 50常量與throw new Error(...)見 log-stream.ts 與 #L304-L311。會話暴露所有在途in-flighttrace外加最近關閉 trace 的滑動窗口更早的 trace 仍可通過 seek 到其生命周期內(nèi)的某個位置來訪問。getTrace(traceId)的身份契約trace 由它 begin 事件的continuum seq唯一標識——傳入 trace 自身的beginSeq來自LogTraceSummary而不是章節(jié)的 beginSeq。原因slot ID 會被復用reuse而beginSeq永不復用。類型定義 types/log.ts 明確寫道id只是顯示用 ID永遠把beginSeq或 begin 事件的 seq傳給getTrace。在 log-stream.ts 的實現(xiàn)中解析流程是確定性的、與位置無關的先根據(jù) span 表定位包含該 seq 的 segment找到 begin 事件再沿其 slot 向前收集到匹配的end跨 segment、必要時跨 live 尾部。當 seq 已低于保留水平線retention horizon或該 seq 不存在 trace-begin 事件slot 復用或 fold docId 不是 trace 身份時會失敗。ingestLive(event)持有實時訂閱的宿主host把到達的事件喂給會話釘在實時時到達節(jié)奏即投遞節(jié)奏arrival paces delivery。實現(xiàn)上log-stream.ts無 body 時間戳的事件會被丟棄An event without body stamps is not a stamped task event且嚴格按 seq 去重seq 最后一個已緩存 seq的直接忽略。會話的監(jiān)控訂閱會話構造時會以流的 scope 為 key 注冊[all]類型的 monitorlog-stream.tscloseEventStream()釋放該注冊——服務端按 key 引用計數(shù)可與宿主自己的注冊共存這屬于會話的內(nèi)部行為不增加任何 wire 面。chapters()一次小讀取拿到整條時間線client.log.chapters(stream)返回流的時間線一次調(diào)用即可獲得時間線 UI 所需的全部元數(shù)據(jù)返回結構見 LogChaptersResult字段含義chapters每次運行的 begin/end 時間、起始 seq、結果outcomesegments活動 spansegment 時間范圍供時間線活動條繪制startTime/endTime保留窗口的起點水平線/ 最新活動時間horizonSeqring/age 淘汰后仍保留的首個 seqcompleted當前是否沒有運行在寫這條流// 自己的 dev 流加 teamId: team-prod 可讀某團隊的部署連續(xù)流。 const stream { projectId: proj-1, source: chat_1 }; const timeline await client.log.chapters(stream); for (const track of timeline.chapters) { console.log(track.beginTime, track.endTime, track.outcome); }LogChapter的outcome取值為ok | error | cancelled運行進行中為 nullbeginSeq即該運行在連續(xù)流中的首條 seqtraceLevel記錄該運行的 trace 級別null/none表示 trace 關閉見 types/log.ts。實現(xiàn)上log.ts它走rrext_log命令的chapters子命令SDK 層透傳stream元組。read()有界分頁的順序事件讀取client.log.read(stream, params)對連續(xù)流做范圍化、分頁化的事件讀取。支持三種范圍形式參數(shù)定義見 LogReadParamsseq 范圍fromSeq/toSeq兩端含時間范圍fromTime/toTime省略toTime表示到當前時間到 segmentfromTimetoSegment讀到并包含該 segment。分頁參數(shù)maxEvents/maxBytes會被服務端鉗制server-clamped到其上限當響應攜帶nextSeq時把它作為cursor傳回即可繼續(xù)翻頁。types數(shù)組在服務端過濾事件類型例如[output]用于日志頁。truncatedAtSeq字段出現(xiàn)時說明本次請求已經(jīng)下探到保留水平線之下即最老的部分已被淘汰。let cursor: number | undefined; do { const page await client.log.read(stream, { fromSeq: 0, cursor, types: [output] }); for (const event of page.events) { process.stdout.write(String(event.body?.output ?? )); } cursor page.nextSeq; } while (cursor ! undefined);body 里的連續(xù)流時間戳——唯一的存在位置每個事件都在其body中攜帶連續(xù)流時間戳且只有 body 里有LogEventBodybody.eventTimeepoch 秒浮點引擎入口處只打一次戳stamped once at engine ingressbody.logSeq連續(xù)流序號目錄catalog播種——全新流從 1 開始并在跨運行、跨重啟后從記錄的lastSeq 1繼續(xù)嚴格單調(diào)遞增。這兩個時間戳在實時投遞與回放時完全一致identical live and on replay。而 DAP 信封自身的seq只是每連接的協(xié)議記賬號與連續(xù)流毫無關系。對舊 v2 段時間戳在 header的兼容由 normalizeStamps 在解碼時統(tǒng)一搬進 body——消費方永遠只讀 body 里的戳。segment()按字節(jié)偏移拉取原始 JSONL 的批量回放路徑client.log.segment(stream, segmentId, { offset, maxBytes })獲取某個 segment 的原始 JSONL 字節(jié)按字節(jié)偏移分塊chunk返回——這是批量回放bulk replay的路徑。服務端不做行掃描、過濾或解析直接原樣交出不可變的 segment 內(nèi)容且每個響應塊都是整行對齊的每個響應都結束在換行符上因此每個 chunk 都能獨立解析。重復攜帶返回的nextOffset直到final: true為止。segment 表id 時間范圍來自chapters()的結果。let offset 0; for (;;) { const chunk await client.log.segment(stream, 0, { offset }); for (const line of chunk.data.split(\n)) { if (line.trim()) handleEvent(JSON.parse(line)); } if (chunk.final) break; offset chunk.nextOffset!; }返回結構LogSegmentResult包括segment段 ID、offset本塊起始字節(jié)、data原始 JSONL 文本、size段總字節(jié)數(shù)活動段會增長、nextOffset繼續(xù)的偏移耗盡時為 null、final是否到達段尾。實現(xiàn)上log.ts就是rrext_log的segment子命令SDK 只是透傳。選型建議來自原文檔消費完整運行回放、導出時優(yōu)先用segment()做過濾或窄范圍查詢時用read()。delete()破壞性維護操作client.log.delete(stream, options)是破壞性操作返回{ deletedSegments }beforeTime丟棄整段早于該截止時間的 segments章節(jié)會被裁剪、水平線前移all: true移除整條流包括其控制文件control file。// 刪除一天前的全部日志段 await client.log.delete(stream, { beforeTime: Date.now() / 1000 - 86400 }); // 刪除整條流 await client.log.delete(stream, { all: true });注意beforeTime的單位是epoch 秒Date.now() / 1000與eventTime的時間刻度一致不要誤傳毫秒。Wire 面與權限模型所有方法都走同一條rrext_logDAP 命令由subcommand參數(shù)分派chapters、read、segment、delete——LogApi的實現(xiàn)確認了這一點log.ts而openEventStream()是純客戶端組合它在底層發(fā)出chapters與segment調(diào)用并在會話打開期間注冊實時 monitor 訂閱closeEventStream()釋放自身不增加任何新的 wire 面。權限規(guī)則如下操作所需權限chapters/read/segment讀task.monitordelete寫/破壞task.control作用域決定權限解析對象請求尋址的 scope 決定了這些權限在誰的流上解析——不帶teamId訪問的是你自己的 dev 流runKind: deploy則訪問你的個人 me 部署流帶teamId權限針對目標團隊檢查——團隊成員身份本身就是讀/寫權限membership is the read/write right。會話的 monitor 注冊同樣遵循該 scope 規(guī)則monitorScope團隊流訂閱團隊的 run無團隊流訂閱調(diào)用者自己的 runrunKind僅在沒有teamId且為deploy時隨 key 傳遞。源碼級縱深客戶端 DVR 的內(nèi)部機制若想理解openEventStream()會話為什么能做到無縫隙、無重復的回放值得讀一讀 log-stream.ts 中的幾個內(nèi)部設計Live bucket實時桶到達的實時事件被保存在一個特殊的緩存段里其段 ID 為Number.MAX_SAFE_INTEGER排在所有服務端段之后因此有序遍歷pump、trace 收集總能最后到達它正如它概念上就是最新的段L88-L95。有界性桶在超過LIVE_BUCKET_SPLIT_BYTES24 MiB 序列化字節(jié)L88時觸發(fā) split——對照新拉取的目錄把服務端已被封存段覆蓋的前綴丟棄這些事件現(xiàn)在可按真實段重新拉取保留的后綴最多一個活動段的量從而支持任意長的實時觀察而不失控L522-L545。LRU 解碼段緩存常駐解碼段上限 6 個MAX_RESIDENT_SEGMENTS淘汰策略為最近最少使用——播放/播種/trace 展開觸達的正是當前位置關心的段因此 recency 天然跟隨指針被淘汰的段封存段不可變一次原始拉取即可重新物化L104、L690-L709。flat-out 批處理速度 0 時每投遞 250 個事件FLAT_OUT_BATCH讓出一次事件循環(huán)避免巨大的追補把宿主餓死L77、L611-L616。pump 世代epoch守衛(wèi)seek()/play()遞增 pump 世代使任何仍在等待 fetch 的舊投遞循環(huán)自動退役防止陳舊回調(diào)交錯進新位置L222-L246、L552-L618。段編解碼codec段的存儲編碼屬于內(nèi)部管道SDK 不對外導出storage encoding is plumbing, never public SDK surface。每個 segment 是自包含容器以{type:keyframe}前導行開頭含完整 status 快照、byPipe、openFrames、closedRecent、console 滾動區(qū)見 SegmentKeyframe內(nèi)部事件可攜帶delta 體——status 增量以同一段內(nèi)的上一個 status/keyframe 為基底trace leave 增量以其配對的 enter 為基底。SegmentDecoderlog-codec.ts是有狀態(tài)解碼器applyShallowDeltaL104-L131實現(xiàn)淺增量逆運算字典字段合并一層、__deleted__鍵刪除。會話消費方永遠只看到重建后的完整事件——這正是文檔所述storage details invisible, every event fully reconstructed的實現(xiàn)基礎。契約一致性這些類型與行為同時固化在 contract/versions/v1.3.d.ts 中LogStreamRef、LogChapter、LogEventStream類簽名、LogApi四方法等是 SDK 與遠端服務之間版本化契約的 TypeScript 鏡像。實踐小結要復現(xiàn)一次完整運行chapters()拿時間線 →segment()按整行分塊批量拉取 → 自行逐行JSON.parse處理或直接開 DVR 會話seek(beginTime)play(pos, speed, cb)。要實時監(jiān)控并隨時可回溯openEventStream()seek(live)回放追平墻鐘后自動進入實時不需要切換模式。要過濾式查詢?nèi)缰蝗?output用read()的types服務端過濾 cursor分頁。要清理delete(stream, { beforeTime })裁剪老段delete(stream, { all: true })移除整條流記住delete需要task.control讀操作需要task.monitor且teamId決定權限在哪個團隊的流上解析。永遠用身份元組projectId source 可選 teamId/runKind尋址絕不用任務 token排序、去重、追平永遠依賴 body 里的eventTime與logSeq而不是 DAP 信封的seq。贊分享【免費下載鏈接】rocketride-serverHigh-performance AI pipeline engine with a C core and 50 Python-extensible nodes. Build, debug, and scale LLM workflows with 13 model providers, 8 vector databases, and agent orchestration, all from your IDE. Includes VS Code extension, TypeScript/Python SDKs, and Docker deployment.項目地址https://gitcode.com/gh_mirrors/ro/rocketride-server點擊查看免費下載相關推薦RocketRide Run Logs 實戰(zhàn)指南用 client.log 實現(xiàn) DVR 式任務日志回放與監(jiān)控RocketRide Run Logs 實戰(zhàn)指南用 client.log 實現(xiàn) DVR 式任務日志回放與監(jiān)控 Run Logs 是 RocketRide 提供RocketRide 可觀測性實戰(zhàn)指南DVR 式運行日志、實時監(jiān)控與事后故障復盤RocketRide 可觀測性實戰(zhàn)指南DVR 式運行日志、實時監(jiān)控與事后故障復盤 RocketRide 把每一次管線運行都完整記錄下來一條按管道身份 prRocketRide Observability 與追蹤集成指南基于 DAP WebSocket 的實時事件訂閱與 DVR 回放入門RocketRide Observability 與追蹤集成指南基于 DAP WebSocket 的實時事件訂閱與 DVR 回放入門 本篇技術指南圍繞 Roc創(chuàng)作聲明：本文部分內(nèi)容由AI輔助生成（AIGC），僅供參考