ComeçarComece de graça

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.

PCXoZ.png

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

Ver curso

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

Começar o exercício