BashOperator sırasını tanımla

Artık bitshift operatörlerini öğrendiğine göre, iş akışını bir pull adımı ve görev sıralamasını içerecek şekilde değiştirme zamanı. Halihazırda tanımlı üç bileşenin var: cleanup, consolidate ve push_data.

analytics_dag DAG'i her zamanki gibi hazır ve BashOperator zaten içe aktarılmış durumda.

Bu egzersiz

Python ile Apache Airflow'a Giriş

kursunun bir parçasıdır

Kursu Görüntüle

Egzersiz talimatları

pull_sales adlı bir BashOperator tanımla; bash komutu wget https://salestracking/latestinfo?json olsun.
pull_sales operatörünü cleanup görevinden önce çalışacak şekilde ayarla.
Downstream operatörünü kullanarak consolidate görevini sonraki adım olarak yapılandır.
push_data'yı bitshift operatörlerinden herhangi birini kullanarak en son çalışacak şekilde ayarla.

Uygulamalı interaktif egzersiz

Bu örnek kodu tamamlayarak bu egzersizi bitirin.

# 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 ____

Kodu Düzenle ve Çalıştır