Gravação em um fluxo do Firehose
Agora que temos um fluxo criado, vamos gravar registros nele.
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
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
