Schrijven naar een Firehose-stream

Nu we een stream hebben aangemaakt, gaan we er records naartoe schrijven.

Te bewerken bestand

Je bewerkt het bestand OBD2_sensors.py in de editor. Deze code simuleert de sensoren in het voertuig.

Omdat we geen echte voertuigsensoren (of voertuigen) beschikbaar hebben, simuleren we telemetriegegevens uit een CSV-bestand. Dat is een goede manier om te testen voordat je naar productie gaat. De dataframe staat in de variabele vehicle_data.

Firehose-stream:

In de vorige oefening heb je de Firehose-stream gps-delivery-stream aangemaakt. Daar gaan we nu naartoe schrijven!

Dia's

Vergeet niet: je kunt altijd op het pictogram dia's rechtsboven klikken om de dia's te bekijken — die zijn erg handig!