時間トリガーの Lambda コード

Cody は、スピード違反者の完全なレポートを、いつまでも、全期間分取得できるようにし、さらに毎晩更新したいと考えています。

そこで、毎晩実行されるジョブを作成してほしいと依頼されました。

現在の構成は次のとおりです：

前の演習で作成した関数の lambda_handler メソッドに入るコードを書いてください。

boto3、pandas、awsrangler はすでにインポートされており、キーも定義済みです。

さあ、始めましょう！

この演習はコースの一部です

AWS Kinesis と Lambda で学ぶストリーミングデータ

コースを見る

演習の手順

AWS_KEY_ID と AWS_SECRET を使って boto3 セッションを初期化します。
そのセッションを AWS Wrangler の read_csv メソッドに渡して、すべてのスピード違反データフレームを取得します。
AWS Wrangler を使って、キー "sd-vehicle-data/speeders-full/full.csv" で結果の 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")

コードを編集して実行