Ghi vào một Firehose stream

Bây giờ khi đã có stream, chúng ta sẽ ghi bản ghi vào đó.

Tệp cần chỉnh sửa

Bạn sẽ chỉnh sửa tệp OBD2_sensors.py trong trình soạn thảo. Tệp này sẽ mô phỏng các cảm biến trên xe.

Vì chúng ta không có sẵn cảm biến (hoặc xe) thực tế, nên ta sẽ mô phỏng dữ liệu telemetry từ một tệp CSV. Đây là cách tốt để kiểm thử trước khi đưa vào vận hành. DataFrame đã có sẵn trong biến vehicle_data.

Firehose Stream:

Ở bài trước, bạn đã tạo Firehose stream gps-delivery-stream. Giờ chúng ta sẽ ghi vào đó!

Slides

Đừng quên — bạn luôn có thể bấm vào biểu tượng slides ở góc trên bên phải để xem các slide — chúng sẽ rất hữu ích!