İş akışlarını Airflow DAG'leriyle planlayın
Airflow mimarisi, DAG ve operatör kavramları, schedule_interval/catchup, Jinja şablonlama ve XCom ile görevler arası veri aktarımını uygulamalı öğreten temel seviye eğitim.
Airflow mimarisi, DAG ve temel ilkeler
Bu eğitim, Apache Airflow'un temel kavram ve mimarisini sıfırdan öğretir. Scheduler, webserver, metadata veritabanı, executor ve worker bileşenlerinin rolü; DAG tanımı, task, operatör ve dependency (>> / set_upstream) kavramları işlenir. PythonOperator, BashOperator ve sensor kullanımı, schedule_interval, start_date, catchup ve backfill davranışı, Jinja şablonları ile {{ ds }} gibi context değişkenleri, XCom ile görevler arası veri aktarımı ve retries/SLA ayarları uygulamalı ele alınır. Airflow UI'da DAG izleme, log okuma ve manuel tetikleme gösterilir.
2 Gün. Her gün dört modül; yerel/Docker Airflow üzerinde DAG yazma ve çalıştırma lableri.
Temel Seviye — Apache Airflow'un mimarisi, DAG kavramı, operatörler ve zamanlama temellerini kapsar.
Çalışan bir Airflow kurulumunda adım adım DAG yazıp UI'dan tetikleyerek ve logları inceleyerek uygulanır.
Scheduler, executor ve metadata DB'nin nasıl birlikte çalıştığını kavrayarak sağlam temel kurarsınız.
DAG ve schedule ile veri hatlarını güvenilir, izlenebilir ve yeniden çalıştırılabilir yaparsınız.
Hatları kod olarak (Python) tanımlayıp sürüm kontrolüne alırsınız.
Eğitimden verim almak için faydalı olacak bilgi ve ortam gereksinimleri
Fonksiyon ve modül düzeyinde temel Python bilgisi gerekir.
Terminal ve temel Linux komutlarına aşinalık faydalıdır.
Veri alma/dönüştürme/yükleme akışına temel aşinalık beklenir.
Docker veya yerel Airflow kurabilen bir makine gerekir.
Programın gün gün akışı aşağıdadır. Bir güne tıklayarak o günün modüllerini ve içeriklerini görebilirsiniz.
Program sonunda katılımcılar:
Scheduler, executor ve metadata DB'nin rolünü açıklarsınız.
Task ve bağımlılıklarla çalışan DAG'ler kurarsınız.
PythonOperator, BashOperator ve TaskFlow API kullanırsınız.
schedule_interval, catchup ve backfill davranışını yönetirsiniz.
Jinja context değişkenleri ve Variables/Connections kullanırsınız.
Görevler arası veri aktarımını XCom ile kurarsınız.
retries, SLA, sensor ve trigger_rule ile sağlam hatlar yaparsınız.
UI'dan DAG'leri izler, logları okur ve yeniden çalıştırırsınız.
Bu eğitim Digital Vizyon Akademi Başarı Sertifikası ile tamamlanır.
Eğitim başında “Ön Test”, bitiminde “Son Test” uygulanarak gelişim ölçümlenir. Değerlendirme formunu dolduran katılımcılar sertifikalarını alır. Sertifikanızın geçerliliğini Sertifika Sorgulama sayfasından doğrulayabilirsiniz.
ETL testi temelleri: test türleri, STTM okuma, count reconciliation, dönüşüm doğrulama ve veri kalitesi kontrollerini SQL ile uygulamalı öğrenin.
Detayları Gör →Airflow'da özel operatör, hook, sensor, deferrable trigger ve plugin geliştirme; provider paketleme ve pytest/CI entegrasyonunu uygulamalı öğrenin.
Detayları Gör →Snowflake'e giriş: tablo oluşturma, COPY INTO ile veri yükleme, SQL sorgulama, virtual warehouse ve Snowsight dashboard'u uygulamalı öğrenin.
Detayları Gör →Snowflake mimarisi: depolama-hesaplama ayrımı, çok-kümeli warehouse, micro-partition, önbellekler, RBAC, zero-copy clone ve data sharing öğrenin.
Detayları Gör →Snowflake Time Travel ile veri kurtarma (UNDROP, AT/BEFORE, Fail-safe) ve SnowSQL CLI ile betik, PUT/GET ve otomasyonu uygulamalı öğrenin.
Detayları Gör →