Athena报错:将BigQuery数组转为列时子查询返回多行
解决BigQuery中event_params数组转列的报错问题
报错原因
你遇到的SUBQUERY_MULTIPLE_ROWS错误,是因为部分数据行的event_params数组中存在多个key为'buttonName'的元素,导致标量子查询返回了多行结果,但SELECT列表中的子查询必须是标量(仅返回单行单列),因此触发错误。
解决方案
根据你的需求,推荐两种可靠的写法:
方法1:条件聚合(支持批量转换多个字段)
这是处理数组转列最常用的方式,能同时提取多个参数,还能处理同一key出现多次的情况(用聚合函数选择保留第一个、最后一个或合并值):
SELECT event_date, user_pseudo_id, -- 提取buttonName字段 MAX(CASE WHEN param.key = 'buttonName' THEN param.value.string_value END) AS buttonName, -- 可添加更多字段,比如提取click_type MAX(CASE WHEN param.key = 'click_type' THEN param.value.string_value END) AS click_type, -- 如果是数值类型,用param.value.int_value,比如: MAX(CASE WHEN param.key = 'click_count' THEN param.value.int_value END) AS click_count FROM `bigquery`, UNNEST(event_params) AS param GROUP BY event_date, user_pseudo_id
- 若同一key存在多个值,
MAX会返回最后出现的那个,MIN返回第一个,STRING_AGG(param.value.string_value, ',')可以合并所有值。 - 需根据参数的实际类型选择
string_value/int_value/float_value等。
方法2:子查询加LIMIT(适合确定每个key唯一的场景)
如果你能确保每行的event_params中每个key只出现一次,可以给子查询加LIMIT 1限制返回行数:
SELECT event_date, user_pseudo_id, (SELECT param.value.string_value FROM UNNEST(event_params) AS param WHERE param.key = 'buttonName' LIMIT 1) AS buttonName FROM `bigquery`
这种写法更简洁,但如果存在重复key,只会取第一个匹配的值。
内容的提问来源于stack exchange,提问作者Nour H
相关产品推荐
相关产品推荐

