无需修改代码，如何动态聚合Variant列中的各类指标？

核心思路 #

借助Snowflake的原生函数，先将Variant对象拆解为键值对行，按分组维度+指标名聚合求和，最后重新组合成Variant对象，全程无需硬编码指标名称，实现完全动态的汇总逻辑。

实现SQL #

SELECT
    activity,
    name,
    OBJECT_AGG(f.key, SUM(f.value::NUMBER)) AS total_events
FROM user_activity,
LATERAL FLATTEN(input => events, mode => 'OBJECT') f
GROUP BY activity, name
ORDER BY activity, name;

代码说明 #

1. 拆解Variant对象：LATERAL FLATTEN(input => events, mode => 'OBJECT')把events列的JSON结构拆分为多行，每行包含指标名称（f.key）和对应数值（f.value）。
2. 分组聚合：按activity、name和指标名分组，对指标数值求和，得到每个分组下各指标的累计值。
3. 重构Variant：OBJECT_AGG(f.key, SUM(f.value::NUMBER))将聚合后的指标名和对应总和重新组合为Variant对象，作为最终的total_events列。

验证结果 #

执行后会自动适配所有已存在或新增的指标，比如示例中新增的service也会被纳入汇总：

简化版（仅按activity分组） #

如果只需要按日期维度汇总，可调整分组逻辑：

SELECT
    activity,
    OBJECT_AGG(f.key, SUM(f.value::NUMBER)) AS total_events
FROM user_activity,
LATERAL FLATTEN(input => events, mode => 'OBJECT') f
GROUP BY activity
ORDER BY activity;

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