Kiểm thử tích hợp với dag.test()
Kiểm thử tính toàn vẹn xác minh việc tải dữ liệu và kiểm thử đơn vị xác minh logic, nhưng cả hai đều không chạy Dag thực tế. Kiểm thử tích hợp với dag.test() lấp khoảng trống đó bằng cách thực thi tất cả task tuần tự trong một tiến trình. Một pipeline ETL tên etl_output đã được triển khai và ghi kết quả vào /tmp/etl_results.json.
Bạn sẽ viết một bài kiểm thử tích hợp để chạy toàn bộ pipeline và xác minh đầu ra của nó.
Bài tập này là một phần của khóa học
Xây dựng Data Pipeline với Airflow
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