イベントに基づいてS3からデータを読み込む

前の章の最後で、S3からデータを読み込む analyze_data メソッドを書きました。ただし、そのメソッドは手動で実行する必要がありました。

ここでは、Firehose が S3 に新しいファイルを書き込むたびに実行される Lambda 関数を作成します。まずは、追加されたファイル名を出力するだけにします。

エディタで recordReaderS3/lambda_function.py を編集してください。これは Lambda 関数のハンドラーを含んでいます。

お忘れなく：S3 へのオブジェクト書き込みは ObjectCreated:Put イベントになります。右上の スライド アイコンをクリックするとスライドを確認できます。役に立ちますよ！