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

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

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

このページでは、配信ストリームを介して Amazon SNSAmazon S3 メッセージを分析する方法について説明します。

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';