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.
Activer la décompression sur un flux Firehose existant
Cette section fournit des instructions pour activer la décompression sur les streams Firehose existants. Il couvre deux scénarios : les flux dont le traitement Lambda est désactivé et les flux dont le traitement Lambda est déjà activé. Les sections suivantes décrivent les step-by-step procédures propres à chaque cas, notamment la création ou la modification de fonctions Lambda, la mise à jour des paramètres Firehose et les CloudWatch mesures de surveillance pour garantir la mise en œuvre réussie de la fonction de décompression Firehose intégrée.
Activation de la décompression lorsque le traitement Lambda est désactivé
Pour activer la décompression sur un flux Firehose existant avec le traitement Lambda désactivé, vous devez d'abord activer le traitement Lambda. Cette condition n'est valable que pour les flux existants. Les étapes suivantes montrent comment activer la décompression sur des flux existants pour lesquels le traitement Lambda n'est pas activé.
-
créer une fonction Lambda ; Vous pouvez soit créer un transfert d'enregistrement fictif, soit utiliser ce plan
pour créer une nouvelle fonction Lambda. -
Mettez à jour votre flux Firehose actuel pour activer le traitement Lambda et utilisez la fonction Lambda que vous avez créée pour le traitement.
-
Une fois que vous avez mis à jour le flux avec la nouvelle fonction Lambda, revenez à la console Firehose et activez la décompression.
-
Désactivez le traitement Lambda que vous avez activé à l'étape 1. Vous pouvez désormais supprimer la fonction que vous avez créée à l'étape 1.
Activation de la décompression lorsque le traitement Lambda est activé
Si vous possédez déjà un flux Firehose doté d'une fonction Lambda, vous pouvez le remplacer par la fonction de décompression Firehose pour effectuer la décompression. Avant de continuer, vérifiez le code de votre fonction Lambda pour vérifier qu'il effectue uniquement la décompression ou l'extraction des messages. La sortie de votre fonction Lambda doit ressembler aux exemples illustrés sur la figure 1 ou la figure 2. Si le résultat est similaire, vous pouvez remplacer la fonction Lambda en procédant comme suit.
Remplacez votre fonction Lambda actuelle par ce plan.
La nouvelle fonction Blueprint Lambda détecte automatiquement si les données entrantes sont compressées ou décompressées. Il n'effectue la décompression que si ses données d'entrée sont compressées. Activez la décompression à l'aide de l'option Firehose intégrée pour la décompression.
Activez CloudWatch les métriques pour votre stream Firehose si ce n'est pas déjà fait. Surveillez la métrique
CloudWatchProcessorLambda_IncomingCompressedDataet attendez qu'elle passe à zéro. Cela confirme que toutes les données d'entrée envoyées à votre fonction Lambda sont décompressées et que la fonction Lambda n'est plus requise.Supprimez la transformation de données Lambda car vous n'en avez plus besoin pour décompresser votre flux.
