Código lambda temporizado
Cody quiere poder obtener un informe completo de todos los infractores de velocidad, para siempre, para siempre, y quiere que se actualice cada noche.
Te pidió que crearas un trabajo nocturno
La estructura actual es la siguiente:
Escribe el código que iría en el método lambda_handler de la función que has creado en el último ejercicio.
Se han importado para ti todos los sitios boto3, pandas y awsrangler, y se han definido las claves.
¡A rodar!
Este ejercicio forma parte del curso
Streaming de datos con AWS Kinesis y Lambda
Instrucciones de ejercicio
- Inicializa la sesión de boto3 con
AWS_KEY_IDyAWS_SECRET. - Pasa la sesión al método AWS Wrangler
read_csvpara obtener todos los fotogramas de datos del speeder. - Utiliza AWS Wrangler para escribir el csv resultante con la clave
"sd-vehicle-data/speeders-full/full.csv".
Ejercicio interactivo práctico
Pruebe este ejercicio completando este código de muestra.
# Initialize boto3 session
session = boto3.____(aws_access_key_id = AWS_KEY_ID,
aws_secret_access_key = AWS_SECRET,
region_name="us-east-1")
# Read all records in the speeders folder
speeders_total = wr.s3.____('s3://sd-vehicle-data/speeders',
____ = session,
delimiter=" ")
# Write aggregated speeders file
____.____.to_csv(df = speeders_total,
boto3_session=session,
path="____://sd-vehicle-data/speeders-full/full.csv")