Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.
Dieser Abschnitt enthält Anweisungen zum Aktivieren der Dekomprimierung vorhandener Firehose-Streams. Es deckt zwei Szenarien ab: Streams mit deaktivierter Lambda-Verarbeitung und Streams mit bereits aktivierter Lambda-Verarbeitung. In den folgenden Abschnitten step-by-step werden die Verfahren für jeden Fall beschrieben, einschließlich der Erstellung oder Änderung von Lambda-Funktionen, der Aktualisierung der Firehose-Einstellungen und der Überwachung von CloudWatch Metriken, um eine erfolgreiche Implementierung der integrierten Firehose-Dekomprimierungsfunktion sicherzustellen.
Dekomprimierung aktivieren, wenn die Lambda-Verarbeitung deaktiviert ist
Um die Dekomprimierung für einen vorhandenen Firehose mit deaktivierter Lambda-Verarbeitung zu aktivieren, müssen Sie zuerst die Lambda-Verarbeitung aktivieren. Diese Bedingung gilt nur für bestehende Streams. Die folgenden Schritte zeigen, wie die Dekomprimierung für bestehende Streams aktiviert wird, für die die Lambda-Verarbeitung nicht aktiviert ist.
-
Erstellen Sie eine Lambda-Funktion. Sie können entweder einen Dummy-Record-Passthrough erstellen oder diesen Blueprint
verwenden, um eine neue Lambda-Funktion zu erstellen. -
Aktualisieren Sie Ihren aktuellen Firehose-Stream, um die Lambda-Verarbeitung zu aktivieren, und verwenden Sie die Lambda-Funktion, die Sie für die Verarbeitung erstellt haben.
-
Sobald Sie den Stream mit der neuen Lambda-Funktion aktualisiert haben, kehren Sie zur Firehose-Konsole zurück und aktivieren Sie die Dekomprimierung.
-
Deaktivieren Sie die Lambda-Verarbeitung, die Sie in Schritt 1 aktiviert haben. Sie können jetzt die Funktion löschen, die Sie in Schritt 1 erstellt haben.
Dekomprimierung aktivieren, wenn die Lambda-Verarbeitung aktiviert ist
Wenn Sie bereits über einen Firehose-Stream mit einer Lambda-Funktion verfügen, können Sie ihn zur Durchführung der Dekomprimierung durch die Firehose-Dekomprimierungsfunktion ersetzen. Bevor Sie fortfahren, überprüfen Sie Ihren Lambda-Funktionscode, um sicherzustellen, dass er nur Dekomprimierung oder Nachrichtenextraktion durchführt. Die Ausgabe Ihrer Lambda-Funktion sollte den Beispielen in Abb. 1 oder Abb. 2 ähneln. Wenn die Ausgabe ähnlich aussieht, können Sie die Lambda-Funktion mithilfe der folgenden Schritte ersetzen.
Ersetzen Sie Ihre aktuelle Lambda-Funktion durch diesen Blueprint
. Die neue Blueprint-Lambda-Funktion erkennt automatisch, ob die eingehenden Daten komprimiert oder dekomprimiert sind. Sie führt nur dann eine Dekomprimierung durch, wenn ihre Eingabedaten komprimiert sind. Schalten Sie die Dekomprimierung mit der integrierten Firehose für die Dekomprimierung ein.
Aktivieren Sie CloudWatch Metriken für Ihren Firehose-Stream, falls er noch nicht aktiviert ist. Überwachen Sie die Metrik
CloudWatchProcessorLambda_IncomingCompressedDataund warten Sie, bis sich diese Metrik auf Null ändert. Dadurch wird bestätigt, dass alle an Ihre Lambda-Funktion gesendeten Eingabedaten dekomprimiert sind und die Lambda-Funktion nicht mehr benötigt wird.Entfernen Sie die Lambda-Datentransformation, da Sie sie nicht mehr benötigen, um Ihren Stream zu dekomprimieren.
