การเขียนข้อมูลลง Firehose Stream

ตอนนี้เราสร้าง stream เรียบร้อยแล้ว มาเขียน record ลงไปกัน

ไฟล์ที่ต้องแก้ไข

ให้แก้ไขไฟล์ OBD2_sensors.py ในตัวแก้ไขโค้ด ไฟล์นี้จำลองการทำงานของเซ็นเซอร์บนยานพาหนะ

เนื่องจากเราไม่มีเซ็นเซอร์หรือยานพาหนะจริง เราจะจำลองข้อมูล telemetry จากไฟล์ CSV แทน ซึ่งเป็นวิธีที่ดีสำหรับการทดสอบก่อนนำขึ้น production โดย dataframe พร้อมใช้งานในตัวแปร vehicle_data

Firehose Stream:

ในแบบฝึกหัดที่แล้ว เราสร้าง Firehose stream ชื่อ gps-delivery-stream ไว้แล้ว นั่นคือ stream ที่เราจะเขียนข้อมูลลงไป

สไลด์

อย่าลืม — สามารถคลิกที่ไอคอน สไลด์ มุมบนขวาเพื่อดูสไลด์ได้ตลอดเวลา ซึ่งจะเป็นประโยชน์มาก!