Écrire dans un flux Firehose

Maintenant que nous avons créé un flux, nous allons y écrire des enregistrements.

Fichier à modifier

Vous allez modifier le fichier OBD2_sensors.py dans l’éditeur. Il simulera les capteurs du véhicule.

Comme nous n’avons pas de capteurs réels (ni de véhicules) à disposition, nous allons simuler des données de télémétrie à partir d’un fichier CSV. C’est un bon moyen de tester avant la mise en production. Le dataframe est disponible dans la variable vehicle_data.

Flux Firehose :

Dans l’exercice précédent, vous avez créé le flux Firehose gps-delivery-stream. C’est celui que nous allons utiliser pour l’écriture !

Diaporama

N’oubliez pas : vous pouvez toujours cliquer sur l’icône Diaporama en haut à droite pour afficher les slides — elles vous seront très utiles !