การสร้าง Dask DataFrame จากไฟล์ CSV
ก่อนหน้านี้ได้วิเคราะห์ข้อมูลเพลง Spotify โดยใช้ loop และฟังก์ชัน delayed ตอนนี้เราจะใช้ Dask DataFrame แทน ซึ่งทำให้งานเดิมทำได้ง่ายขึ้นมาก มาดูกันว่างานที่เคยทำด้วย loop นั้น จะสะดวกขึ้นแค่ไหนเมื่อใช้วิธีนี้แทน แต่ก่อนอื่น ต้องโหลดชุดข้อมูลเข้า Dask DataFrame ก่อน
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
Parallel Programming with Dask in Python
คำแนะนำการฝึกหัด
- Import subpackage
dask.dataframeโดยใช้ชื่อย่อว่าdd - อ่านไฟล์ CSV ทั้งหมดในโฟลเดอร์
data/spotifyโดยกำหนด blocksize สูงสุดที่ 1MB - ใช้ฟังก์ชัน
dd.to_datetime()เพื่อแปลง string ในคอลัมน์'release_date'ให้เป็น datetime - ใช้เมธอด
.head()ของ DataFrame เพื่อแสดง 5 แถวแรกของตาราง
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำ
ลองทำแบบฝึกหัดนี้โดยเติมโค้ดตัวอย่างนี้ให้สมบูรณ์
# Import dask dataframe as dd
____
# Load in the DataFrame
df = ____
# Convert the release_date column from string to datetime
____
# Show 5 rows of the DataFrame
print(____)