Conversia în DataFrame
Vrei să creezi un DataFrame din datele JSON despre politicieni. Acum că ai eliminat structurile imbricate, tot ce trebuie să faci este să selectezi cheile care vor deveni coloane în DataFrame.
Dask bag-ul creat în exercițiul anterior este disponibil în mediul tău ca dict_bag.
Acest exercițiu face parte din cursul
Programare paralelă cu Dask în Python
Instrucțiuni pentru exercițiu
- Completează funcția
select_keys()astfel încât cheile din listakeys_to_keepsă fie adăugate în noul dicționar filtrat și returnate. - Folosește funcția
select_keys()pentru a selecta cheile['gender','name', 'birth_date', 'url']dindict_bag. - Convertește bag-ul filtrat într-un Dask DataFrame.
- Afișează primele câteva rânduri ale DataFrame-ului.
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
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(____)