使用 Athena 分析存放在 Amazon S3 中的亞馬遜SNS訊息 - Amazon Simple Notification Service

本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。

使用 Athena 分析存放在 Amazon S3 中的亞馬遜SNS訊息

本頁說明如何分析透過 Amazon 資料 Firehose 交付串流傳SNS送至亞馬遜簡單儲存服務 (Amazon S3) 目的地的 Amazon 訊息。

分析透過 Firehose 交付串流傳SNS送至 Amazon S3 目的地的訊息
  1. 設定您的 Amazon S3 資源。如需指示,請參閱《Amazon Simple Storage Service 使用者指南》中的建立儲存貯體和《Amazon Simple Storage Service 使用者指南》中的使用 Amazon S3 儲存貯體

  2. 設定交付串流。如需指示,請參閱 Amazon 資料 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';