分析存储在 Amazon Redshift 目标中的 Amazon SNS 消息
本页面描述如何分析通过 Amazon Data Firehose 传输流发送到 Amazon Redshift 目标的 Amazon SNS 消息。
要分析通过 Firehose 传输流发送到 Amazon Redshift 目标的 SNS 消息
-
配置您的 Amazon Redshift 资源。有关说明,请参阅 Amazon Redshift 入门指南中的Amazon Redshift 入门。
-
配置传输流。有关说明,请参阅《Amazon Data Firehose 开发人员指南》中的选择 Amazon Redshift 作为目标。
-
运行查询。有关更多信息,请参阅《Amazon Redshift 管理指南》中的 使用查询编辑器查询数据库。
示例查询
在本示例查询中,我们假设满足以下条件:
-
消息存储在默认
public
schema 的notifications
表中。 -
SNS 消息的
Timestamp
属性存储在表的timestamp
列中,其列数据类型为timestamptz
。注意
要转换 Amazon Redshift 终端节点的 JSON 元数据,您可以使用 SQL
COPY
命令。有关更多信息,请参阅 Amazon Redshift 数据库开发人员指南中的从 JSON 中复制示例和使用“auto ignorecase”选项从 JSON 数据中加载。
以下查询返回在指定日期范围内收到的所有 SNS 消息:
SELECT * FROM public.notifications WHERE timestamp > '2020-12-01T09:00:00.000Z' AND timestamp < '2020-12-02T09:00:00.000Z';