如何修改ADF复制数据活动的映射以添加管道参数至Snowflake表？

要把管道传入的key_value参数和API返回的JSON数据一起插入Snowflake目标表，你只需修改TabularTranslator的映射配置，新增一个针对key_value列的映射项，直接引用管道参数作为数据源即可。

修改后的完整映射代码 #

{
    "type": "TabularTranslator",
    "mapComplexValuesToString": true,
    "mappings": [
        {
            "source": {"path": "$.data"},
            "sink": {"name": "JSON"}
        },
        {
            "source": {"value": "@pipeline().parameters.key_value"},
            "sink": {"name": "key_value"}
        }
    ]
}

关键说明 #

• 新增的映射项里，source使用value字段而非path，因为key_value不是来自API返回的JSON，而是管道参数。
• @pipeline().parameters.key_value是ADF引用管道参数的标准表达式，要确保你管道里定义的参数名称和这里的key_value完全一致。
• 目标sink的name必须和Snowflake表的key_value列名完全匹配。

配置完成后，Copy Data活动会同时将API返回的$.data部分存入JSON列，把管道传入的key_value参数存入key_value列，实现数据的关联存储。

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