시간 트리거 Lambda 코드
Cody는 모든 과속 차량의 전체 보고서를 언제든지 영구적으로 조회하고, 이를 매일 밤 업데이트되길 원해요.
이를 위해 매일 밤 실행되는 작업을 만들어 달라고 요청했어요.
현재 구조는 다음과 같아요:
이전 연습 문제에서 만든 함수의 lambda_handler 메서드에 들어갈 코드를 작성하세요.
boto3, pandas, awsrangler는 이미 임포트되어 있으며, 필요한 키도 정의되어 있어요.
시작해 볼까요!
이 연습은 강의의 일부입니다
AWS Kinesis와 Lambda로 배우는 스트리밍 데이터
연습 안내
AWS_KEY_ID와AWS_SECRET로 boto3 세션을 초기화하세요.- 해당 세션을 AWS Wrangler의
read_csv메서드에 전달하여 모든 과속 차량 데이터프레임을 가져오세요. - AWS Wrangler를 사용해 결과 CSV를 키
"sd-vehicle-data/speeders-full/full.csv"로 작성하세요.
실습형 인터랙티브 연습
이 예제를 이 샘플 코드를 완성하여 풀어보세요.
# 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")