Łączenie operacji
Gdy dane są już wczytane i oczyszczone, możesz przystąpić do ich analizy. Pierwsze zadanie polega na zbadaniu dat urodzenia polityków. Daty są zapisane w formacie tekstowym, np. 'YYYY-MM-DD'. Pierwsze 4 znaki łańcucha to rok.
Filtrowany worek Dask utworzony w poprzednim ćwiczeniu, filtered_bag, jest dostępny w twoim środowisku.
To ćwiczenie jest częścią kursu
Programowanie równoległe z Dask w Pythonie
Instrukcje do ćwiczenia
- Użyj metody
.pluck()worka, aby wyodrębnić łańcuchy'birth_date'. - Napisz funkcję lambda, która wyodrębni rok z łańcuchów
'birth_date'i przekształci go na liczbę całkowitą. - Użyj nowego worka
birth_year_bag, aby obliczyć minimalny, maksymalny i średni rok urodzenia. - Użyj funkcji
dask.compute(), aby efektywnie obliczyć wszystkie trzy agregacje.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
# Select the 'birth_date' from each dictionary in the bag
birth_date_bag = filtered_bag.____
# Extract the year as an integer from the birth_date strings
birth_year_bag = birth_date_bag.____(lambda x: ____)
# Calculate the min, max and mean birth years
min_year = ____
max_year = ____
mean_year = ____
# Compute the results efficiently and print them
print(____(____))