Konwersja do DataFrame

Chcesz utworzyć DataFrame z danych JSON dotyczących polityków. Po spłaszczeniu struktury danych pozostało już tylko wybrać klucze, które staną się kolumnami w DataFrame.

Dask bag utworzony w poprzednim ćwiczeniu jest dostępny w środowisku pod nazwą dict_bag.

To ćwiczenie jest częścią kursu

Programowanie równoległe z Dask w Pythonie

Zobacz kurs

Instrukcje do ćwiczenia

Uzupełnij funkcję select_keys() tak, aby klucze z listy keys_to_keep były dodawane do nowego, przefiltrowanego słownika i zwracane jako wynik.
Użyj funkcji select_keys(), aby wybrać klucze ['gender','name', 'birth_date', 'url'] z dict_bag.
Przekonwertuj przefiltrowany bag na Dask DataFrame.
Wyświetl kilka pierwszych wierszy DataFrame.

Interaktywne ćwiczenie praktyczne

Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.

def select_keys(dictionary, keys_to_keep):
  new_dict = {}
  # Loop through kept keys and add them to new dictionary
  for k in ____:
    ____
  return new_dict

# Use the select_keys to reduce to the 4 required keys
filtered_bag = dict_bag.map(____, ____=____)

# Convert the restructured bag to a DataFrame
df = filtered_bag.____

# Print the first few rows of the DataFrame
print(____)

Edytuj i uruchom kod