Menjadwalkan Dag melalui Python
Anda telah mempelajari cukup banyak tentang membuat Dag, tetapi sekarang Anda ingin menjadwalkan sebuah Dag tertentu pada hari tertentu dalam seminggu pada jam tertentu. Anda ingin kode menyertakan informasi ini jika rekan kerja perlu memasang ulang Dag ke server yang berbeda.
Objek airflow dag dan metode datetime yang sesuai telah diimpor untuk Anda.
Latihan ini adalah bagian dari kursus
Pengantar Apache Airflow dengan Python
Petunjuk latihan
- Tetapkan tanggal mulai Dag ke 1 November 2025.
- Gunakan sintaks cron untuk mengonfigurasi jadwal setiap hari Rabu pukul 12:30 siang.
Latihan interaktif praktis
Cobalah latihan ini dengan menyelesaikan kode contoh berikut.
@dag(
dag_id='update_dataflows',
# Set to November 1, 2025
start_date=datetime(____),
# Every Wednesday at 12:30pm
schedule='____'
)
def update_dataflows():
@task
def pull_source_data():
pass
update_dataflows()