Código lambda acionado por tempo
Cody quer que você possa obter um relatório completo de todos os infratores, para sempre, para todo o sempre - e ela quer que isso seja atualizado todas as noites.
Ela pediu que você criasse um trabalho noturno
A estrutura atual é a seguinte:
Escreva o código que entraria no método lambda_handler
da função que você criou no último exercício.
Todos os sites boto3
, pandas
e awsrangler
foram importados para você, e as chaves foram definidas.
Vamos lá!
Este exercício faz parte do curso
Streaming de dados com AWS Kinesis e Lambda
Instruções do exercício
- Inicialize a sessão boto3 com
AWS_KEY_ID
eAWS_SECRET
. - Passe a sessão para o método AWS Wrangler
read_csv
para obter todos os quadros de dados do speeder. - Use o AWS Wrangler para gravar o csv resultante com a chave
"sd-vehicle-data/speeders-full/full.csv"
.
Exercício interativo prático
Experimente este exercício completando este código de exemplo.
# 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")