Реструктуризація словника
Тепер ви хочете очистити дані про політиків і перенести їх у Dask DataFrame. Однак дані про політиків вкладені, тож перед тим, як вони підійдуть для DataFrame, їх потрібно ще обробити.
Один конкретний фрагмент даних, який ви хочете витягти, захований на кілька рівнів углиб словника. Це посилання на вебсайт для кожного політика. Нижче наведено приклад, як це зберігається в словнику.
record = {
...
'links': [{'note': '...',
'url': '...'},], # Stored here
...
}
Bag із даними про політиків доступний у вашому середовищі як dict_bag.
Ця вправа є частиною курсу
Паралельне програмування з Dask у Python
Інструкції до вправи
- Завершіть функцію
extract_url(), щоб витягти ключ'url'зі словника, який міститься в нульовій позиції списку під ключем'links', і присвоїти це значення ключуurl. - Запустіть функцію
extract_url()для всіх елементів bag.
Інтерактивна практична вправа
Спробуйте виконати цю вправу, доповнивши цей зразок коду.
def extract_url(x):
# Extract the url and assign it to the key 'url'
x['url'] = x[____][____][____]
return x
# Run the function on all elements in the bag.
dict_bag = ____
print(dict_bag.take(1))