効果的なデータ管理のための Amazon SNS設定のテストとクエリ

Amazon SNSコンソールのトピックページを開きます。

[ticketTopic トピック] を選択します。

[メッセージの発行] を選択します。

[Publish message to topic] ページで、メッセージ本文に次のように入力します。メッセージの末尾に改行文字を追加します。

{"BookingDate":"2020-12-15","BookingTime":"2020-12-15 04:15:05","Destination":"Miami","FlyingFrom":"Vancouver","TicketNumber":"abcd1234"}

他のすべてのオプションはデフォルト設定のままにします。

[メッセージの発行] を選択します。

公開の詳細については、「Amazon SNS メッセージを発行する」を参照してください。

配信ストリームの間隔が 60 秒になったら、はじめに作成した Amazon Simple Storage Service (Amazon S3) コンソールと Amazon S3 バケットを選択します。

バケットには、発行されたメッセージが表示されます。

Amazon Athena コンソールを開きます。

クエリを実行する

例えば、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 ユーザーガイド』の「開始方法」を参照してください。