Azure Synapse/Data Factory：如何让ForEach并行运行所有传入值？

核心问题定位 #

你遇到的串行执行问题，根源在于只调整了Batch count和关闭Sequential mode，但未配置ForEach Loop的并发执行上限，同时Lookup的结果集传递方式可能有误。

一、正确处理Lookup的输出 #

1. 确保Lookup组件使用Full Cache模式，且结果集设置为Full result set（而非单行或单值）。
2. 创建一个Object类型的变量（例如User::LookupDataset），将Lookup的完整结果集映射到这个变量——这是传递批量数据给ForEach的正确方式，不要用字符串数组。

二、配置ForEach Loop实现并行 #

1. 选择ForEach Loop的枚举器类型为Foreach ADO Enumerator，在“ADO对象源变量”中选择User::LookupDataset。
2. 进入ForEach Loop的属性面板（右键容器→属性），修改两个关键参数：
   • SequentialMode：设为False（允许容器内任务并行）
   • MaxConcurrentExecutables：设置为你需要的并发数（比如20，建议根据服务器CPU核心数调整，一般不超过核心数×2）

   注意：Batch count是针对部分枚举器的批次读取参数，和并行执行无关，之前的调整方向有误。

3. 在“变量映射”里，将Lookup结果集中需要传递给子管道的字段（比如ID）映射到对应的变量（例如User::CurrentItemID），子管道直接引用这个变量即可。

三、子管道无串行约束检查 #

确保子管道内部的任务没有设置强制串行的优先约束——如果子管道里的任务之间有Success类型的优先约束，会导致单条子管道内部串行，但不影响多个子管道实例的并行。

四、简化演示流程 #

1. 新建SSIS包，添加Data Flow Task，内部放置Lookup组件：
   • 配置Lookup连接源表，获取100+条记录
   • 结果集选择Full result set，映射到User::LookupDataset（Object类型）
2. 添加ForEach Loop容器，连接Data Flow Task（确保Lookup执行完成后启动循环）
3. 配置ForEach Loop：
   • 枚举器：Foreach ADO Enumerator，选择User::LookupDataset
   • 变量映射：将结果集的ID列映射到User::CurrentItemID（Int32类型）
4. 在ForEach Loop内添加子Data Flow Task，子任务中使用User::CurrentItemID作为查询条件处理数据
5. 打开ForEach Loop属性面板，设置MaxConcurrentExecutables=20，SequentialMode=False
6. 运行包，观察执行日志，会看到多个子Data Flow Task同时启动

五、常见排查点 #

• 如果仍串行，检查MaxConcurrentExecutables是否正确设置（属性面板里的参数，不是枚举器配置页）
• 确认SSIS目录的全局并发限制未被调低（可在SSIS目录→操作→配置目录中查看MaxConcurrentExecutables）
• 验证Lookup的结果集确实包含100+条记录（可在调试时查看变量User::LookupDataset的内容）

内容的提问来源于stack exchange，提问作者ishan khobare