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 を使用して、標準 を使用して Amazon S3 オブジェクトをクエリしますSQL。詳細については、『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';