Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.
Probar y consultar una SNS configuración de Amazon para una gestión de datos eficaz
En esta página se describe cómo probar un ejemplo de caso práctico de archivado y análisis de mensajes publicando un mensaje en el SNS tema de Amazon. Entre las instrucciones se incluye una consulta de ejemplo que puede ejecutar y adaptar a sus propias necesidades.
Para probar la configuración
-
Abre la página de temas
de la SNS consola de Amazon. -
Elija el tema
ticketTopic
. -
Elija Publish message (Publicar mensaje).
-
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.
-
Elija Publish message (Publicar mensaje).
Para obtener más información sobre la publicación de mensajes, consulte Publicar un SNS mensaje de Amazon.
-
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:
-
Abra la consola de Amazon Athena
. -
Ejecute una consulta.
Por ejemplo, supongamos que en la tabla
notifications
del esquemadefault
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:
-
SNSSuscripciones a Amazon
-
SNSTema de Amazon
-
Colas de Amazon Simple Queue Service (AmazonSQS)
-
Bucket de Amazon S3
-
Transmisión de entrega de Amazon Data Firehose
-
AWS Identity and Access Management (IAM) funciones y políticas