使用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');

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

在此处输入图片描述

预先感谢您的帮助,

1 Antwort
0

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

profile picture
EXPERTE
beantwortet vor 6 Monaten

Du bist nicht angemeldet. Anmelden um eine Antwort zu veröffentlichen.

Eine gute Antwort beantwortet die Frage klar, gibt konstruktives Feedback und fördert die berufliche Weiterentwicklung des Fragenstellers.

Richtlinien für die Beantwortung von Fragen