如何在AWS Athena中编写SQL实现多列合并与表结构转换

该需求属于典型的行转列转换场景，Athena基于Presto SQL引擎，可通过以下两种方式实现：

• 方式1：使用PIVOT语法（适用于Athena引擎v2及以上版本）

SELECT 
  user_id,
  page_view AS page_view_time,
  add_to_cart AS add_to_cart_time,
  purchase AS purchase_time
FROM (
  -- 替换为实际的表名，取出需要的三个核心字段
  SELECT user_id, event_name, event_time FROM your_source_table
)
PIVOT (
  -- 聚合规则可根据业务调整：取最新时间用MAX，取最早时间用MIN，收集全量时间用ARRAY_AGG
  MAX(event_time)
  -- 括号内替换为你实际所有的事件名称取值，和业务侧的事件名完全匹配
  FOR event_name IN ('page_view', 'add_to_cart', 'purchase')
)
ORDER BY user_id;

• 方式2：使用条件聚合（兼容所有Athena版本，灵活度更高）

SELECT
  user_id,
  MAX(CASE WHEN event_name = 'page_view' THEN event_time END) AS page_view_time,
  MAX(CASE WHEN event_name = 'add_to_cart' THEN event_time END) AS add_to_cart_time,
  MAX(CASE WHEN event_name = 'purchase' THEN event_time END) AS purchase_time
-- 替换为实际的源表名
FROM your_source_table
GROUP BY user_id
ORDER BY user_id;

注意事项 #

• 如果事件类型不固定需要动态生成列，Athena本身不支持动态PIVOT，可先执行SELECT DISTINCT event_name FROM your_source_table查询所有事件类型，再手动拼接SQL语句即可。
• 聚合函数可根据业务需求调整：若同一用户同一事件存在多条记录，需要最早时间替换为MIN，需要全量时间列表替换为ARRAY_AGG即可。

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