Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.
Habilitar la descompresión en un flujo de Firehose existente
Esta sección presenta las instrucciones para habilitar la descompresión de los flujos de Firehose existentes. Abarca dos escenarios: los flujos con el procesamiento de Lambda deshabilitado y los flujos con el procesamiento de Lambda ya habilitado. En las siguientes secciones se describen step-by-step los procedimientos para cada caso, incluida la creación o modificación de funciones Lambda, la actualización de la configuración de Firehose y la supervisión de las CloudWatch métricas para garantizar la implementación correcta de la función de descompresión Firehose integrada.
Habilitar la descompresión cuando el procesamiento de Lambda está deshabilitado
Para habilitar la descompresión en un flujo de Firehose existente con el procesamiento de Lambda deshabilitado, primero debe habilitar el procesamiento de Lambda. Esta condición solo es válida para los flujos existentes. Los siguientes pasos muestran la forma de habilitar la descompresión en los flujos existentes que no tienen habilitado el procesamiento de Lambda.
-
Creación de una función de Lambda. Puede crear una transferencia de registros ficticia o utilizar este esquema
para crear una nueva función de Lambda. -
Actualice su flujo de Firehose actual para habilitar el procesamiento de Lambda, y utilice la función de Lambda que creó para el procesamiento.
-
Una vez se actualice el flujo con la nueva función de Lambda, regrese a la consola de Firehose y habilite la descompresión.
-
Deshabilite el procesamiento de Lambda que habilitó en el paso 1. Ahora puede eliminar la clave que creó en el paso 1.
Habilitar la descompresión cuando el procesamiento de Lambda está habilitado
Si ya tiene un flujo de Firehose con una función de Lambda, puede sustituirlo por la característica de descompresión de Firehose para realizar la descompresión. Antes de continuar, revise el código de la función de Lambda para confirmar que solo realiza la descompresión o la extracción de mensajes. La salida de la función de Lambda debería tener un aspecto similar a los ejemplos que se muestran en la figura 1 o la figura 2. Si el resultado tiene un aspecto similar, puede reemplazar la función de Lambda siguiendo estos pasos.
Sustituya la función de Lambda actual por este esquema
. La nueva función de Lambda del esquema detecta automáticamente si los datos entrantes están comprimidos o descomprimidos. Solo realiza la descompresión si los datos de entrada están comprimidos. Active la descompresión con la opción de Firehose integrada para la descompresión.
Activa CloudWatch las métricas para tu transmisión de Firehose si aún no está habilitada. Supervise la métrica
CloudWatchProcessorLambda_IncomingCompressedDatay espere a que esta cambie a cero. Esto confirma que todos los datos de entrada enviados a la función de Lambda están descomprimidos y que la función de Lambda ya no es necesaria.Elimine la transformación de datos de Lambda porque ya no la necesita para descomprimir el flujo.
