自訂建立 Dask bag
Dask bag 的常見用法之一,是把你已經寫好的程式碼改為平行執行。依照程式碼的結構,有時先建立一串延遲(delayed)物件的清單,再把它轉成 bag 會比較容易;有時候則是及早在程式中建立 Dask bag,然後在其上對映(map)函式會比較直覺。哪一種方式較容易,取決於你的實際程式碼,因此同時熟悉這兩種方法很重要。
已為你匯入 dask,且將 dask.bag 以 db 名稱匯入。環境中已有一個檔名字串的清單,變數名稱為 wavfiles。
本練習屬於課程
在 Python 中使用 Dask 進行平行程式設計
動手互動練習
試著完成這個範例程式碼,體驗一下這個練習。
# Convert the list of filenames into a Dask bag
filename_bag = ____
# Apply the load_wav() function to each element of the bag
loaded_audio_bag = ____