Streaming dữ liệu bán lẻ vào Delta Lake
Mỗi ngày, các file đơn hàng mới sẽ được đưa vào volume của nhóm bạn tại Global Retail Analytics.
Thay vì nạp lại mọi thứ mỗi sáng, bạn sẽ xây dựng một pipeline streaming tự động nhận các file CSV mới, ghi chúng vào Delta Lake và có thể khôi phục ổn định sau khi khởi động lại nhờ checkpoints.
Bài tập này là một phần của khóa học
Chuyển đổi dữ liệu với Spark SQL trong Databricks
Bài tập tương tác thực hành
Biến lý thuyết thành hành động với một trong các bài tập tương tác của chúng tôi
Bắt đầu bài tập