Athena を使用して Amazon S3 に保存された Amazon SNS メッセージを分析する - Amazon Simple Notification Service
クエリの例

Athena を使用して Amazon S3 に保存された Amazon SNS メッセージを分析する

このページでは、Amazon Data Firehose 配信ストリームを介して Amazon Simple Storage Service (Amazon S3) の送信先に送信される Amazon SNS メッセージを分析する方法について説明します。

Firehose 配信ストリームを介して Amazon S3 送信先に送信された SNS メッセージを分析するには

  1. Amazon S3 リソースを設定します。手順については、『Amazon Simple Storage Service ユーザーガイド』の「バケットの作成」および『Amazon Simple Storage Service ユーザーガイド』の「Amazon S3 バケットの使用」を参照してください。

  2. 配信ストリームを設定します。手順については、「Amazon Data Firehose デベロッパーガイド」の「配信先の Amazon S3 の選択」を参照してください。

  3. Amazon Athena を使用して、標準 SQL を使用した Amazon S3 オブジェクトのクエリを実行します。詳細については、『Amazon Athena ユーザーガイド』の「開始方法」を参照してください。

クエリの例

このクエリの例では、次のことを前提としています。

  • メッセージは default スキーマの 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';