Lectura de datos Firehose
En los dos ejercicios anteriores, has creado un bucket S3 de destino ("sd-vehicle-data"
) y un flujo Firehose ("gps-delivery-stream"
). Has escrito registros en el flujo que se entregaron al cubo.
Ahora es el momento de leer esos registros y hacer un análisis básico. Si tienes éxito, podrás analizar las velocidades máximas alcanzadas por cada vehículo. Disponer de esta información evitaría que los conductores infringieran los límites de velocidad, y probablemente salvaría muchas vidas.
Archivo a editar
Editarás el archivo analyze_data.py
en el editor.
Diapositivas
No lo olvides: 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
- Lista los objetos que se han escrito en el bucket S3.
- Para cada objeto, cárgalo desde S3.
- Cárgalo en un marco de datos, especificando un delimitador y los nombres de las columnas. Esto se te proporciona hecho.
- Ejecuta
analyze_data.py
ejecutandopython3 analyze_data.py
.
Ejercicio interactivo práctico
Convierte la teoría en acción con uno de nuestros ejercicios interactivos
