本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
測試和查詢 Amazon SNS組態以進行有效的資料管理
此頁面說明如何透過將訊息發佈至 Amazon 主題來測試訊息封存和分析範例使用案例。 SNS這些指示包括一個範例查詢,您可以執行並適應自己的需求。
若要測試組態
-
開啟 Amazon SNS主控台的主題頁面
。 -
選擇
ticketTopic
主題。 -
選擇 Publish message (發佈訊息)。
-
在 Publish message to topic (將訊息發佈至主題) 頁面上,輸入訊息內文的下列資訊。在訊息的結尾新增換行字元。
{"BookingDate":"2020-12-15","BookingTime":"2020-12-15 04:15:05","Destination":"Miami","FlyingFrom":"Vancouver","TicketNumber":"abcd1234"}
所有其他選項保持為預設值。
-
選擇 Publish message (發佈訊息)。
如需發佈郵件的詳細資訊,請參閱 發佈 Amazon SNS 訊息。
-
在 60 秒的交付串流間隔之後,開啟 Amazon Simple Storage Service (Amazon S3) 主控台
並選擇您最初建立的 Amazon S3 儲存貯體。 發佈的訊息會出現在儲存貯體中。
查詢資料
-
執行查詢。
例如,假設
default
架構中的notifications
表格包含下列資料:{"BookingDate":"2020-12-15","BookingTime":"2020-12-15 04:15:05","Destination":"Miami","FlyingFrom":"Vancouver","TicketNumber":"abcd1234"} {"BookingDate":"2020-12-15","BookingTime":"2020-12-15 11:30:15","Destination":"Miami","FlyingFrom":"Omaha","TicketNumber":"efgh5678"} {"BookingDate":"2020-12-15","BookingTime":"2020-12-15 3:30:10","Destination":"Miami","FlyingFrom":"NewYork","TicketNumber":"ijkl9012"} {"BookingDate":"2020-12-15","BookingTime":"2020-12-15 12:30:05","Destination":"Delhi","FlyingFrom":"Omaha","TicketNumber":"mnop3456"}
若要尋找第一目的地,執行下列查詢:
SELECT destination FROM default.notifications GROUP BY destination ORDER BY count(*) desc LIMIT 1;
若要查詢特定日期和時間範圍內銷售的票證,請執行類似下列的查詢:
SELECT * FROM default.notifications WHERE bookingtime BETWEEN TIMESTAMP '2020-12-15 10:00:00' AND TIMESTAMP '2020-12-15 12:00:00';
您可以根據自己的需求調整這兩個範例查詢。如需使用 Athena 執行查詢的詳細資訊,請參閱 Amazon Athena 使用者指南中的入門。
清除
若要避免在完成測試後產生使用費用,請刪除您在教學課程期間建立的下列資源:
-
Amazon SNS訂閱
-
Amazon SNS主題
-
Amazon Simple Queue Service (Amazon SQS) 佇列
-
Amazon S3 儲存貯體
-
Amazon Data Firehose 交付串流
-
AWS Identity and Access Management (IAM) 角色和政策