使用 Replicate 轮询循环实现异步 AI 生成 - n8n 工作流

AI 开发者与集成工程师： 需要将耗时较长的异步 AI 模型（如托管在 Replicate 上的模型）集成到标准业务流程中的用户。
n8n 高阶玩家： 希望学习如何使用 Code n8n 节点和流程控制结构（如 If 和 Wait）来处理外部 API 的进阶示例的用户。
内容自动化专家： 所有需要可靠的 n8n 模板来根据提示词生成创意内容的专业人士。
技术自动化人员： 需要一个健壮的 n8n 触发机制来启动复杂计算任务的用户。

生成复杂内容通常需要异步运行任务，这意味着初始请求会立即返回一个状态，但最终输出会有延迟。这个稳定可靠的 n8n 工作流通过实现一套专为 Replicate API 定制的、非阻塞的轮询序列来解决这个问题。

与那些简单的集成方式不同，这个 n8n 模板通过先启动预测、提取 Job ID，然后每两秒持续检查一次状态，直到任务成功，从而确保了高可靠性。使用 httpRequest n8n 节点，并结合 Code n8n 节点中的数据处理能力，为将任何异步服务集成到你的 n8n 环境中提供了一个强大且可复用的框架。这种结构对于使用 n8n 构建关键任务的自动化流程至关重要。

这个强大的 n8n 工作流由一个手动 n8n 触发器启动：

1. 初始化： 通过“点击'执行'时触发 (On clicking 'execute')”的 n8n 触发器手动启动工作流。紧接着，‘设置 API 密钥 (Set API Key)’ n8n 节点会将你的 Replicate API 密钥安全地注入为变量，供后续的 HTTP 请求使用。


2. 启动预测： ‘创建预测 (Create Prediction)’ n8n 节点（一个 HTTP 请求节点）向 Replicate 发送一个 POST 请求，指定模型版本和所需的输入提示词。这便启动了异步 AI 任务。


3. 提取： 创建请求的响应中包含了 Job ID。‘提取预测 ID (Extract Prediction ID)’ Code n8n 节点会解析此响应，存储预测 ID 以及后续轮询所需的 URL。


4. 进入轮询循环： 执行流程进入轮询阶段。它首先命中 ‘等待 (Wait)’ n8n 节点，暂停整个 n8n 工作流 2 秒钟，以避免 API 调用过于频繁。


5. 检查状态： ‘检查预测状态 (Check Prediction Status)’ httpRequest n8n 节点随后会查询先前提取的预测 URL，以获取 AI 任务的当前状态。


6. 条件判断： ‘检查是否完成 (Check If Complete)’ If n8n 节点会评估当前状态。如果状态等于 'succeeded'（即为 True 分支），则任务完成，n8n 工作流继续处理结果。如果状态不是 'succeeded'（即为 False 分支），则流程会循环回到 ‘等待 (Wait)’ n8n 节点，继续轮询，直到任务完成。


7. 结果处理： 任务成功后，‘处理结果 (Process Result)’ Code n8n 节点会提取最终生成的内容（通常是资源的 URL），并将其整理成干净的格式，以便在你的 n8n 工作流中供下游步骤使用。

要使用这个 n8n 工作流模板，请遵循以下步骤：

1. 导入： 复制提供的 JSON 代码并直接导入到你的 n8n 实例中。


2. 设置 API 密钥（Replicate）： 找到 ‘设置 API 密钥 (Set API Key)’ n8n 节点。

1. 配置模型输入： 找到 ‘创建预测 (Create Prediction)’ n8n 节点。在它的 JSON Body 配置中，修改 prompt 值以及其他所需的输入参数（如 width、height 等），以匹配你期望的生成要求。确保 JSON Body 中的模型版本是正确的。


2. 执行： 使用 ‘点击'执行'时触发 (On clicking 'execute')’ n8n 触发器节点上的 ‘执行工作流 (Execute Workflow)’ 按钮手动运行 n8n 工作流，以测试集成和轮询循环。

点击'执行'时触发 (Manual Trigger)： 作为整个 n8n 工作流的启动触发器，允许手动执行以进行测试和配置。
设置 API 密钥 (Set)： 一个关键的 n8n 节点，用于安全地定义 Replicate API 密钥，使其在后续 n8n 工作流中可以作为表达式 ($($Set API Key).item.json.replicateapikey) 访问。
创建预测 (HTTP Request)： 向 Replicate API 发送初始的异步 POST 请求，启动 AI 生成任务。它包含了使用前面定义的 API 密钥进行授权的自定义请求头。
提取预测 ID (Code)： 一个自定义的 Code n8n 节点，对于读取初始预测请求的响应至关重要。它提取唯一的 predictionId，并为后续在 n8n 工作流中的请求构建必要的轮询 URL。
等待 (Wait)： 通过将 n8n 工作流暂停设定的时长（2 秒）来管理流程控制，防止在轮询循环期间进行过于密集的 API 调用。
检查预测状态 (HTTP Request)： 使用提取到的预测 URL 发起 GET 请求，以检查正在运行的 AI 任务的状态。这是此 n8n 模板中的核心轮询步骤。
检查是否完成 (If)： 一个流程控制 n8n 节点，用于引导 n8n 工作流的逻辑走向。如果状态是 'succeeded'，则进入结果处理程序；否则，它会返回到 ‘等待 (Wait)’ n8n 节点继续轮询。
处理结果 (Code)： 最后一个 Code n8n 节点，仅在成功时执行。它整理并提取最终输出，包括指标和生成的资源 URL，清理数据以供你的大型 n8n 工作流中的后续步骤使用。