ADF Pipeline拆分JSON对象数组写入Cosmos DB的动态映射问题

问题根因 #

当前手动配置Copy Data映射时硬编码了数组索引[0]，活动默认不会自动展开d.results路径下的对象数组，仅读取指定索引位置的单条对象，最终导致所有写入Cosmos DB的文档都重复首项内容。

方案1：无代码配置（优先选择，性能最优） #

不需要额外搭配其他活动，直接调整Copy Data活动配置即可实现数组自动拆分写入：

• 调整JSON源数据集配置
  打开JSON文件对应的源数据集，在「连接」配置页找到JSON路径设置项，在「数组的JSON路径」输入框中填入$.d.results，该配置会指定Copy Data活动直接将results节点下的数组按单条对象逐行展开，不需要手动指定数组索引。

  注意：如果之前已经在数据集「架构」页导入过带[0]固定索引的硬编码架构，先清空所有已导入的架构配置，避免旧配置干扰。

• 调整复制活动映射规则
  回到Copy Data活动的「映射」配置页，点击「导入架构」，系统会自动识别展开后的数组对象全量字段（即OrderDescription、SalesManager等业务属性），此时字段路径不会再出现[0]类固定索引标记，确认字段和Cosmos DB端的属性对应关系即可，无需手动逐字段配置映射。
• 校验Cosmos DB接收器配置
  确认接收器写入行为设置为插入，分区键字段和数组对象内的对应字段匹配，直接运行管道即可将数组内每个对象作为独立文档写入Cosmos DB。

方案2：Lookup+ForEach组合（适合需要额外字段处理的场景） #

如果拆分数组后需要做字段清洗、格式转换、字段补全等自定义逻辑，可以用多活动组合实现：

• 添加Lookup活动，配置为读取目标JSON源文件，取消勾选仅返回第一行选项，获取完整的JSON文件内容。
• 添加ForEach循环活动，在循环的「项」配置中填入表达式@activity('Lookup活动名称').output.d.results，遍历results数组下的每一个对象。
• 在ForEach循环内部添加Copy Data活动，源端配置为动态读取当前循环项@item()，接收器配置为目标Cosmos DB数据集，每次循环写入单个对象。

  该方案灵活度更高，但单次数组对象量超过1万条时写入性能远低于方案1，无特殊处理需求优先选择方案1。

待处理JSON结构参考 #

{
"d": {
    "results": [
        {
            "OrderDescription": "abc",
            "SalesManager": "abc",
            "ProjectCoordinator": "",
            "CustomerNumber": "",
            "CustomerName": "",
            "CustomerStreetAddress": "",
            "CustomerCity": "",
            "CustomerState": "",
            "CustomerZiip": "",
            "FacilityName": "",
            "ShipToNumber": "",
            "ShipToName": ""
        },
        {
            "OrderDescription": "abc",
            "SalesManager": "abc",
            "ProjectCoordinator": "",
            "CustomerNumber": "",
            "CustomerName": "",
            "CustomerStreetAddress": "",
            "CustomerCity": "",
            "CustomerState": "",
            "CustomerZiip": "",
            "FacilityName": "",
            "ShipToNumber": "",
            "ShipToName": ""
        },
        {
            "OrderDescription": "abc",
            "SalesManager": "abc",
            "ProjectCoordinator": "",
            "CustomerNumber": "",
            "CustomerName": "",
            "CustomerStreetAddress": "",
            "CustomerCity": "",
            "CustomerState": "",
            "CustomerZiip": "",
            "FacilityName": "",
            "ShipToNumber": "",
            "ShipToName": ""
        }
    ]
}
}

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