Tạo Dask DataFrame từ các tệp CSV
Trước đây, bạn đã phân tích dữ liệu bài hát Spotify bằng vòng lặp và các hàm delayed. Giờ bạn biết rằng có thể làm điều tương tự dễ dàng hơn với Dask DataFrame. Hãy xem các tác vụ bạn đã làm trước đó trở nên đơn giản thế nào khi dùng các phương thức này thay vì vòng lặp. Tuy nhiên, trước hết, bạn cần nạp tập dữ liệu vào một Dask DataFrame.
Bài tập này là một phần của khóa học
Lập trình song song với Dask trong Python
Hướng dẫn bài tập
- Import gói con
dask.dataframevới bí danhdd. - Đọc tất cả các tệp CSV trong thư mục
data/spotifyvới kích thước khối tối đa 1MB. - Dùng hàm
dd.to_datetime()để chuyển các chuỗi trong cột'release_date'thành datetime. - Dùng phương thức
.head()của DataFrame để hiển thị 5 hàng đầu của bảng.
Bài tập tương tác thực hành trực tiếp
Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.
# Import dask dataframe as dd
____
# Load in the DataFrame
df = ____
# Convert the release_date column from string to datetime
____
# Show 5 rows of the DataFrame
print(____)