Analisi dei messaggi Amazon SNS archiviati in Amazon S3 utilizzando Athena

Questa pagina spiega come analizzare i messaggi Amazon SNS inviati tramite flussi di consegna a destinazioni Amazon Simple Storage Service (Amazon S3).

Per analizzare i messaggi SNS inviati tramite i flussi di distribuzione Firehose verso destinazioni Amazon S3

1. Configura le risorse Amazon S3. Per istruzioni, consulta Creazione di un bucket nella Guida per l'utente di Amazon Simple Storage Service e Utilizzo dei bucket Amazon S3 nella Guida per l'utente di Amazon Simple Storage Service.

2. Configura il flusso di consegna. Per istruzioni, consulta Scegli Amazon S3 per la tua destinazione nella Amazon Data Firehose Developer Guide.

3. Utilizza Amazon Athena per eseguire query sugli oggetti Amazon S3 utilizzando SQL standard. Per ulteriori informazioni, consulta l'argomento relativo alle nozioni di base nella Guida per l'utente di Amazon Athena.

Query di esempio

Per questa query di esempio, supponiamo quanto segue:

• I messaggi vengono archiviati nella tabella notifications nello schema default.

• La tabella notifications include una colonna timestamp con un tipo di string.

La query seguente restituisce tutti i messaggi SNS ricevuti nell'intervallo di date specificato:

SELECT * 
FROM default.notifications
WHERE from_iso8601_timestamp(timestamp) BETWEEN TIMESTAMP '2020-12-01 00:00:00' AND TIMESTAMP '2020-12-02 00:00:00';