构建自定义 Dask bag
Dask bag 的一个常见用法是把您已经写好的代码改造成并行运行。根据代码情况,有时先构造由延迟对象组成的列表再转换成 bag 更方便;另一些时候,则是在代码早期就形成一个 Dask bag,并在其上映射函数更顺手。哪种方式更容易取决于您的具体代码,因此掌握这两种方法都很重要。
已为您导入 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 = ____