본문으로 건너뛰기

핸들Workflow스트림()

AI SDK 호환 형식의 스트리밍 Workflow 실행을 위한 프레임워크에 구애받지 않는 핸들러입니다. Hono 또는 Mastra 자체 외부의 Workflow 스트리밍을 처리해야 하는 경우 이 기능을 직접 사용하십시오.apiRoutes특징.

handleWorkflowStream()은 createUIMessageStreamResponse()로 감쌀 수 있는 ReadableStream을 반환합니다. handleWorkflowStream()기존 AI SDK v5/기본 동작을 유지합니다. 앱이 AI SDK v6에 대해 입력된 경우 다음을 통과하세요.version: 'v6'.

Mastra 서버 내에 Workflow 경로를 만들려면 workflowRoute()를 사용하세요.

Workflow에서 Agent 스트리밍

Workflow 단계에서 Agent의 스트림을 Workflow writer로 파이프하는 경우(예: await response.fullStream.pipeTo(writer)), Agent가 Workflow 단계 내에서 실행되더라도 Agent의 텍스트 청크와 Tool 호출이 UI 스트림으로 실시간 전달됩니다. 자세한 내용은 Workflow 스트리밍을 참고하세요.

사용예
사용예에 대한 직접 링크

Next.js 앱 라우터 예:

app/api/workflow/route.ts
import { handleWorkflowStream } from '@mastra/ai-sdk'
import { createUIMessageStreamResponse } from 'ai'
import { mastra } from '@/src/mastra'

export async function POST(req: Request) {
  const params = await req.json()
  const stream = await handleWorkflowStream({
    mastra,
    workflowId: 'weatherWorkflow',
    params,
  })
  return createUIMessageStreamResponse({ stream })
}

매개변수
매개변수에 대한 직접 링크

version?:

'v5' | 'v6'
= 'v5'
출력할 AI SDK 스트림 계약을 선택합니다. 기존 기본 동작을 사용하려면 생략하거나 'v5'를 전달하세요. 앱이 AI SDK v6 응답 헬퍼를 기준으로 타입이 지정된 경우 'v6'을 전달하세요.

mastra:

Mastra
등록된 Workflow를 포함하는 Mastra 인스턴스입니다.

workflowId:

string
실행할 Workflow의 ID입니다.

params:

WorkflowStreamHandlerParams
Workflow 스트림의 매개변수입니다.

params.runId?:

string
Workflow 실행에 사용할 선택적 실행 ID입니다.

params.resourceId?:

string
Workflow 실행에 사용할 선택적 리소스 ID입니다.

params.inputData?:

Record<string, any>
새 Workflow 실행을 시작하기 위한 입력 데이터입니다.

params.resumeData?:

Record<string, any>
일시 중단된 Workflow 실행을 재개하기 위한 데이터입니다.

params.requestContext?:

RequestContext
Workflow 실행에 전달할 요청 컨텍스트입니다.

params.tracingOptions?:

TracingOptions
추적 및 Observability 옵션입니다.

params.step?:

string
Workflow에서 대상으로 지정할 특정 단계입니다.

includeTextStreamParts?:

boolean
= true
출력에 텍스트 스트림 부분을 포함할지 여부입니다.
On this page