Запись в поток Firehose

Теперь, когда поток создан, мы запишем в него записи.

Файл для редактирования

Вы будете редактировать файл OBD2_sensors.py в редакторе. Этот файл имитирует датчики транспортного средства.

Поскольку у нас нет настоящих датчиков (и самих транспортных средств), мы будем симулировать телеметрические данные на основе CSV-файла. Это удобный способ протестировать всё перед запуском в продакшн. Датафрейм доступен в переменной vehicle_data.

Поток Firehose:

В предыдущем упражнении вы создали поток Firehose gps-delivery-stream. Именно в него мы и будем записывать данные!

Слайды

Не забывайте — вы всегда можете нажать на иконку Слайды в правом верхнем углу, чтобы просмотреть слайды. Они окажутся очень полезными!