Membaca variabel di Python

Anda menyadari bahwa menggunakan Variable di dalam Dag akan memberi sedikit kendali atas konfigurasi di berbagai lingkungan, termasuk server Airflow pengembangan dan pengujian Anda. Agar tidak perlu memperbarui kode Dag untuk masing-masing lingkungan, Anda memutuskan untuk menerapkan variabel Output_Path untuk menyimpan lokasi di server tempat berbagai berkas disimpan.

Objek dag dan task telah diimpor untuk Anda, bersama dengan datetime.

Latihan ini merupakan bagian dari kursus

Pengantar Apache Airflow dengan Python

Lihat Kursus

Instruksi latihan

Impor pustaka yang diperlukan untuk bekerja dengan Variable.
Baca variabel Output_Path dari Airflow.
Sediakan nilai cadangan /home jika Output_Path tidak ditentukan.

Latihan interaktif langsung praktik

Cobalah latihan ini dengan melengkapi kode contoh ini.

# 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()

Edit dan Jalankan Kode