Mapping Data Flow表达式IIF与IN语法报错求助：列需包裹聚合函数

错误根源 #

报错columns should be wrapped in an aggregate function的核心原因是：在聚合转换（Aggregate）中，你引用的GroupingName列既没有被设置为分组键（Group By），也没有用聚合函数（如first()、max()）包裹。Data Flow要求聚合场景下，所有非分组列必须通过聚合函数处理。

两种解决方案 #

根据你的业务需求选择对应的修正方式：

方案1：将GroupingName设为分组键

如果GroupingName是你聚合分组的依据，直接在聚合转换的Group By面板中添加GroupingName作为分组列。此时修正后的表达式无需修改GroupingName的引用，仅需确保嵌套函数的语法正确（原表达式的嵌套逻辑没问题，仅需确认分组配置）：

iif(in(GroupingName, ['Item1', 'Item2', 'Item3'])
,   replace(
        unescape(
            replace(
                replace(toString(collect(KeyValuePair))
                , '[', '{'
                )
            , ']', '}'
            )
        , 'json'
        )
    , '""', '"'
    )
,   collect(KeyValuePair)
)

方案2：用聚合函数包裹GroupingName

如果GroupingName不是分组依据，仅需判断同组内该列的值是否在指定列表中，就用first()或max()等聚合函数包裹GroupingName（确保同组内该列值一致时使用）。修正后的表达式如下：

iif(in(first(GroupingName), ['Item1', 'Item2', 'Item3'])
,   replace(
        unescape(
            replace(
                replace(toString(collect(KeyValuePair))
                , '[', '{'
                )
            , ']', '}'
            )
        , 'json'
        )
    , '""', '"'
    )
,   collect(KeyValuePair)
)

额外验证点 #

• 确认collect(KeyValuePair)的使用符合预期：collect()会将同组内的KeyValuePair值收集为数组，这部分是聚合函数，语法合法。
• unescape(..., 'json')用于解析JSON转义字符，配合外层的replace将数组符号转为对象符号，逻辑可行。

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