Trigger.dev：构建完全托管的AI代理与工作流

项目简介

Trigger.dev 是一个开源平台，专为构建和部署完全托管的AI代理及长运行工作流而设计。它解决了传统Serverless架构中常见的超时问题，支持任务重试、队列管理、可观测性和弹性扩展。无论你需要构建AI内容生成管线、数据处理管道还是复杂的Agent编排，Trigger.dev 都能让你用TypeScript以同步方式编写异步逻辑，大幅降低开发复杂度。

如果你对Agent编排系统感兴趣，还可以参考我们的 OpenFang Agent OS教程 了解另一种Agent操作系统架构。

核心功能与架构

安装指南

首先安装 Trigger.dev CLI工具和SDK：

# 安装 CLI
npm install -g @trigger.dev/cli

# 初始化项目
npx @trigger.dev/init@latest

# 安装 SDK
npm install @trigger.dev/sdk

# 登录（使用云服务或自托管）
npx trigger.dev login

初始化完成后，会生成 trigger.config.ts 配置文件和 src/trigger/ 目录。

使用示例

以下是一个完整的AI代理工作流示例，包含任务定义、触发器和错误处理：

// src/trigger/ai-agent.ts
import { task, retry } from "@trigger.dev/sdk";
import { openai } from "@trigger.dev/openai";

// 定义AI内容生成任务
export const generateContent = task({
  id: "generate-content",
  maxDuration: 300, // 5分钟超时
  retry: {
    maxAttempts: 3,
    minTimeout: 1000,
    factor: 2,
  },
  run: async (payload: { topic: string; tone: string }) => {
    const response = await openai.chat.completions.create({
      model: "gpt-4",
      messages: [
        { role: "system", content: `用${payload.tone}的语气写作` },
        { role: "user", content: `写一篇关于${payload.topic}的文章` },
      ],
    });

    return {
      content: response.choices[0].message.content,
      tokens: response.usage.total_tokens,
    };
  },
});

// 定义批处理工作流
export const batchWorkflow = task({
  id: "batch-content-workflow",
  run: async (payload: { topics: string[] }) => {
    const results = await Promise.all(
      payload.topics.map((topic) =>
        generateContent.triggerAndWait({ topic, tone: "专业" })
      )
    );
    return { total: results.length, items: results };
  },
});

部署任务到Trigger.dev平台：

# 部署所有任务
npx trigger.dev deploy

# 查看运行日志
npx trigger.dev runs list

# 实时查看日志
npx trigger.dev runs logs <run-id>

与其他工具对比

如果你想了解可视化的工作流方案，推荐阅读 n8n工作流自动化教程 进行对比学习。