1. Učit se
    2. /
  2. Kurzy
    3. /
  3. Parallel Programming with Dask in Python
Connected

cvičení

Vytváření vlastních Dask bags

Častým případem použití Dask bags je převedení již napsaného kódu tak, aby běžel paralelně. V závislosti na kódu může být někdy jednodušší sestavit seznam delayed objektů a ten pak převést na bag. Jindy je výhodnější vytvořit Dask bag hned na začátku a mapovat přes něj funkce. Která z těchto možností je vhodnější závisí na konkrétním kódu, takže je důležité, abys uměl/a použít obě metody.

dask je již naimportován a dask.bag je dostupný jako db. V prostředí máš k dispozici seznam názvů souborů wavfiles.

Instrukce 1/2

undefined XP
  • 1
    • Převeď seznam názvů souborů na Dask bag.
    • Vytvoř nový bag s načtenými audio daty pomocí funkce load_wav(), kterou jsi napsal/a.
  • 2
    • Projdi soubory ve smyčce a na každý soubor z wavfiles aplikuj delayed verzi funkce load_wav(), přičemž výsledek přidávej do delayed_loaded_audio.
    • Převeď seznam delayed objektů na Dask bag.