使用Athena从S3查询JSON文件

0

【以下的问题经过翻译处理】 你好, 有人可以帮忙吗? 我设置了一个跟踪来审计帐户中的所有 TLS 调用并将所有日志保存在 S3 中。我尝试使用 Athena 从 S3 查询日志。这是我创建的查询:

创建外部表 cloudtrail_logs_tls_calls (
    事件版本 STRING,
    用户身份结构<
        类型:字符串,
        主体 ID:STRING,
        阿恩:STRING,
        帐户 ID:STRING,
        accessKeyId: STRING,
        会话上下文:结构<
            sessionIssuer: STRUCT<
                类型:字符串,
                主体 ID:STRING,
                阿恩:STRING,
                帐户 ID:STRING,
                用户名:STRING>>>,
    事件时间字符串,
    事件源 STRING,
    事件名称 STRING,
    aws区域字符串,
    源 IP 地址字符串,
    用户代理字符串,
    请求参数 STRUCT<
最大结果:STRING>,
    响应元素 STRING,
    请求 ID STRING,
    事件 ID STRING,
    事件类型 STRING,
    管理事件 STRING,
    收件人帐户 ID STRING,
    事件类别 STRING,
    tlsDetails 结构<
        tlsVersion:STRING,
        密码套件:STRING,
        clientProvidedHostHeader:STRING>
)
COMMENT '<bucket_name> 存储桶的 CloudTrail 表'
行格式 SERDE 'com.amazon.emr.hive.serde.CloudTrailSerde'
存储为输入格式 'com.amazon.emr.cloudtrail.CloudTrailInputFormat'
输出格式 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'
LOCATION 's3://<bucket_name>/AWSLogs/<Acccount_Number>/CloudTrail/'
TBLPROPERTIES ('分类'='cloudtrail');

然后,在预览表格时。我收到此错误:

在此处输入图片描述

预先感谢您的帮助,

profile picture
专家
已提问 7 个月前33 查看次数
1 回答
0

【以下的回答经过翻译处理】 changed the ROW FORMAT serde to 'org.openx.data.jsonserde.JsonSerDe'. issue has been fixed

profile picture
专家
已回答 7 个月前

您未登录。 登录 发布回答。

一个好的回答可以清楚地解答问题和提供建设性反馈,并能促进提问者的职业发展。

回答问题的准则