本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
分析存储在亚马逊 Redshift 目标中的亚马逊SNS消息
本页介绍如何分析通过亚马逊 Data Firehose 传送流SNS发送到亚马逊 Redshift 目的地的亚马逊消息。
分析通过 Firehose 传送流SNS发送到亚马逊 Redshift 目的地的消息
-
配置您的 Amazon Redshift 资源。有关说明,请参阅 Amazon Redshift 入门指南中的Amazon Redshift 入门。
-
配置传输流。有关说明,请参阅《亚马逊数据 Firehose 开发者指南》中的为目的地选择亚马逊 Redsh ift。
-
运行查询。有关更多信息,请参阅《Amazon Redshift 管理指南》中的 使用查询编辑器查询数据库。
示例查询
在本示例查询中,我们假设满足以下条件:
-
消息存储在默认
public
schema 的notifications
表中。 -
SNS消息中的
Timestamp
属性存储在表的timestamp
列中,列数据类型为timestamptz
。注意
要转换 Amazon Redshift 终端节点的JSON元数据,您可以使用命令。SQL
COPY
有关更多信息,请参阅 Amazon Redshift 数据库开发者指南中的从JSON示例复制和使用 “自动忽略大小写” 选项从JSON数据加载。
以下查询返回在指定日期范围内收到的所有SNS消息:
SELECT * FROM public.notifications WHERE timestamp > '2020-12-01T09:00:00.000Z' AND timestamp < '2020-12-02T09:00:00.000Z';