Trigger.dev で自律AIエージェントを24時間運用する — ローコード卒業のアーキテクチャ

# Trigger.dev プロジェクトの初期化
npx create-trigger@latest ai-research-agent
cd ai-research-agent
 
# 依存パッケージのインストール
npm install @anthropic-ai/sdk @trigger.dev/sdk

import { schedules } from "@trigger.dev/sdk/v3";
 
// 毎日午前9時にリサーチを実行
export const dailyResearch = schedules.task({
  id: "daily-ai-research",
  cron: "0 9 * * *",
  maxDuration: 7200, // 最大2時間
  run: async () => {
    const topics = await fetchTodayTopics();
 
    for (const topic of topics) {
      // 各トピックを並列で処理
      await myAiAgent.trigger({ topic });
    }
  }
});

import { task, wait } from "@trigger.dev/sdk/v3";
import Anthropic from "@anthropic-ai/sdk";
 
const anthropic = new Anthropic();
 
export const multiStepResearch = task({
  id: "multi-step-research",
  maxDuration: 14400,
  run: async (payload: { query: string; depth: number }) => {
    const results: string[] = [];
 
    // Phase 1: 初回調査
    const initialResearch = await anthropic.messages.create({
      model: "claude-sonnet-4-6",
      max_tokens: 4096,
      messages: [{
        role: "user",
        content: `以下のトピックについて調査し、さらに深掘りすべきサブトピックを3つ提案してください: ${payload.query}`
      }]
    });
    results.push(initialResearch.content[0].type === "text"
      ? initialResearch.content[0].text : "");
 
    // Phase 2: サブトピックの深掘り（再帰的に実行可能）
    if (payload.depth > 0) {
      const subtopics = extractSubtopics(results[0]);
 
      for (const subtopic of subtopics) {
        // 各サブトピックを独立したタスクとして実行
        const subResult = await multiStepResearch.triggerAndWait({
          query: subtopic,
          depth: payload.depth - 1
        });
        results.push(JSON.stringify(subResult));
      }
    }
 
    // Phase 3: 統合レポート生成
    const finalReport = await anthropic.messages.create({
      model: "claude-sonnet-4-6",
      max_tokens: 8192,
      messages: [{
        role: "user",
        content: `以下の調査結果を統合し、包括的なレポートを作成してください:\n${results.join("\n---\n")}`
      }]
    });
 
    return {
      query: payload.query,
      report: finalReport.content[0].type === "text"
        ? finalReport.content[0].text : "",
      depth: payload.depth,
      subtopicCount: results.length - 1
    };
  }
});
 
function extractSubtopics(text: string): string[] {
  // テキストからサブトピックを抽出するロジック
  const lines = text.split("\n").filter(l => l.match(/^\d+\./));
  return lines.slice(0, 3).map(l => l.replace(/^\d+\.\s*/, ""));
}

import { task } from "@trigger.dev/sdk/v3";
 
// 外部イベント（GitHub Issue作成など）をトリガー
export const onNewIssue = task({
  id: "github-issue-analyzer",
  run: async (payload: { title: string; body: string; repo: string }) => {
    // Issue の内容をAIで分析
    const analysis = await anthropic.messages.create({
      model: "claude-sonnet-4-6",
      max_tokens: 2048,
      messages: [{
        role: "user",
        content: `以下のGitHub Issueを分析し、優先度・カテゴリ・推奨対応を提案してください:\nTitle: ${payload.title}\nBody: ${payload.body}`
      }]
    });
 
    // 分析結果をSlackに通知
    await sendSlackMessage({
      channel: "#dev-alerts",
      text: analysis.content[0].type === "text"
        ? analysis.content[0].text : "Analysis failed"
    });
 
    return { analyzed: true };
  }
});

# docker-compose.yml
version: "3.8"
 
services:
  trigger-dev:
    image: ghcr.io/triggerdotdev/trigger.dev:latest
    ports:
      - "3030:3030"
    environment:
      - DATABASE_URL=postgresql://trigger:password@postgres:5432/trigger
      - REDIS_URL=redis://redis:6379
      - SECRET_KEY=your-secret-key
    depends_on:
      - postgres
      - redis
 
  postgres:
    image: postgres:16
    environment:
      - POSTGRES_USER=trigger
      - POSTGRES_PASSWORD=password
      - POSTGRES_DB=trigger
    volumes:
      - postgres_data:/var/lib/postgresql/data
 
  redis:
    image: redis:7-alpine
    volumes:
      - redis_data:/data
 
volumes:
  postgres_data:
  redis_data:

# 起動
docker compose up -d
 
# ダッシュボードにアクセス
# http://localhost:3030