本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
分析 Amazon S3 目标的消息
本页介绍如何分析通过 Amazon Data Firehose 传送流发送到亚马逊简单存储服务 (Amazon S3) 目标的 Amazon SNS 消息。
分析通过 Firehose 发送到亚马逊 S3 目的地的传输流的 SNS 消息
-
配置 Amazon S3 资源。有关说明,请参阅 Amazon Simple Storage Service 用户指南中的创建存储桶和 Amazon Simple Storage Service 用户指南中的使用 Amazon S3 存储桶。
-
配置传输流。有关说明,请参阅《亚马逊数据 Firehose 开发者指南》中的选择亚马逊 S3 作为您的目的地。
-
使用 Amazon Athena
通过标准的 SQL 查询 Amazon S3 对象。有关更多信息,请参阅 Amazon Athena 用户指南中的入门。
示例查询
在本示例查询中,我们假设满足以下条件:
-
消息存储在
default
schema 的notifications
表中。 -
notifications
表包含一个类型为string
的timestamp
列。
以下查询返回在指定日期范围内收到的所有 SNS 消息:
SELECT * FROM default.notifications WHERE from_iso8601_timestamp(timestamp) BETWEEN TIMESTAMP '2020-12-01 00:00:00' AND TIMESTAMP '2020-12-02 00:00:00';