使用“noItemsLeft”检测批量处理完成情况 - n8n 工作流

• 需要精确控制异步循环的开发者。


• 需要可靠确认批量处理完成的大数据集用户。


• 任何构建自定义 n8n 模板或在其 n8n 工作流中寻求高级流程控制技术的人员。

此 n8n 工作流模板展示了一种在批量处理数据时管理流程控制的强大技术。在处理可能多达数千条数据项时，准确知道最后一批数据何时完成，对于启动清理操作、通知或后续处理步骤至关重要。此 n8n 节点演示利用了 n8n 的 Split In Batches 节点所暴露的特定上下文属性 noItemsLeft。通过在下游的 IF n8n 节点中检查此变量，n8n 工作流可确保最终的完成操作仅执行一次，即在所有数据项成功处理完毕之后。

此 n8n 工作流模板专为展示 Split In Batches n8n 节点的内部机制而设计。

1. 开始与初始化： n8n 工作流以手动 n8n 触发器（“点击‘执行’时”）开始。


2. 数据生成： 一个 Function n8n 节点生成 10 个示例数据项（模拟要送入批量处理器的庞大数据集）。


3. 批量拆分： Split In Batches n8n 节点接收这 10 个数据项，并配置为以 1 为批次大小进行处理。


4. 完成检查： 每批数据处理完毕后，流程会进入 IF n8n 节点。这个关键的 n8n 节点会检查表达式 {{$node["SplitInBatches"].context["noItemsLeft"]}}。此上下文变量的值仅在最终执行周期变为 true，表示 Split In Batches n8n 节点已完全耗尽源数据流。


5. 最终操作： 如果 IF 条件为真（意味着没有数据项剩余），n8n 工作流将执行最后的 Set n8n 节点，设置一条确认消息。如果条件为假，处理循环会隐式继续，直到所有批次都处理完毕。

要使用此流程，请按照以下步骤导入此有用的 n8n 模板：

1. 导入 n8n 工作流： 复制提供的 JSON 数据。


2. 登录您的 n8n 实例并导航到“工作流”部分。


3. 点击“新建”并选择“从 JSON 导入”。粘贴复制的 n8n 工作流 JSON。


4. 执行： 由于此 n8n 模板使用了手动 n8n 触发器，您可以通过点击“执行工作流”直接测试功能。在执行日志中观察 IF n8n 节点的输出路径，以查看 noItemsLeft 条件何时评估为真。

手动触发器（点击‘执行’时）： 用于轻松测试 n8n 工作流结构的起始 n8n 触发器。
Function： 生成 10 个占位符数据项（i=0 到 i=9），以模拟需要批量处理的负载。这种自定义代码脚本可以快速测试流程。
Split In Batches n8n 节点： 核心流程控制 n8n 节点。它将传入的 10 个数据项拆分为大小为 1 的批次，循环通过后续节点直到所有数据项被处理完毕。此 n8n 节点提供了关键的 noItemsLeft 上下文变量。
IF n8n 节点： 决策点。它使用表达式 ={{$node["SplitInBatches"].context["noItemsLeft"]}} 来检查批量处理的完成状态。这是在此 n8n 工作流中准确检测批处理操作结束的关键。

• Set n8n 节点： 仅在批量处理完成时（当 noItemsLeft 为真时）执行。它设置一条简单消息：“无数据项剩余”，确认 Split In Batches 循环成功终止。