如何在ADF DataFlow中使用map()函数转换薪资字段数据类型？

你的核心问题是map()函数缺少目标数组参数，ADF数据流的map函数要求第一个参数必须是要处理的数组列，再传入处理每个元素的lambda表达式。

正确的派生列表达式 #

在派生列转换中，针对departmentManager字段使用以下表达式：

map(departmentManager, item -> 
    {
        "supervisor": item.supervisor,
        "department": item.department,
        "salary": toLong(replace(item.salary, "$", ""))
    })

操作步骤 #

1. 在数据流画布中添加派生列转换
2. 将派生列的名称设置为departmentManager（直接覆盖原字段，或者设置新名称后通过后续转换替换原字段）
3. 把上述表达式填入派生列的公式框中

异常处理补充 #

如果你的数据中存在salary字段为空、格式不符合预期（比如包含非数字字符）的情况，建议用try()函数包裹转换逻辑，避免数据流运行失败：

map(departmentManager, item -> 
    {
        "supervisor": item.supervisor,
        "department": item.department,
        "salary": try(toLong(replace(item.salary, "$", "")), 0L)
    })

这里当转换失败时会返回默认值0L，你可以根据实际需求调整默认值。

额外检查点 #

• 确认Cosmos数据源的schema已正确识别departmentManager为数组类型，否则map函数无法正常解析
• 测试时可以先取少量样本数据验证转换结果，确保格式符合预期

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