如何通过ADF遍历Cosmos DB数据并在Blob存储生成独立文件？

问题根源 #

你遇到的函数length要求参数为数组或字符串错误，核心原因是ForEach活动的迭代输入不是数组类型：

• 你设置的@activity('Lookup1').output.firstRow返回的是单个JSON文档对象，而ForEach需要遍历数组，内部调用length函数时无法处理单个对象，因此报错。

修正步骤 #

1. 调整Lookup活动配置 #

• 打开Lookup活动设置，将First row only选项设为否。
• 确保Cosmos DB查询返回所有需归档的文档（例如SELECT * FROM c），此时Lookup输出activity('Lookup1').output.value会是包含所有文档的数组。

2. 修正ForEach活动的迭代项 #

将ForEach的Items配置改为：

@activity('Lookup1').output.value

这样ForEach会遍历数组中的每一个文档对象，满足length函数对数组类型的要求。

3. 配置Copy Activity实现单文档归档 #

源配置（Cosmos DB）

在Copy Activity的Cosmos DB源中，用当前循环的文档做过滤，确保每次仅读取单个文档：

• 选择Query模式，输入查询语句：

  SELECT * FROM c WHERE c.id = '@item().id'
  

  （若文档唯一标识不是id，替换为对应字段即可）

目标配置（Blob存储）

在Blob目标中动态生成单个文件名，保证每个文档对应独立文件：

• 将文件路径设置为：

  @concat('归档目录/', item().id, '.json')
  

  （替换归档目录/为你的Blob实际存储目录，文件名可按需调整，比如添加时间戳等）

注意事项 #

• Lookup活动默认最多返回100条数据，若需归档的文档数量超过100，需启用分页设置，或考虑用Copy Activity的「按分区/字段拆分文件」方式（后者更适合批量拆分，而非单文档场景）。
• 确保Cosmos DB源权限与Blob存储目标权限配置正确，避免读写失败。

内容的提问来源于stack exchange，提问作者Vishal Verma