Run.observeStream()
.observeStream() 方法會為目前正在執行的 Workflow run 開啟新的 ReadableStream,讓你在原有串流已無法使用時,仍可觀察事件串流。
使用範例使用範例 的直接連結
const run = await workflow.createRun()
run.stream({
inputData: {
value: 'initial data',
},
})
const stream = await run.observeStream()
for await (const chunk of stream) {
console.log(chunk)
}
傳回值傳回值 的直接連結
ReadableStream<ChunkType>
串流事件串流事件 的直接連結
串流會在 Workflow 執行期間發出不同類型的事件。每個事件都有一個 type 欄位,以及包含相關資料的 payload:
workflow-start:Workflow 開始執行workflow-step-start:步驟開始執行workflow-step-output:步驟的自訂輸出workflow-step-result:步驟完成並產生結果workflow-finish:Workflow 執行完成,並附有用量統計資料。執行成功時,payload.finalWorkflowResult會包含 Workflow 的最終結果