Đọc một Variable trong Python
Bạn nhận ra rằng dùng Variables trong các Dag sẽ giúp bạn kiểm soát một phần cấu hình trên nhiều môi trường, bao gồm cả các máy chủ Airflow cho phát triển và kiểm thử. Để tránh phải cập nhật mã Dag cho từng môi trường, bạn quyết định triển khai biến Output_Path để lưu vị trí trên máy chủ nơi các tệp được giữ.
Các đối tượng dag và task đã được nhập sẵn cho bạn, cùng với datetime.
Bài tập này là một phần của khóa học
Giới thiệu về Apache Airflow bằng Python
Hướng dẫn bài tập
- Nhập thư viện cần thiết để làm việc với Variables.
- Đọc biến
Output_Pathtừ Airflow. - Cung cấp giá trị dự phòng là
/homenếuOutput_Pathchưa được định nghĩa.
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 the proper library to read Variables
from airflow.____ import ____
@dag(dag_id='process_sales', start_date=datetime(2026, 4, 15))
def process_sales():
@task()
def parse_file():
# Get the output file location, otherwise default to "/home"
output_path = ____.____("Output_Path", ____="/home")
# Logging only currently - processing to be added later
print(f"File parsed and saved to {output_path}/sales_report.pdf")
parse_file()
process_sales()