Перетворення на DataFrame
Ви хочете створити DataFrame з JSON-даних про політиків. Тепер, коли ви розгорнули вкладені структури, потрібно лише вибрати ключі, які слід зберегти як стовпці в DataFrame.
Створений у попередній вправі Dask bag доступний у вашому середовищі як dict_bag.
Ця вправа є частиною курсу
Паралельне програмування з Dask у Python
Інструкції до вправи
- Доповніть функцію
select_keys()так, щоб ключі зі спискуkeys_to_keepбули додані до нового відфільтрованого словника і повернені. - Використайте функцію
select_keys(), щоб вибрати ключі['gender','name', 'birth_date', 'url']зdict_bag. - Перетворіть відфільтрований bag на Dask DataFrame.
- Виведіть перші кілька рядків DataFrame.
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
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(____)