在 AWS Athena 中选择嵌套结构的查询

编程问答 2022-05-15

问题描述

我想运行一个选择查询来获取名称、城市、位置.纬度、位置.contact.email1 在 AWS Athena 中来自 .avro 文件

DDL 如下：

CREATE EXTERNAL TABLE `testing`(
`id` string COMMENT 'from deserializer',`name` string COMMENT 'from deserializer',`city` string COMMENT 'from deserializer',`area` string COMMENT 'from deserializer',`location` struct<
    latitude:double,longitude:double
    `contact` : struct<
        email1:string,email2:string,skype:string
    >
>,`active` string COMMENT 'from deserializer' )
ROW FORMAT SERDE 
  'org.apache.hadoop.hive.serde2.avro.AvroSerDe' 
WITH SERDEPROPERTIES ( 'avro.schema.literal'=' /schema inserted/')
STORED AS INPUTFORMAT 
  'org.apache.hadoop.hive.ql.io.avro.AvroContainerInputFormat' 
OUTPUTFORMAT 
  'org.apache.hadoop.hive.ql.io.avro.AvroContainerOutputFormat'
LOCATION
  's3://testing/'

表已创建并 我正在尝试运行以下查询：

SELECT name,city,location.latitude,location.contact.email1 FROM "database"."testing" limit 10;

但面临多个错误，例如 Error parsing field value 或 GENERIC_INTERNAL_ERROR 有人可以建议从ddl上面查询

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

amazon-athenaamazon-s3avro