
关于
工作流自动化是让 AI 代理发挥作用的基础设施。帮助设计和实现自动化工作流。
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 ─┘
兼容工具
Claude CodeCursor
标签
运维部署

