Daha fazla PythonOperator

İş akışını uygulamaya devam etmek için, indirilen dosyayı ayrıştırıp değişiklikleri kaydeden bir adım daha eklemen gerekiyor. process_sales_dag adlı DAG tanımlanmış ve pull_file görevi zaten eklenmiş durumda. Bu durumda, Python fonksiyonu da senin için hazır: parse_file(inputfile, outputfile).

Unutma, Airflow görevlerini uygularken sana verilen adımların her birini tek tek anlamayabilirsin. Bu adımları Airflow'un yapısı içine doğru şekilde yerleştirmeyi bildiğin sürece, hedeflenen iş akışını başarıyla uygulayabilirsin.

Bu egzersiz

Python ile Apache Airflow'a Giriş

kursunun bir parçasıdır

Kursu Görüntüle

Egzersiz talimatları

Python görevini parse_file_task değişkenine, kimliği parse_file olacak şekilde tanımla.
Operatöre parse_file(inputfile, outputfile) fonksiyonunu ekle.
callable'a aktarılacak argümanları tanımla.

Uygulamalı interaktif egzersiz

Bu örnek kodu tamamlayarak bu egzersizi bitirin.

# Add another Python task
____ = ____(
    task_id=____,
    # Set the function to call
    ____
    # Add the arguments
    ____={'inputfile':'latestsales.json', 'outputfile':'parsedfile.json'},
)

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