本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
使用 Athena 分析存放在 Amazon S3 中的亞馬遜SNS訊息
本頁說明如何分析透過 Amazon 資料 Firehose 交付串流傳SNS送至亞馬遜簡單儲存服務 (Amazon S3) 目的地的 Amazon 訊息。
分析透過 Firehose 交付串流傳SNS送至 Amazon S3 目的地的訊息
-
設定您的 Amazon S3 資源。如需指示,請參閱《Amazon Simple Storage Service 使用者指南》中的建立儲存貯體和《Amazon Simple Storage Service 使用者指南》中的使用 Amazon S3 儲存貯體。
-
設定交付串流。如需指示,請參閱 Amazon 資料 Firehose 開發人員指南中的為您的目的地選擇 Amazon S3。
-
使用 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';