Workflows

多步骤、可重试、可暂停/恢复的长流程编排。

官方文档 ↗

按步骤次数计费；空闲等待不计费。

编排长任务

适合场景

订单流程、AI pipeline、数据处理、审批流

Wrangler 配置

{
  "workflows": [
    { "binding": "ORDER", "name": "order-flow", "class_name": "OrderFlow" }
  ]
}

Worker 代码

import { WorkflowEntrypoint } from "cloudflare:workers";

export class OrderFlow extends WorkflowEntrypoint {
  async run(event, step) {
    const order = await step.do("create", () => createOrder(event.payload));
    await step.sleep("wait-payment", "10 minutes");
    await step.do("notify", () => sendEmail(order));
  }
}

实现注意事项

● 每个 step 必须幂等；失败会从该 step 重试
● 不是 Queues 的替代；Workflows 管多步骤流程，Queues 管消息缓冲
● 整体可暂停最长 1 年；不适合需要毫秒响应的任务

已复制