Escribir en un flujo Firehose
Ahora que tenemos un flujo creado, vamos a escribir registros en él.
Archivo a editar
Editarás el archivo OBD2_sensors.py en el editor. Simularán los sensores del vehículo.
Como no tenemos a mano sensores de vehículos reales (ni vehículos), simularemos los datos de telemetría de un archivo CSV. Es una buena forma de probar antes de pasar a producción. El marco de datos está disponible en la variable vehicle_data.
Flujo de manguera de incendios:
En el último ejercicio creaste el flujo gps-delivery-stream Firehose. ¡A eso escribiremos!
Diapositivas
No lo olvides: siempre puedes hacer clic en el icono de diapositivas de la parte superior derecha para ver las diapositivas, ¡te serán muy útiles!
Este ejercicio forma parte del curso
Streaming de datos con AWS Kinesis y Lambda
Instrucciones de ejercicio
- Crea una cadena
payloadpara cada fila de datos que termine en un carácter de nueva línea. - Envía la carga útil al flujo
gps-delivery-streamFirehose. - Imprime el escrito resultante
RecordId.
Ejercicio interactivo práctico
Convierte la teoría en acción con uno de nuestros ejercicios interactivos
Empieza a hacer ejercicio