É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. Ceux-ci simuleront les capteurs du véhicule.

Comme nous ne disposons pas de capteurs de véhicules réels (ou de véhicules), nous simulerons des données de télémétrie à partir d'un fichier CSV. C'est un bon moyen de tester avant de passer à la production. Le DataFrame est disponible dans la variable vehicle_data.

Flux d'informations (Firehose Stream) :

Dans le dernier exercice, vous avez créé le flux gps-delivery-stream Firehose. C'est à cela que nous allons écrire !

Diapositives

N'oubliez pas que vous pouvez toujours cliquer sur l'icône des diapositives en haut à droite pour voir les diapositives - elles vous seront très utiles !