Pruebas y consulta de una configuración de Amazon SNS para una administración de datos eficaz

En esta página, se describe cómo probar el caso de uso de ejemplo de archivado y análisis de mensajes mediante la publicación de un mensaje en el tema de Amazon SNS. Entre las instrucciones se incluye una consulta de ejemplo que puede ejecutar y adaptar a sus propias necesidades.

Para probar la configuración

1. Abra la página Topics (Temas) en la consola de Amazon SNS.

2. Elija el tema ticketTopic.

3. Elija Publish message (Publicar mensaje).

4. En la página Publicar mensaje en tema, ingrese lo siguiente en el cuerpo del mensaje. Agregue un carácter de nueva línea al final del mensaje.

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

   Mantenga todas las demás opciones en sus valores predeterminados.

5. Elija Publish message (Publicar mensaje).

   Para obtener más información sobre la publicación de mensajes, consulte Publicación de un mensaje de Amazon SNS.

6. Después del intervalo de flujo de entrega de 60 segundos, abra la consola de Amazon Simple Storage Service (Amazon S3) y elija el bucket de Amazon S3 que creó en un principio.

   El mensaje publicado aparece en el bucket.

Para consultar los datos, siga estos pasos:

1. Abra la consola de Amazon Athena.

2. Ejecute una consulta.

   Por ejemplo, supongamos que en la tabla notifications del esquema default se incluyen los siguientes datos:

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

   Para buscar el destino principal, ejecute la siguiente consulta:

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

   Para consultar los tickets vendidos durante un intervalo de fecha y hora específico, ejecute una consulta como la siguiente:

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

   Puede adaptar ambas consultas de muestra según sus propias necesidades. Si desea obtener más información sobre el uso de Athena para ejecutar consultas, consulte Introducción en la Guía del usuario de Amazon Athena.

Limpieza

Para evitar incurrir en cargos de uso después de haber terminado la prueba, elimine los siguientes recursos que creó durante el tutorial:

• Suscripciones a Amazon SNS

• Tema de Amazon SNS

• Colas de Amazon Simple Queue Service (Amazon SQS)

• Bucket de Amazon S3

• Flujo de entrega de Amazon Data Firehose

• AWS Identity and Access Management Funciones y políticas (IAM)