Testen und Abfragen einer Amazon SNS SNS-Konfiguration für effektives Datenmanagement

In diesem Thema wird erklärt, wie Sie den Beispielanwendungsfall Nachrichtenarchivierung und -analyse testen, indem Sie eine Nachricht im Amazon SNS SNS-Thema veröffentlichen. Die Anweisungen enthalten eine Beispielabfrage, die Sie ausführen und an Ihre eigenen Bedürfnisse anpassen können.

So testen Sie die Konfiguration

1. Öffnen Sie die Seite Themen der Amazon-SNS-Konsole.

2. Wählen Sie das Symbol ticketTopic Thema.

3. Wählen Sie Publish message (Nachricht veröffentlichen) aus.

4. Geben Sie auf der Seite Nachricht im Thema veröffentlichen für den Nachrichtentext Folgendes ein. Fügen Sie am Ende der Nachricht einen Zeilenumbruch hinzu.

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

   Behalten Sie alle anderen Optionen als Standardwerte bei.

5. Wählen Sie Publish message (Nachricht veröffentlichen) aus.

   Weitere Informationen zum Veröffentlichen von Nachrichten finden Sie unter Veröffentlichen einer Amazon SNS SNS-Nachricht.

6. Öffnen Sie nach dem Übermittlungsstromintervall von 60 Sekunden das Dialogfeld Konsole für Amazon Simple Storage Service (Amazon S3) und wählen Sie den Amazon S3 Bucket aus, den SieInital erstellt haben.

   Die veröffentlichte Nachricht wird im Bucket angezeigt.

Abfragen der Daten

1. Öffnen Sie die Amazon-Athena-Konsole.

2. Ausführen einer Abfrage

   Angenommen, dass die notifications-Tabelle im default-Schema folgende Daten enthält:

   {"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"}

   Führen Sie die folgende Abfrage aus, um das oberste Ziel zu finden:

   SELECT destination
   FROM default.notifications
   GROUP BY destination
   ORDER BY count(*) desc
   LIMIT 1;

   Führen Sie zum Abfragen nach Tickets aus, die in einem bestimmten Datums- und Zeitbereich verkauft wurden, eine Abfrage wie die folgende aus:

   SELECT * 
   FROM default.notifications 
   WHERE bookingtime 
     BETWEEN TIMESTAMP '2020-12-15 10:00:00' 
     AND TIMESTAMP '2020-12-15 12:00:00';

   Sie können beide Beispielabfragen an Ihre eigenen Bedürfnisse anpassen. Weitere Informationen über die Verwendung von Athena zum Ausführen von Abfragen finden Sie unter Erste Schritte im Benutzerhandbuch zu Amazon Athena.

Bereinigen

Um zu vermeiden, dass nach dem Testen Nutzungsgebühren entstehen, löschen Sie die folgenden Ressourcen, die Sie während des Lernprogramms erstellt haben:

• Amazon SNS-Abonnement

• Amazon SNS-Thema

• Amazon-Simple-Queue-Service-(Amazon-SQS)-Warteschlangen

• Amazon-S3-Bucket

• Bereitstellungsstream

• AWS Identity and Access Management (IAM) -Rollen und -Richtlinien