Déploiement et abonnement du pipeline de stockage et de sauvegarde d'événements auprès d'Amazon SNS - Amazon Simple Notification Service

Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.

Déploiement et abonnement du pipeline de stockage et de sauvegarde d'événements auprès d'Amazon SNS

Pour l'archivage et l'analyse des événements, Amazon recommande SNS désormais d'utiliser son intégration native avec Amazon Data Firehose. Vous pouvez abonner les flux de diffusion Firehose à des SNS rubriques, ce qui vous permet d'envoyer des notifications aux points de terminaison d'archivage et d'analyse tels que les buckets Amazon Simple Storage Service (Amazon S3), les tables Amazon Redshift, Amazon Service (Service), etc. OpenSearch OpenSearch L'utilisation d'Amazon SNS avec les flux de diffusion Firehose est une solution entièrement gérée et sans code qui ne nécessite pas l'utilisation de fonctions. AWS Lambda Pour de plus amples informations, veuillez consulter Streams de diffusion de Fanout to Firehose.

Cette page explique comment déployer le pipeline de stockage et de sauvegarde d'événements et comment l'abonner à une SNS rubrique Amazon. Ce processus transforme automatiquement le AWS SAM modèle associé au pipeline en une AWS CloudFormation pile, puis déploie la pile dans votre Compte AWS. De plus, ce processus crée et configure l'ensemble de ressources qui comprennent le pipeline de stockage et de sauvegarde des événements, y compris ce qui suit :

  • SQSFile d'attente Amazon

  • Fonction Lambda

  • Flux de diffusion Firehose

  • Compartiment de sauvegarde Amazon S3

Pour plus d'informations sur la configuration d'un flux avec un compartiment S3 comme destination, consultez le S3DestinationConfiguration manuel Amazon Data Firehose API Reference.

Pour plus d'informations sur la transformation des événements et sur la configuration de la mise en mémoire tampon des événements, de la compression des événements et du chiffrement des événements, consultez la section Création d'un flux de diffusion Amazon Data Firehose dans le manuel du développeur Amazon Data Firehose.

Pour plus d'informations sur le filtrage des événements, consultez la section Politiques de filtrage des SNS abonnements Amazon dans le présent guide.

  1. Connectez-vous à la AWS Lambda console.

  2. Dans le panneau de navigation, choisissez Fonctions, puis Créer une fonction.

  3. Sur la page Créer une fonction, procédez de la façon suivante :

    1. Choisissez Parcourir le référentiel d'applications sans serveur, Applications publiques, Afficher les applications qui créent des IAM rôles personnalisés ou des politiques de ressources.

    2. Recherchez fork-event-storage-backup-pipeline et choisissez l'application.

  4. Sur la page fork-event-storage-backup-pipeline, procédez comme suit :

    1. Dans la section Paramètres de l'application, entrez un Nom d'application (par exemple, my-app-backup).

      Note

      • Pour chaque déploiement, le nom de l'application doit être unique. Si vous réutilisez le nom d'une application, le déploiement mettra à jour uniquement la AWS CloudFormation pile précédemment déployée (plutôt que d'en créer une nouvelle).

    2. (Facultatif) Pour BucketArn, entrez le ARN compartiment S3 dans lequel les événements entrants sont chargés. Si vous ne saisissez aucune valeur, un nouveau compartiment S3 est créé dans votre AWS compte.

    3. (Facultatif) Pour DataTransformationFunctionArn, entrez ARN la fonction Lambda par laquelle les événements entrants sont transformés. Si vous ne spécifiez pas de valeur, la transformation des données est désactivée.

    4. (Facultatif) Entrez l'un des LogLevelparamètres suivants pour l'exécution de la fonction Lambda de votre application :

      • DEBUG

      • ERROR

      • INFO (default)

      • WARNING

    5. Pour TopicArn, entrez ARN le SNS sujet Amazon auquel cette instance du pipeline de fork doit être abonnée.

    6. (Facultatif) Pour StreamBufferingIntervalInSecondset StreamBufferingSizeInMBs, entrez les valeurs pour configurer la mise en mémoire tampon des événements entrants. Si vous n'entrez aucune valeur, 300 secondes et 5 Mo sont utilisés.

    7. (Facultatif) Entrez l'un des StreamCompressionFormatparamètres suivants pour compresser les événements entrants :

      • GZIP

      • SNAPPY

      • UNCOMPRESSED (default)

      • ZIP

    8. (Facultatif) Pour StreamPrefix, entrez le préfixe de chaîne pour nommer les fichiers stockés dans le compartiment de sauvegarde S3. Si vous ne spécifiez pas de valeur, aucun préfixe n'est utilisé.

    9. (Facultatif) Pour SubscriptionFilterPolicy, entrez la politique de filtrage des SNS abonnements Amazon, dans le JSON format à utiliser pour filtrer les événements entrants. La politique de filtrage détermine quels événements sont indexés dans l'index des OpenSearch services. Si vous ne spécifiez pas de valeur, aucun filtrage n'est utilisé (tous les événements sont indexés).

    10. (Facultatif) Pour SubscriptionFilterPolicyScope, entrez la chaîne MessageBody ou MessageAttributes pour activer le filtrage des messages basé sur la charge utile ou basé sur les attributs.

    11. Choisissez Je reconnais que cette application crée des IAM rôles personnalisés, des politiques de ressources et déploie des applications imbriquées. puis choisissez Deploy.

Sur l'état du déploiement pour my-apppage, Lambda affiche le statut Votre application est en cours de déploiement.

Dans la section Ressources, AWS CloudFormation commence à créer la pile et affiche le PROGRESS statut CREATE_IN_ pour chaque ressource. Lorsque le processus est terminé, AWS CloudFormation affiche le COMPLETE statut CREATE_.

Une fois le déploiement terminé, Lambda affiche l'état Votre application a été déployée.

Les messages publiés sur votre SNS sujet Amazon sont stockés dans le compartiment de sauvegarde S3 approvisionné automatiquement par le pipeline Event Storage and Backup.