Test e interrogazione di una SNS configurazione Amazon per una gestione efficace dei dati - Amazon Simple Notification Service

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Test e interrogazione di una SNS configurazione Amazon per una gestione efficace dei dati

Questa pagina descrive come testare il caso d'uso di esempio di archiviazione e analisi dei messaggi pubblicando un messaggio SNS sull'argomento Amazon. Le istruzioni includono una query di esempio che è possibile eseguire e adattare alle proprie esigenze.

Per testare la configurazione
  1. Apri la pagina Argomenti della SNS console Amazon.

  2. Seleziona l'argomento ticketTopic.

  3. Seleziona Publish message (Pubblica messaggio).

  4. Nella pagina Pubblica il messaggio nell'argomento inserisci quanto segue per il corpo del messaggio. Aggiungi un carattere di nuova riga alla fine del messaggio.

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

    Mantenere tutte le altre opzioni come valori predefiniti.

  5. Seleziona Publish message (Pubblica messaggio).

    Per ulteriori informazioni sulla pubblicazione dei messaggi, consulta Pubblicazione di un SNS messaggio Amazon.

  6. Dopo l'intervallo di flusso di consegna di 60 secondi, aprire la finestra Console Amazon Simple Storage Service (Amazon S3) e scegliere il bucket Amazon S3 creato inizialmente.

    Il messaggio pubblicato appare nel bucket.

Per eseguire una query sui dati
  1. Aprire la console Amazon Athena.

  2. Eseguire una query.

    Ad esempio, si supponga che la tabella notifications nello schema default contenga i seguenti dati:

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

    Per trovare la destinazione principale, eseguire la seguente query:

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

    Per eseguire una query per i ticket venduti in un intervallo di data e ora specifico, eseguire una query simile alla seguente:

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

    È possibile adattare entrambe le query di esempio per le proprie esigenze. Per ulteriori informazioni sull'utilizzo di Athena per eseguire query, consulta Nozioni di base nellaGuida per l'utente di Amazon Athena.

Pulizia

Per evitare di incorrere in costi di utilizzo dopo aver terminato il test, eliminare le seguenti risorse create durante l'esercitazione:

  • SNSAbbonamenti Amazon

  • SNSArgomento Amazon

  • Code di Amazon Simple Queue Service (AmazonSQS)

  • Bucket Amazon S3

  • Flusso di distribuzione di Amazon Data Firehose

  • AWS Identity and Access Management (IAM) ruoli e politiche