React Router v7 × Vercel AI SDKで作る自律的マルチステップAIエージェント
はじめに
React Router v7とVercel AI SDK v5を使って、自律的なマルチステップAIエージェント「scalpingAgent」を作ってみました。
スキャルピングとは、株の超短期トレードのことで、数分〜30分以内に取引を完了させるデイトレードのひとつです。今回のエージェントは、スキャルピングで利益を上げられそうな銘柄とその要因を抽出するものです。
このシステムの最大の特徴は、Vercel AI SDK v5のstreamTextとstopWhen機能を活用して、AIがプロンプトに基づいて自分で考え、適切なツールを選択し、5段階の研究プロセスを自律的に実行するところにあります。
デモ動画
実際にscalpingAgentが動作している様子です:
React Router v7 × Vercel AI SDK v5 の統合
フロントエンドではReact Router v7のResource Route(API Route)とVercel AI SDK v5のuseChatを組み合わせています:
// フロントエンド(React Component)
import { useState } from 'react'
import { useChat } from 'ai/react'
export default function ScalpingResearch() {
const [input, setInput] = useState('')
const { messages, sendMessage, status } = useChat({
api: '/autonomous/api', // Resource Route endpoint
})
const handleSubmit = (e: React.FormEvent) => {
e.preventDefault()
sendMessage({ text: input })
setInput('')
}
return (
<div>
{messages.map(message => (
<div key={message.id}>{message.content}</div>
))}
<form onSubmit={handleSubmit}>
<input
value={input}
onChange={(e) => setInput(e.target.value)}
disabled={status === 'streaming'}
/>
<button type="submit" disabled={status === 'streaming'}>
送信
</button>
</form>
</div>
)
}
// Resource Route(API Route)
export const action = async ({ request }: Route.ActionArgs) => {
const { messages } = (await request.json()) as { messages: UIMessage[] }
const result = await runScalpingAgent(messages)
return result.toDataStreamResponse()
}
v5での主な変更点
v5ではuseChatフックの使い方が変わりました:
-
入力状態の管理:v4では
inputとhandleInputChangeが提供されていましたが、v5ではuseStateで手動管理 -
メッセージ送信:
append()がsendMessage()に変更 -
状態管理:
isLoadingがstatusに変更('ready'|'streaming'|'submitted'|'error')
この構成で、useChatが自動的にストリーミングレスポンスを処理し、AIの思考過程をリアルタイムで表示できるようになりました。
自律的マルチステップ実行の仕組み
Vercel AI SDK v5のコア設定
import { streamText, stepCountIs, hasToolCall } from 'ai'
import { google } from '@ai-sdk/google'
export async function runScalpingAgent(messages: Message[]) {
return await streamText({
model: google('gemini-2.5-flash'),
tools, // カスタムツール群
toolCallStreaming: true, // ツール実行をストリーミング
stopWhen: [ // ← v5での推奨パターン
stepCountIs(20), // 最大20ステップまで実行
hasToolCall('final_report') // final_reportツールが呼ばれたら終了
],
system: systemPrompt,
messages,
})
}
Vercel AI SDK v5のstopWhen でAIの自律的な実行を制御します。v5ではmaxStepsパラメータが削除され、代わりにstopWhenを使って停止条件を定義します。
-
stepCountIs(20):最大20ステップまで実行(無限ループ防止) -
hasToolCall('final_report'):final_reportツールが呼ばれたら研究完了と判断して終了
複数の停止条件を配列で指定でき、いずれかの条件を満たすと処理が終了します。これで5段階の研究プロセスが完了したら確実に終了するようになります。
カスタムツールの定義
Vercel AI SDK v5のtool関数を使ってカスタムツールを定義しました:
import { tool } from 'ai'
import { z } from 'zod'
const tools = {
get_market_overview: tool({
description: '市場の概況を取得(日経平均、TOPIX、USD/JPY)',
inputSchema: z.object({}),
execute: async () => {
// Yahoo Finance APIからデータ取得
}
}),
get_stock_rankings: tool({
description: '株式ランキングを取得(値上がり率・出来高)',
inputSchema: z.object({
limit: z.number().default(20)
}),
execute: async ({ limit }) => {
// ランキングデータ取得
}
}),
// analyze_stocks, evaluate_strategies, final_report...
}
5つのツールをAIが状況に応じて選択・実行します:
-
get_market_overview- 市場概況取得 -
get_stock_rankings- 銘柄ランキング取得 -
analyze_stocks- 複数銘柄の詳細分析 -
evaluate_strategies- 3つの戦略での評価 -
final_report- 最終レポート生成
実際のシステムプロンプト
# 東証スキャルピング研究エージェント - 段階的分析システム
あなたは科学的手法を用いて段階的にスキャルピング機会を研究する専門エージェントです。
DeepResearchのように、仮説→検証→結論のサイクルを通じて最適解を発見します。
## 🔬 研究プロセス(5段階)
### 段階1: 市場環境分析
**目的**: 今日の市場の特徴を把握し、有効な戦略仮説を構築
**ツール**: 'get_market_overview'
**出力**: 日経平均、TOPIX、USD/JPYの価格と変動率データ
**仮説例**: "高ボラティリティ環境 → Livermore戦略が有効"
### 段階2: 候補銘柄の発見
**目的**: 仮説に基づき有望な銘柄を収集。最低20銘柄を抽出。
**ツール**: 'get_stock_rankings' (limit: 20)
**出力**: 値上がりランキングと出来高ランキングの構造化データ
**思考**: "どの条件の銘柄が今日の環境に適しているか?"
**データ処理**: ランキング結果から、value_upとvolumeの上位銘柄のcodeを抽出し、重複を除いて最大20銘柄のシンボル配列として段階3に渡すこと
### 段階3: 詳細分析・検証
**目的**: 候補銘柄の詳細な特性を分析
**ツール**: 'analyze_stocks' (段階2で抽出したシンボル配列を入力として使用)
**入力**: シンボル配列 例: ["6098", "3994", "7203", ...]
**出力**: 各銘柄の流動性・モメンタム・ボラティリティスコア、技術指標(SMA5/25/75)、トレンド判定
**検証**: "仮説通りの特性を持つか?技術指標は何を示している?予想と異なる点は?"
### 段階4: 戦略適用・評価
**目的**: 段階3の分析結果を受けて、3つの戦略で総合評価し比較
**ツール**: 'evaluate_strategies' (段階3の結果を入力として受け取る)
**入力**: 段階3のanalysisResults(rankings配列)
**出力**: 各銘柄の戦略別スコア、最適戦略、トレーディングプラン(エントリー/ターゲット/ストップロス価格)
**比較**: "どの戦略が最も適しているか?なぜそう判断するか?"
### 段階5: 最終レポート作成 ⚠️【必須実行】
**目的**: 段階1-4の全ての結果をまとめて最終レポートを作成
**ツール**: 'final_report'
**入力**:
- researchSummary: 今回の研究で分かったことを要約
- executionRecommendations: 具体的な銘柄と取引プラン
- cautions: 注意事項とリスク警告
**出力**: 3セクション構成の最終レポート
**重要**: final_reportツール実行後は、重複した内容は抑え、ユーザに質問を促す形で終了してください。
## 🎯 3つのスキャルピング戦略
### Livermore戦略(勢い重視)
- **利幅**: 2.5-3.5% | **リスク**: 高 | **適用**: 強トレンド・高ボラティリティ
- **重視**: モメンタム50%, 流動性30%, ボラティリティ20%
### Niederhoffer戦略(統計重視)
- **利幅**: 1.5% | **リスク**: 中 | **適用**: 安定環境・統計的優位性
- **重視**: モメンタム30%, 流動性50%, ボラティリティ20%
### Harris戦略(流動性重視)
- **利幅**: 0.8% | **リスク**: 低 | **適用**: 超高流動性・低ボラティリティ
- **重視**: モメンタム20%, 流動性60%, ボラティリティ20%
## 📋 研究原則
- 各段階で仮説→検証→結論のサイクルを実行
- データに基づく客観的判断、予想外の発見も報告
- 初心者向けの実行可能な推奨事項を提示
- 研究者として、データに基づく客観的分析と、実用的な推奨事項の両立を心がける
## ⚠️ 制約・注意事項
- データは遅延あり、市場時間外(前場9:00-11:30、後場12:30-15:30以外)は更新停止
- 個別銘柄取得失敗時は除外して続行、最低10銘柄確保
- 買いポジションのみ、30分以内取引、ストップロス必須
## 目標
30分以内に1-3%の利益を安全に狙える銘柄を発見し、初心者でも実行できる具体的な推奨事項を提示する。
## 実行方針
5段階の研究プロセスに従って体系的に進める:
**各段階で必須**:
- **仮説**: その段階で検証したい仮説を明確に述べる
- **思考過程**: なぜその判断・選択をしたかの理由を説明
- **検証結果**: データから分かったことと予想との比較
- **次段階への示唆**: この結果が次の段階にどう影響するか
このプロンプトで、AIが5段階のプロセスを自律的に実行し、各段階で仮説を立て、検証し、次段階への判断を行うようになりました。
実際の動作フロー
自律的実行の例
AIはこんな感じで自律的に判断していきます:
-
市場分析後の判断
- 「日経平均が+2%上昇 → 高ボラティリティと判断 → Livermore戦略を重視」
-
銘柄選択の判断
- 「値上がり率と出来高の両方にランクインした銘柄を優先」
-
分析結果の解釈
- 「SMA5がSMA25を上抜け → 上昇トレンドと判断」
-
戦略の選択
- 「高流動性・高モメンタムの銘柄 → Livermore戦略が最適」
Vercel AI SDK v5のstopWhenが実現するマルチステップ実行
import { stepCountIs, hasToolCall } from 'ai'
stopWhen: [
stepCountIs(20), // 最大20ステップまで自律実行
hasToolCall('final_report') // final_reportツールが呼ばれたら終了
]
従来のAIツール実行と何が違うのか
- v4以前(maxSteps):ステップ数のみで制御、柔軟性に欠ける
- Vercel AI SDK v5(stopWhen):AIが判断しながら複数のツールを連続実行し、複数の停止条件を組み合わせて確実に完了
v5のstopWhenの利点
-
柔軟な停止条件:
stepCountIs()やhasToolCall()などのヘルパーを組み合わせられる - ツールチェーン:前のツールの結果を次のツールに自動的に渡す
- 状態管理:複数ステップ間での状態を自動管理
- エラーハンドリング:個別ツールの失敗を適切に処理
- ストリーミング:各ステップの進捗をリアルタイム表示
stopWhenの動作
stopWhenの条件は、最後のステップにtool resultsが含まれる場合のみ評価されます。今回のケースでは:
-
stepCountIs(20):無限ループを防ぐための上限 -
hasToolCall('final_report'):研究プロセスが完了したことを示すシグナル
いずれかの条件を満たすと処理が終了します。この設定で、AIは人間の介入なしに5段階すべてを完遂できるようになります。
実装のポイント
1. ツール間のデータ連携
// 段階2の出力
{
symbols: ["6098", "3994", "7203", ...] // シンボル配列
}
// 段階3はこの配列を入力として受け取る
{
symbols: ["6098", "3994", "7203", ...] // 前段階の出力を使用
}
2. プロンプトでの明確な指示
**データ処理**: ランキング結果から、value_upとvolumeの上位銘柄のcodeを抽出し、
重複を除いて最大20銘柄のシンボル配列として段階3に渡すこと
3. エラーハンドリング
個別銘柄の取得に失敗しても、AIは判断して処理を継続:
- 個別銘柄取得失敗時は除外して続行、最低10銘柄確保
まとめ
scalpingAgentを作ってみて、Vercel AI SDK v5の強力な機能をフル活用できたと感じています。
特にこんな点が良かったです:
-
stopWhenとstepCountIs()/hasToolCall()で柔軟な停止条件を定義できる -
tool関数とinputSchemaでZodスキーマベースのツール定義が簡単 -
toolCallStreamingで進捗をリアルタイム表示できる -
streamTextで高速なレスポンスが得られる
v4からv5への主な変更点
この記事で使用しているAPI機能について、v4からの主な変更点をまとめておきます:
| 項目 | v4 | v5 |
|---|---|---|
| マルチステップ制御 | maxSteps: 20 |
stopWhen: [stepCountIs(20), hasToolCall('tool')] |
| ツール定義 | createTool({ parameters: z.object({}) }) |
tool({ inputSchema: z.object({}) }) |
| useChat入力管理 |
input, handleInputChange (内部管理) |
useStateで手動管理 |
| メッセージ送信 | append() |
sendMessage() |
| 状態管理 | isLoading |
status ('ready' | 'streaming' など) |
v5ではmaxStepsが削除され、より柔軟なstopWhenに置き換わったことで、「最大ステップ数」と「特定ツールの呼び出し」など、複数の停止条件を組み合わせられるようになりました。
AIエージェントが人間のアナリストのように、仮説を立て、データを収集し、分析し、結論を導くプロセスを自律的に実行できるようになったのが、この実装の肝です。
Vercel AI SDK v5を使うと、複雑なマルチステップAIワークフローも簡単に実装できるので、この設計パターンは他の分析タスクにも応用できそうです。
実際のトレード実績
このリサーチシステムを使って実際にトレードしてみた結果です:
| 月 | 取引回数 | 損益 |
|---|---|---|
| 3月の合計 | 13 | ¥-122,340 |
| 4月の合計 | 17 | ¥23,380 |
| 5月の合計 | 24 | ¥126,890 |
| 6月の合計 | 20 | ¥92,186 |
| 総計 | 74 | ¥120,116 |
初月は損失を出してしまいましたが、システムの改善とともに安定して利益を出せるようになりました。
お知らせ
この記事の内容について、6/23(月) 19:00 からの Remix Tokyo で Lightning Talk でお話します。よかったらぜひご参加ください。
Discussion