Tester et interroger une configuration Amazon SNS pour une gestion efficace des données

Cette page explique comment tester l'exemple d'archivage des messages et d'analyse de cas d'utilisation en publiant un message dans la rubrique Amazon SNS. Les instructions comprennent un exemple de requête que vous pouvez exécuter et adapter à vos propres besoins.

Pour tester votre configuration

1. Ouvrez la page Rubriques de la console Amazon SNS.

2. Cliquez sur la rubrique ticketTopic.

3. Choisissez Publier le message.

4. Sur la page Publier un message dans une rubrique, saisissez ce qui suit pour le corps du message. Ajoutez un caractère de saut de ligne à la fin du message.

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

   Conservez toutes valeurs par défaut des autres options.

5. Choisissez Publier le message.

   Pour en savoir plus sur la publication de messages, consultez la section Publication d'un message Amazon SNS.

6. Après l'intervalle de flux de diffusion de 60 secondes, ouvrez la console Amazon Simple Storage Service (Amazon S3) et choisissez le compartiment Amazon S3 que vous avez initialement créé.

   Le message publié s'affiche dans le compartiment.

Pour des requêtes sur des données

1. Ouvrez la console Amazon Athena.

2. Exécuter une requête.

   Par exemple, supposons que le tableau notifications dans le schéma defaultcontient les données suivantes :

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

   Pour rechercher la destination la plus importante, exécutez la requête suivante :

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

   Pour rechercher les tickets vendus au cours d'une période et d'une plage d'heures spécifique, exécutez une requête comme suit :

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

   Vous pouvez adapter les deux exemples de requêtes à vos propres besoins. Pour en savoir plus sur l'utilisation d'Athena pour exécuter des requêtes, consultez la section de Mise en route dans le Guide de l'utilisateur Amazon Athena.

Nettoyage

Pour éviter d'encourir des frais d'utilisation après avoir terminé le test, supprimez les ressources suivantes que vous avez créées pendant le didacticiel :

• Abonnements Amazon SNS

• Rubrique Amazon SNS

• Files d’attente Amazon Simple Queue Service (Amazon SQS)

• Compartiment Amazon S3

• Flux de livraison d'Amazon Data Firehose

• AWS Identity and Access Management Rôles et politiques (IAM)