Analyse des messages Amazon SNS stockés dans Amazon S3 à l'aide d'Athena

Cette page explique comment analyser les messages Amazon SNS envoyés via des flux de livraison vers des destinations Amazon Simple Storage Service (Amazon S3).

Pour analyser les messages SNS envoyés via les flux de diffusion Firehose vers des destinations Amazon S3

1. Configurez vos ressources Amazon S3. Pour obtenir des instructions, consultez la section Créer un compartiment dans le Guide de mise en route Amazon Simple Storage Service et Utilisation des compartiments Amazon S3 dans le Guide de l’utilisateur Amazon Simple Storage Service.

2. Configurez votre flux de diffusion. Pour obtenir des instructions, consultez Choisir Amazon S3 pour votre destination dans le manuel Amazon Data Firehose Developer Guide.

3. Utiliser Amazon Athena pour interroger les objets Amazon S3 à l'aide de SQL standard. Pour en savoir plus, consultez la section Mise en route dans le Guide de l'utilisateur Amazon Athena.

Exemple de requête

Pour cet exemple de requête, supposons ce qui suit :

• Les messages sont stockés dans le tableau notifications dans le schéma default.

• Le tableau notifications comprend une colonne timestamp avec un type de string.

La requête suivante renvoie tous les messages SNS reçus dans la plage de dates spécifiée :

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';