Leitura de dados do S3 com base em um evento
No final do último capítulo, você escreveu um método para ler dados do S3 - analyze_data. No entanto, você tinha que executar esse método manualmente.
Vamos escrever uma função Lambda que será executada sempre que o Firehose gravar um novo arquivo no S3. Por enquanto, ele imprime apenas os arquivos que foram adicionados.
Você editará o arquivo recordReaderS3/lambda_function.py
no editor. Ele contém o manipulador da nossa função Lambda.
Não se esqueça: um objeto que está sendo gravado no S3 resulta em um evento ObjectCreated:Put
. Você sempre pode clicar no ícone de slides no canto superior direito para ver os slides - eles serão muito úteis!
Este exercício faz parte do curso
Streaming de dados com AWS Kinesis e Lambda
Instruções do exercício
- Atualize o método lambda handler (
recordReaderS3/lambda_function.py
) para aceitar os argumentos corretos. - Analisar o evento de entrada. Se o evento for um evento de gravação do S3 e estiver em
"sd-vehicle-data"
, retorne a nova chave do objeto (essa última parte já foi resolvida para você). - No terminal, execute
python3 run_lambda.py
para implantar e testar sua função lambda.
Exercício interativo prático
Transforme a teoria em ação com um de nossos exercícios interativos
