ComeçarComece de graça

Gravação em um fluxo do Firehose

Agora que temos um fluxo criado, vamos gravar registros nele.

vRg6A.png

Arquivo para editar

Você editará o arquivo OBD2_sensors.py no editor. Eles simularão os sensores do veículo.

Como não temos sensores de veículos reais (ou veículos) à disposição, simularemos dados de telemetria de um arquivo CSV. É uma boa maneira de você testar antes de entrar em produção. O quadro de dados está disponível na variável vehicle_data.

Fluxo de mangueiras:

No último exercício, você criou o fluxo gps-delivery-stream Firehose. É para isso que vamos escrever!

Slides

Não se esqueça: 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

  • Crie uma cadeia de caracteres payload para cada linha de dados que termina em um caractere de nova linha.
  • Envie a carga útil para o fluxo gps-delivery-stream Firehose.
  • Imprima a escrita resultante RecordId.

Exercício interativo prático

Transforme a teoria em ação com um de nossos exercícios interativos

Começar o exercício