Vercel AI SDK を用いたマルチエージェント研究システムの構築

pnpm add ai @ai-sdk/anthropic @valyu/ai-sdk @ai-sdk/react zod valyu-js

ANTHROPIC_API_KEY=your_key_here
VALYU_API_KEY=your_key_here

research-nexus/
├── src/
│   ├── agents/
│   │   ├── financial-analyst.ts   # Financial analyst
│   │   ├── scientist.ts  # Scientist
│   │   ├── journalist.ts          # Journalist
│   │   └── orchestrator.ts        # Query router + synthesizer
│   └── app/
│       └── api/
│           └── chat/
│               └── route.ts       # Next.js API route
└── package.json

import { ToolLoopAgent } from "ai";
import { anthropic } from "@ai-sdk/anthropic";
import { secSearch, financeSearch, economicsSearch } from "@valyu/ai-sdk";

import { ToolLoopAgent } from \"ai\";
import { anthropic } from \"@ai-sdk/anthropic\";
import { bioSearch, paperSearch } from \"@valyu/ai-sdk\";

export const medicalResearcherAgent = new ToolLoopAgent({
  model: anthropic(\"claude-haiku-4-5-20251001\"),
  instructions: `あなたは臨床試験、薬物発見、および生物医学文献に専門知識を持つ医療・生命科学研究の専門家です。

あなたの能力:
- 臨床試験データベースを検索して試験の状況、結果、主要評価項目を調べる
- FDAの薬剤ラベル、承認、および安全情報を調べる
- PubMed、bioRxiv、medRxivの生物医学文献を調査する
- 薬、治療法、医療機器に関する学術論文を分析する

回答時:
- 試験ID（NCT番号）、DOI、または出版参照を常に引用する
- 予備的な発見と査読済みの発見を明確に区別する
- 臨床試験の段階と主要なエンドポイントを記載する
- データに言及されている安全上の懸念や有害事象を指摘する
- 必要に応じて正確な医療用語を使用し、説明する`,
  tools: {
    bioSearch: bioSearch({ maxNumResults: 3, responseLength: \"short\" `),
    paperSearch: paperSearch({ maxNumResults: 3, responseLength: \"short\" `),
  },
});

import { ToolLoopAgent } from \"ai\";
import { anthropic } from \"@ai-sdk/anthropic\";
import { webSearch } from \"@valyu/ai-sdk\";

export const journalistAgent = new ToolLoopAgent({
  model: anthropic(\"claude-haiku-4-5-20251001\"),
  instructions: `あなたはリアルタイムのウェブソースにアクセスできる調査ジャーナリストおよびニュース分析家です。

あなたの能力:
- 最新のニュースと時事をウェブ上で検索する
- トピックに関して複数のニュースソースを検索し、相互参照する
- 展開中の報道を追跡し、時系列の文脈を提供する
- 人物、組織、イベントの背景を調査する

返却形式: {\"translated\": \"翻訳されたHTML\"}`,
  tools: {
    webSearch: webSearch({ maxNumResults: 3, responseLength: \"short\" `),
  },
});

import { ToolLoopAgent, tool, stepCountIs } from "ai";
import { anthropic } from "@ai-sdk/anthropic";
import { z } from "zod";
import { financialAnalystAgent } from "./financial-analyst";
import { scientistAgent } from "./scientist";
import { journalistAgent } from "./journalist";

const financialAnalystTool = tool({
  description:
    "Delegate to the Financial Analyst agent for SEC filings, stock data, earnings reports, economic indicators, and financial analysis.",
  inputSchema: z.object({
    task: z.string().describe("The financial research task to complete"),
  }),
  execute: async ({ task }, { abortSignal }) => {
    const result = await financialAnalystAgent.generate({
      prompt: task,
      abortSignal,
    });
    return result.text;
  },
});

const scientistTool = tool({
  description:
    "Delegate to the Scientist agent for clinical trials, drug information, FDA data, biomedical papers, and life sciences research.",
  inputSchema: z.object({
    task: z.string().describe("The medical/life sciences research task to complete"),
  }),
  execute: async ({ task }, { abortSignal }) => {
    const result = await scientistAgent.generate({
      prompt: task,
      abortSignal,
    });
    return result.text;
  },
});

返却形式: {const journalistTool = tool({
  description:
    "ジャーナリストエージェントにリアルタイムのニュース、時事、速報、および任意のトピックに関するウェブベースのリサーチを委任します。",
  inputSchema: z.object({
    task: z.string().describe("完了するニュース/リサーチのタスク"),
  }),
  execute: async ({ task }, { abortSignal }) => {
    const result = await journalistAgent.generate({
      prompt: task,
      abortSignal,
    });
    return result.text;
  },
});

export const orchestratorAgent = new ToolLoopAgent({
  model: anthropic("claude-haiku-4-5-20251001"),
  instructions: `You are a research orchestrator that routes queries to specialized agents.

You have three specialist agents available:
1. **Financial Analyst** — SEC filings, stock data, earnings, financial statements, economic data
2. **Scientist** — Clinical trials, drug discovery, FDA data, biomedical papers
3. **Journalist** — Real-time news, current events, web research

Your job:
- Analyze the user's query and delegate to the right specialist(s)
- For questions that span multiple domains, call multiple agents
- Synthesize results from multiple agents into a coherent response
- If a query doesn't fit any specialist, answer it yourself
- Always be clear about which sources informed your response`,
  tools: {
    financialAnalyst: financialAnalystTool,
    scientist: scientistTool,
    journalist: journalistTool,
  },
  stopWhen: stepCountIs(10),
});

// app/api/chat/route.ts
import { createAgentUIStreamResponse } from "ai";
import { orchestratorAgent } from "@/agents/orchestrator";

export async function POST(request: Request) {
  const { messages } = await request.json();

  return createAgentUIStreamResponse({
    agent: orchestratorAgent,
    uiMessages: messages,
  });
}

pnpm dev