Menentukan urutan BashOperator

Sekarang setelah Anda mempelajari operator bitshift, saatnya memodifikasi alur kerja Anda untuk menyertakan langkah pull dan mengatur urutan tugas. Anda memiliki tiga komponen yang saat ini telah didefinisikan, yaitu cleanup, consolidate, dan push_data.

DAG analytics_dag tersedia seperti sebelumnya dan BashOperator sudah diimpor.

Latihan ini adalah bagian dari kursus

Pengantar Apache Airflow dengan Python

Lihat Kursus

Petunjuk latihan

Definisikan BashOperator bernama pull_sales dengan perintah bash wget https://salestracking/latestinfo?json.
Atur agar operator pull_sales berjalan sebelum tugas cleanup.
Konfigurasikan consolidate agar berjalan berikutnya dengan menggunakan operator downstream.
Atur push_data agar berjalan terakhir menggunakan salah satu operator bitshift.

Latihan interaktif praktis

Cobalah latihan ini dengan menyelesaikan kode contoh berikut.

# Define a new pull_sales task
pull_sales = ____(
    task_id='pullsales_task',
    ____
)

# Set pull_sales to run prior to cleanup
pull_sales ____ cleanup

# Configure consolidate to run after cleanup
____

# Set push_data to run last
consolidate ____

Edit dan Jalankan Kode