步骤 3: 在 Amazon S3 中查询日志数据

在此 Amazon Kinesis 代理微软 Windows 的最后一步教程中，您使用 Amazon Athena 查询 Amazon Simple Storage Service (Amazon S3) 中存储的日志数据。

1. 从 https://console.aws.amazon.com/athena/ 打开 Athena 控制台。

2. 选择加号 (+）创建新的查询窗口。

   

3. 在查询窗口中输入以下文本：

   CREATE DATABASE logdatabase
   
   CREATE EXTERNAL TABLE logs (
     Message string,
     Severity string,
     ComputerName string,
     DT timestamp
   )
   ROW FORMAT SERDE 'org.openx.data.jsonserde.JsonSerDe'
   LOCATION 's3://bucket/year/month/day/hour/'
   
   SELECT * FROM logs
   SELECT * FROM logs WHERE severity = 'Error'

   将 bucket 替换为您在创建 Amazon S3 存储桶中创建的存储桶的名称。Replaceyear、month、day和hour分别为 Amazon S3 日志文件的创建时间（用 UTC 表示）中的年、月、日和小时。

4. 选择 CREATE DATABASE 语句的文本，然后选择 Run query (运行查询)。这将在 Athena 中创建日志数据库。

5. 选择 CREATE EXTERNAL TABLE 语句的文本，然后选择 Run query (运行查询)。这将创建一个 Athena 表，该表使用日志数据引用 S3 存储桶，并将 JSON 的架构映射到 Athena 表的架构。

6. 选择第一个 SELECT 语句的文本，然后选择 Run query (运行查询)。这将显示表中的所有行。

   

7. 选择第二个 SELECT 语句的文本，然后选择 Run query (运行查询)。这仅显示表中表示具有 Error 级别严重性的日志记录的行。此类查询从可能很大的日志记录集中查找有趣的日志记录。