從 CSV 建立 Dask DataFrame
先前你透過迴圈和延後(delayed)函式分析 Spotify 歌曲資料。現在你知道可以用 Dask DataFrame 更輕鬆地完成同樣的事。我們來看看,把先前做過的任務改用這些方法(而不是用迴圈)會有多容易。不過首先,你需要把資料集載入成一個 Dask DataFrame。
本練習屬於課程
在 Python 中使用 Dask 進行平行程式設計
練習說明
- 將
dask.dataframe子套件匯入為dd。 - 使用最大區塊大小 1MB 讀取
data/spotify資料夾中的所有 CSV 檔案。 - 使用
dd.to_datetime()函式把'release_date'欄位中的字串轉換為日期時間。 - 使用 DataFrame 的
.head()方法顯示資料表的 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(____)