Schreiben in einen Firehose-Stream

Jetzt, wo wir einen Stream erstellt haben, werden wir Datensätze in diesen Stream schreiben.

Zu bearbeitende Datei

Du wirst die Datei OBD2_sensors.py mit dem Editor bearbeiten. Diese simulieren die Sensoren des Fahrzeugs.

Da wir keine echten Fahrzeugsensoren (oder Fahrzeuge) zur Verfügung haben, werden wir Telemetriedaten aus einer CSV Datei simulieren. Das ist eine gute Möglichkeit, um zu testen, bevor du in die Produktion gehst. Der DataFrame ist in der Variable vehicle_data verfügbar.

Firehose Stream:

In der letzten Übung hast du den Stream gps-delivery-stream Firehose erstellt. Das ist es, was wir schreiben werden!

Folien

Vergiss nicht - du kannst immer auf das Foliensymbol oben rechts klicken, um die Folien zu sehen - sie sind sehr hilfreich!