---

name: workflow-automation description: 工作流自动化是让 AI 代理可靠运行的基础设施。没有持久执行机制，10 步支付流程中的一次网络故障就意味着资金损失和客户投诉。有了它，工作流可以从中断处精确恢复。 risk: critical source: vibeship-spawner-skills (Apache 2.0) date_added: 2026-02-27

工作流自动化

工作流自动化是让 AI 代理可靠运行的基础设施。没有持久执行机制，10 步支付流程中的一次网络故障就意味着资金损失和客户投诉。有了它，工作流可以从中断处精确恢复。

本技能涵盖将脆弱脚本转变为生产级自动化的平台（n8n、Temporal、Inngest）和模式（顺序、并行、编排器-工作者）。

核心洞察：各平台做出了不同的权衡。n8n 优化易用性，Temporal 优化正确性，Inngest 优化开发者体验。根据实际需求选择，而非跟风。

原则

• 对于涉及资金或状态关键的工作流，持久执行不可妥协
• 事件是工作流触发器的通用语言
• 步骤即检查点——每个步骤都应可独立重试
• 从简单开始，仅在可靠性要求时增加复杂度
• 可观测性不是可选项——你需要看到工作流在哪里失败
• 工作流和代理共同演进——为两者而设计

能力

• workflow-automation
• workflow-orchestration
• durable-execution
• event-driven-workflows
• step-functions
• job-queues
• background-jobs
• scheduled-tasks

范围

• multi-agent-coordination → multi-agent-orchestration
• ci-cd-pipelines → devops
• data-pipelines → data-engineer
• api-design → api-designer

工具

平台

• n8n - 适用场景：低代码自动化、快速原型、非技术用户 备注：可自托管，400+ 集成，适合可视化工作流
• Temporal - 适用场景：关键任务工作流、金融交易、微服务 备注：最强持久性保证，学习曲线较陡
• Inngest - 适用场景：事件驱动无服务器、TypeScript 代码库、AI 工作流 备注：最佳开发者体验，兼容任何托管方式
• AWS Step Functions - 适用场景：AWS 原生技术栈、现有 Lambda 函数 备注：紧密 AWS 集成，基于 JSON 的工作流定义
• Azure Durable Functions - 适用场景：Azure 技术栈、.NET 或 TypeScript 备注：良好的 AI 代理支持，检查点和重放

模式

顺序工作流模式

步骤按顺序执行，每个输出成为下一个输入

适用场景：内容管道、数据处理、有序操作

顺序工作流：

Step 1 → Step 2 → Step 3 → Output
  ↓         ↓         ↓
(checkpoint at each step)

Inngest 示例 (TypeScript)

import { inngest } from "./client";

export const processOrder = inngest.createFunction(
  { id: "process-order" },
  { event: "order/created" },
  async ({ event, step }) => {
    // Step 1: Validate order
    const validated = await step.run("validate-order", async () => {
      return validateOrder(event.data.order);
    });

    // Step 2: Process payment (durable - survives crashes)
    const payment = await step.run("process-payment", async () => {
      return chargeCard(validated.paymentMethod, validated.total);
    });

    // Step 3: Create shipment
    const shipment = await step.run("create-shipment", async () => {
      return createShipment(validated.items, validated.address);
    });

    // Step 4: Send confirmation
    await step.run("send-confirmation", async () => {
      return sendEmail(validated.email, { payment, shipment });
    });

    return { success: true, orderId: event.data.orderId };
  }
);

Temporal 示例 (TypeScript)

import { proxyActivities } from '@temporalio/workflow';
import type * as activities from './activities';

const { validateOrder, chargeCard, createShipment, sendEmail } =
  proxyActivities<typeof activities>({
    startToCloseTimeout: '30 seconds',
    retry: {
      maximumAttempts: 3,
      backoffCoefficient: 2,
    }
  });

export async function processOrderWorkflow(order: Order): Promise<void> {
  const validated = await validateOrder(order);
  const payment = await chargeCard(validated.paymentMethod, validated.total);
  const shipment = await createShipment(validated.items, validated.address);
  await sendEmail(validated.email, { payment, shipment });
}

n8n 模式

[Webhook: order.created]
    ↓
[HTTP Request: Validate Order]
    ↓
[HTTP Request: Process Payment]
    ↓
[HTTP Request: Create Shipment]
    ↓
[Send Email: Confirmation]

Configure each node with retry on failure.
Use Error Trigger for dead letter handling.

并行工作流模式

独立步骤同时运行，聚合结果

适用场景：多个独立分析、来自多个数据源的数据

并行工作流：

        ┌→ Step A ─┐
Input ──┼→ Step B ─┼→ Aggregate → Output
        └→ Step C ─┘