Lectura de datos de S3 basada en un evento
Al final del último capítulo, escribiste un método para leer datos de S3: analizar_datos. Sin embargo, tenías que ejecutar ese método manualmente.
Vamos a escribir una función Lambda que se ejecute cada vez que Firehose escriba un nuevo archivo en S3. Por ahora, sólo imprime los archivos que se han añadido.
Editarás el archivo recordReaderS3/lambda_function.py en el editor. Contiene el controlador de nuestra función Lambda.
No lo olvides: un objeto que se escribe en S3 provoca un evento ObjectCreated:Put. Siempre puedes hacer clic en el icono de diapositivas de la parte superior derecha para ver las diapositivas: ¡te serán muy útiles!
Este ejercicio forma parte del curso
Streaming de datos con AWS Kinesis y Lambda
Instrucciones de ejercicio
- Actualiza el método manejador lambda (
recordReaderS3/lambda_function.py) para que acepte los argumentos correctos. - Analiza el evento entrante. Si el evento es de escritura en S3 y está en
"sd-vehicle-data", devuelve la nueva clave del objeto (de esta última parte ya nos hemos ocupado por ti). - En el terminal, ejecuta
python3 run_lambda.pypara desplegar y probar tu función lambda.
Ejercicio interactivo práctico
Convierte la teoría en acción con uno de nuestros ejercicios interactivos
Empieza a hacer ejercicio