Převod na DataFrame
Chceš vytvořit DataFrame z JSON dat o politicích. Teď, když jsi data odstranil/a z vnořené struktury, stačí vybrat klíče, které se stanou sloupci DataFramu.
Dask bag, který jsi vytvořil/a v předchozím cvičení, je dostupný v prostředí jako dict_bag.
Toto cvičení je součástí kurzu
Parallel Programming with Dask in Python
Pokyny k cvičení
- Dokonči funkci
select_keys()tak, aby klíče ze seznamukeys_to_keepbyly přidány do nového filtrovaného slovníku a vráceny. - Pomocí funkce
select_keys()vyber klíče['gender','name', 'birth_date', 'url']zdict_bag. - Převeď filtrovaný bag na Dask DataFrame.
- Vypiš prvních několik řádků DataFramu.
Interaktivní cvičení na vyzkoušení si v praxi
Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.
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(____)