Membuat Dag sederhana
Anda telah meninjau komponen Airflow dan tertarik untuk menguji alur kerja Anda sendiri. Untuk memulai, Anda memutuskan untuk mendefinisikan parameter default dan membuat objek Dag untuk alur kerja Anda.
Objek datetime telah diimpor untuk Anda.
Latihan ini merupakan bagian dari kursus
Pengantar Apache Airflow dengan Python
Instruksi latihan
- Impor objek Dag Airflow; perhatikan bahwa penulisan huruf besar-kecilnya peka (case-sensitive).
- Definisikan dekorator Dag dan beri nama Dag
example_etl. - Jalankan fungsi Dag di akhir berkas kode.
Latihan interaktif langsung praktik
Cobalah latihan ini dengan melengkapi kode contoh ini.
# Import the dag object
from ____ import dag
# Define the Dag attributes
____(
____='example_etl',
start_date=datetime(2026, 3, 1),
)
def example_etl():
pass
# Run the Dag
____()