1. Nauka
    2. /
  2. Kursy
    3. /
  3. Programowanie równoległe z Dask w Pythonie
Connected

ćwiczenie

Tworzenie własnych worków Dask

Częstym zastosowaniem worków Dask jest przekształcenie istniejącego kodu tak, aby działał równolegle. W zależności od kodu, czasem łatwiej jest zbudować listę obiektów opóźnionych i przekonwertować ją na worek. Innym razem wygodniej jest utworzyć worek Dask na początku kodu i mapować na niego funkcje. To, które podejście jest lepsze, zależy od konkretnego kodu – dlatego warto znać obie metody.

dask został już zaimportowany, a dask.bag jest dostępny jako db. W środowisku masz też dostępną listę nazw plików w postaci zmiennej wavfiles.

Instrukcje 1/2

undefined XP
  • 1
    • Przekonwertuj listę nazw plików na worek Dask.
    • Utwórz nowy worek z wczytanymi danymi audio, korzystając z napisanej wcześniej funkcji load_wav().
  • 2
    • Przejdź pętlą po plikach i zastosuj opóźnioną wersję funkcji load_wav() do każdego pliku z wavfiles, dołączając wynik do delayed_loaded_audio.
    • Przekonwertuj listę obiektów opóźnionych na worek Dask.