Skip to Content
ドキュメントワークフロー複雑なLLM操作の処理 | ワークフロー | Mastra

ワークフローを使用した複雑なLLM操作の処理

Mastraのワークフローは、分岐、並列実行、リソースの一時停止などの機能を使用して、複雑な操作のシーケンスを調整するのに役立ちます。

ワークフローを使用するタイミング

ほとんどのAIアプリケーションは、言語モデルへの単一の呼び出し以上のものを必要とします。複数のステップを実行したり、特定のパスを条件付きでスキップしたり、ユーザー入力を受け取るまで実行を一時停止したりすることがあるかもしれません。時には、エージェントツールの呼び出しが十分に正確でないこともあります。

Mastraのワークフローシステムは以下を提供します：

  • ステップを定義し、それらを結びつけるための標準化された方法。
  • 単純（線形）および高度（分岐、並列）パスの両方をサポート。
  • 各ワークフローの実行を追跡するためのデバッグおよび可観測性機能。

例

ワークフローを作成するには、1つ以上のステップを定義し、それらをリンクしてから、開始する前にワークフローをコミットします。

ワークフローの分解

ワークフロー作成プロセスの各部分を見てみましょう：

1. ワークフローの作成

Mastraでワークフローを定義する方法は次のとおりです。nameフィールドはワークフローのAPIエンドポイント（/workflows/$NAME/）を決定し、triggerSchemaはワークフローのトリガーデータの構造を定義します：

src/mastra/workflow/index.ts
const myWorkflow = new Workflow({
  name: "my-workflow",
  triggerSchema: z.object({
    inputValue: z.number(),
  }),
});

2. ステップの定義

次に、ワークフローのステップを定義します。各ステップは独自の入力および出力スキーマを持つことができます。ここでは、stepOneが入力値を2倍にし、stepTwoがstepOneが成功した場合にその結果をインクリメントします。（簡単にするために、この例ではLLM呼び出しは行っていません）：

src/mastra/workflow/index.ts
const stepOne = new Step({
  id: "stepOne",
  outputSchema: z.object({
    doubledValue: z.number(),
  }),
  execute: async ({ context }) => {
    const doubledValue = context.triggerData.inputValue * 2;
    return { doubledValue };
  },
});
 
const stepTwo = new Step({
  id: "stepTwo",
  execute: async ({ context }) => {
    const doubledValue = context.getStepResult(stepOne)?.doubledValue;
    if (!doubledValue) {
      return { incrementedValue: 0 };
    }
    return {
      incrementedValue: doubledValue + 1,
    };
  },
});

3. ステップのリンク

次に、制御フローを作成し、ワークフローを「コミット」（最終化）します。この場合、stepOneが最初に実行され、その後にstepTwoが続きます。

src/mastra/workflow/index.ts
myWorkflow.step(stepOne).then(stepTwo).commit();

ワークフローの登録

Mastraにワークフローを登録して、ログとテレメトリを有効にします：

src/mastra/index.ts
import { Mastra } from "@mastra/core";
 
export const mastra = new Mastra({
  workflows: { myWorkflow },
});

動的なワークフローを作成する必要がある場合には、mastraインスタンスをコンテキストに注入することもできます：

src/mastra/workflow/index.ts
import { Mastra } from "@mastra/core";
 
const mastra = new Mastra();
 
const myWorkflow = new Workflow({
  name: "my-workflow",
  mastra,
});

ワークフローの実行

プログラム的にまたはAPI経由でワークフローを実行します：

src/mastra/run-workflow.ts
import { mastra } from "./index";
 
// ワークフローを取得
const myWorkflow = mastra.getWorkflow("myWorkflow");
const { runId, start } = myWorkflow.createRun();
 
// ワークフローの実行を開始
await start({ triggerData: { inputValue: 45 } });

またはAPIを使用します（mastra devを実行する必要があります）：

// ワークフロー実行の作成

curl --location 'http://localhost:4111/api/workflows/myWorkflow/start-async' \
     --header 'Content-Type: application/json' \
     --data '{
       "inputValue": 45
     }'

この例は基本を示しています：ワークフローを定義し、ステップを追加し、ワークフローをコミットし、それから実行します。

ステップの定義

ワークフローの基本的な構成要素はステップです。ステップは入力と出力のスキーマを使用して定義され、前のステップの結果を取得することができます。

フロー制御

ワークフローを使用すると、並列ステップ、分岐パスなどでステップを連鎖させるフロー制御を定義できます。

ワークフロー変数

ステップ間でデータをマッピングしたり、動的なデータフローを作成する必要がある場合、ワークフロー変数は、情報をあるステップから別のステップに渡し、ステップ出力内のネストされたプロパティにアクセスするための強力なメカニズムを提供します。

可観測性とデバッグ

Mastraワークフローは自動的にワークフロー実行内の各ステップの入力と出力をログに記録し、このデータを好みのロギング、テレメトリ、または可観測性ツールに送信できるようにします。

以下のことが可能です：

  • 各ステップのステータス（例：success、error、またはsuspended）を追跡する。
  • 分析のための実行固有のメタデータを保存する。
  • ログを転送することで、DatadogやNew Relicなどのサードパーティの可観測性プラットフォームと統合する。

## その他のリソース

- ガイドセクションの[ワークフローガイド](../guides/ai-recruiter.mdx)は、主要な概念をカバーするチュートリアルです。
- [シーケンシャルステップのワークフロー例](../../examples/workflows/sequential-steps.mdx)
- [並列ステップのワークフロー例](../../examples/workflows/parallel-steps.mdx)
- [分岐パスのワークフロー例](../../examples/workflows/branching-paths.mdx)
- [ワークフロー変数の例](../../examples/workflows/workflow-variables.mdx)
- [循環依存関係のワークフロー例](../../examples/workflows/cyclical-dependencies.mdx)
- [一時停止と再開のワークフロー例](../../examples/workflows/suspend-and-resume.mdx)
ネストされたワークフローランタイム変数 - 依存性注入 | ワークフロー | Mastra ドキュメント