Analyser les messages des destinations Amazon S3 - Amazon Simple Notification Service

Analyser les messages des destinations Amazon S3

Cette page explique comment analyser les messages Amazon SNS envoyés grâce à des flux de diffusion Amazon Kinesis Data Firehose vers les destinations Amazon Simple Storage Service (Amazon S3).

Pour analyser les messages SNS envoyés grâce aux flux de diffusion Kinesis Data Firehose vers les 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 la section Choisissez Amazon S3 pour votre destination dans le Guide du développeur Amazon Kinesis Data Firehose.

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