APACHE AIRFLOW: VERİ İFADELERİNİN OLUŞTURULMASI VE YÖNETİMİ EĞİTİMİ

Airflow'da veri odaklı akışlar tasarlayın

Dataset tetikleme, hook/connection, veri kalitesi görevleri ve parametreli DAG'lerle veri akışlarını uçtan uca yönetin.

Airflow Datasets ile veri odaklı zamanlama, hook/connection ile kaynak erişimi, SQL check veri kalitesi, upsert ve yeniden işlemeyi öğreten orta seviye eğitim.

3 gün Orta Seviye Online / Yüz Yüze / Hibrit Sertifikalı

Eğitim Hakkında

Veri odaklı Airflow akışları ve kaynak yönetimi

Bu eğitim Airflow'da veri odaklı iş akışlarının oluşturulması ve yönetimine odaklanır. Datasets ile veri temelli zamanlama (data-aware scheduling), üretici-tüketici DAG bağlama, connection/hook ile veritabanı, S3 ve API kaynaklarına erişim işlenir. Parametreli DAG'ler (params), Jinja şablonlama ve templating, veri kalitesi kontrol görevleri, SQL check operatorları, staging ve upsert desenleri ele alınır. Dinamik task mapping ile çok kaynaklı yükleme, idempotency, yeniden işleme (reprocessing) ve izleme/uyarı uygulamalı gösterilir.

Süre ve Format

3 Gün. Her gün dört modül; dataset ve hook tabanlı DAG yazma labler içerir.

Seviye

Orta Seviye — Airflow'da veri odaklı DAG'ler, Datasets, hook/connection ile kaynak yönetimini kapsar.

Öğrenme Metodu

Üretici-tüketici DAG'leri Datasets ile bağlayıp hook üzerinden veri taşıyarak öğrenilir.

Neden Bu Eğitim?

🔗Veri Odaklı

Datasets ile veri hazır olduğunda tetiklenen akışlar kurarsınız.

🔌Kaynak Yönetimi

Hook/connection ile veritabanı, S3 ve API'yi güvenle bağlarsınız.

✅Veri Kalitesi

SQL check görevleriyle hat içinde kaliteyi doğrularsınız.

Anahtar Konular

airflow datasetsveri odaklı zamanlamaairflow hook connectionairflow veri kalitesiupsert deseniairflow templatingincremental yüklemeveri hattı yönetimiairflow eğitimi
“Veri akışını yöneten, veriyi ne zaman güveneceğini de bilir.”

Ön Koşullar

Eğitimden verim almak için faydalı olacak bilgi ve ortam gereksinimleri

1
Airflow Temeli

DAG, task ve operator kavramlarına aşinalık gerekir.

2
SQL

Veritabanı sorguları ve upsert mantığı faydalıdır.

3
Python

Hook ve callable yazımı için Python gerekir.

4
Lab Ortamı

Airflow ve bir veritabanı/S3 erişimi olan ortam gerekir.

Eğitim İçeriği

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.

Günün hedefiKatılımcı Datasets ile veri temelli zamanlama ve DAG bağlama kurabilir.
Modül 1
Datasets
  • Dataset tanımı
  • Üretici DAG (outlets)
  • Tüketici DAG tetikleme
  • Çoklu dataset bağımlılığı
  • Dataset güncelleme izleme
  • Zamanlama ile birleştirme
Modül 2
Parametreli DAG
  • params tanımı
  • Çalıştırmada parametre girme
  • Varsayılan ve doğrulama
  • Jinja ile parametre kullanımı
  • Konfigürasyon ayrımı
  • Yeniden kullanılabilir DAG
Modül 3
Templating
  • Jinja şablon alanları
  • ds/ts makroları
  • Custom macro tanımı
  • SQL dosyası şablonlama
  • render edilen alan inceleme
  • Hassas değer yönetimi
Modül 4
Bağımlılık Yönetimi
  • Cross-DAG bağımlılık
  • ExternalTaskSensor
  • Dataset vs sensor tercihi
  • Zamanlama hizalama
  • Döngüsüz bağımlılık
  • Akış dokümantasyonu
Günün hedefiKatılımcı hook/connection ile kaynaklara bağlanıp veri taşıyabilir.
Modül 1
Connection/Hook
  • Connection tanımlama
  • DbApiHook kullanımı
  • S3Hook ile nesne erişimi
  • HttpHook ile API
  • Secret backend
  • Bağlantı yeniden kullanımı
Modül 2
Veri Çıkarma
  • SQL ile kaynak okuma
  • API sayfalama (pagination)
  • Artımlı çekme (incremental)
  • Dosya indirme/okuma
  • Hız/rate limit yönetimi
  • Hata ve yeniden deneme
Modül 3
Yükleme Desenleri
  • Staging tabloya yükleme
  • Upsert/MERGE deseni
  • Partition yazma
  • COPY/bulk load çağrısı
  • İdempotent yazım
  • İşlem bütünlüğü
Modül 4
Dinamik Mapping
  • expand() ile çok kaynak
  • Dosya/partition üzerinde map
  • Parametre listesi üretme
  • Paralellik ve pool
  • Sonuç toplama
  • Kaynak başına hata izolasyonu
Günün hedefiKatılımcı hat içi veri kalitesi, yeniden işleme ve izleme kurabilir.
Modül 1
Veri Kalitesi
  • SQLColumnCheckOperator
  • SQLTableCheckOperator
  • Satır sayısı/eşik kontrolü
  • Null/duplicate kontrolü
  • Great Expectations entegrasyonu
  • Başarısızlıkta durdurma
Modül 2
Yeniden İşleme
  • Backfill ile yeniden yük
  • Idempotent silme/yükleme
  • clear ve rerun
  • Partition bazlı reprocess
  • Watermark sıfırlama
  • Veri düzeltme akışı
Modül 3
İzleme ve Uyarı
  • Log ve XCom inceleme
  • on_failure_callback
  • SLA ve bildirim
  • Slack/Email entegrasyonu
  • Metrik ve süre takibi
  • Olay kaydı
Modül 4
İyi Uygulamalar
  • DAG modülerliği
  • Ortam ayrımı (dev/prod)
  • Sürüm ve kod incelemesi
  • Dokümantasyon ve etiket
  • Test edilebilir callable
  • Yeniden üretilebilirlik

Eğitim Kazanımları

Program sonunda katılımcılar:

✅
Datasets

Veri temelli zamanlama ile üretici-tüketici DAG'leri bağlarsınız.

✅
Parametreli DAG

params ve Jinja ile yeniden kullanılabilir DAG yazarsınız.

✅
Hook/Connection

Veritabanı, S3 ve API kaynaklarını güvenle bağlarsınız.

✅
Veri Taşıma

Artımlı çekme ve bulk yükleme desenlerini uygularsınız.

✅
Yükleme

Staging ve upsert/MERGE ile idempotent yazım kurarsınız.

✅
Veri Kalitesi

SQL check görevleriyle hat içinde kaliteyi doğrularsınız.

✅
Yeniden İşleme

Backfill ve partition reprocess ile veriyi düzeltirsiniz.

✅
İzleme

Uyarı ve metriklerle operasyonel görünürlük sağlarsınız.

Kimler İçin Uygundur?

  • Airflow temelini bilen
  • veri hatlarını kaynak bağlantılarıyla yönetmek isteyen veri mühendisleri

Sıkça Sorulan Sorular

Bu eğitim kimler için uygundur?
Airflow temelini bilen ve veri hatlarını kaynak bağlantılarıyla yönetecek veri mühendisleri için uygundur.
Datasets neyi değiştirir?
Zamana değil veri güncellemesine bağlı tetikleme kurarak hatları veri-odaklı hale getirir.
Veri kalitesi nasıl kontrol edilir?
SQLColumnCheck/SQLTableCheck operatorları ve Great Expectations entegrasyonuyla hat içinde doğrulanır.
Airflow temel bilgisi şart mı?
Evet; DAG, task ve operator kavramlarına aşinalık beklenir.
Sertifika veriliyor mu?
Eğitim sonunda Digital Vizyon Akademi Katılım ve Başarı Sertifikası verilir.

Sertifikalandırma

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.

Örnek Sertifika d Digital Vizyon AKADEMİ KATILIM SERTİFİKASI Bu sertifika [Katılımcı Adı Soyadı] adlı katılımcının aşağıdaki eğitim programını başarıyla tamamladığını belgeler. Apache Airflow: Veri İfadelerinin Oluşturulması ve Yönetimi Sertifika Kodu DV-2026XX00 Tarih 26.10.2026 Yetkili İmza DV AKADEMİ

Eğitim Bilgileri

Süre3 gün
SeviyeOrta Seviye
FormatOnline / Yüz Yüze / Hibrit
Sertifika✓ Var
Hemen Bilgi Al
İlgili Eğitimler

Bu Eğitimle Birlikte Tercih Edilenler

Veri Mühendisliği ve AmbarıData Pipeline: Using Frameworks for Advanced Data Management Eğitimi
Veri ve Analitik Eğitimleri

Data Pipeline: Using Frameworks for Advanced Data Management Eğitimi

4 günİleriOnline / Yüz Yüze / Hibrit

dbt, Airflow ve Great Expectations/Soda ile test edilebilir, gözlemlenebilir ve CI/CD'li ileri veri hatları kurmayı uygulamalı öğrenin.

Detayları Gör →
Veri Mühendisliği ve AmbarıData Warehouse Essential: Architecture Frameworks & Implementation Eğitimi
Veri ve Analitik Eğitimleri

Data Warehouse Essential: Architecture Frameworks & Implementation Eğitimi

4 günİleriOnline / Yüz Yüze / Hibrit

Inmon, Kimball ve Data Vault çerçeveleri, katmanlı mimari, boyutsal/DV modelleme ve bulut ambar uygulamasını uygulamalı öğrenin.

Detayları Gör →
Veri Mühendisliği ve AmbarıData Warehouse Essential: Concepts Eğitimi
Veri ve Analitik Eğitimleri

Data Warehouse Essential: Concepts Eğitimi

2 günTemelOnline / Yüz Yüze / Hibrit

Veri ambarı temelleri: OLTP/OLAP, star/snowflake şema, olgu/boyut, grain, SCD tipleri, ETL süreci ve OLAP işlemlerini uygulamalı öğrenin.

Detayları Gör →
Veri Mühendisliği ve AmbarıDatabricks Göç Atölyesi: Depolanan Prosedürlerden Lakehouse'a (Günlük Yoğun Eğitim) Eğitimi
Veri ve Analitik Eğitimleri

Databricks Göç Atölyesi: Depolanan Prosedürlerden Lakehouse'a (Günlük Yoğun Eğitim) Eğitimi

2 günİleriOnline / Yüz Yüze / Hibrit

SQL stored procedure ETL'ini Databricks Lakehouse'a göç: kalıp çevirme, Delta MERGE/SCD, reconciliation ve cutover stratejisini yoğun atölyede öğrenin.

Detayları Gör →
Veri Mühendisliği ve AmbarıDatabricks ve PySpark ile Veri Mühendisliği Eğitimi
Veri ve Analitik Eğitimleri

Databricks ve PySpark ile Veri Mühendisliği Eğitimi

3 günOrtaOnline / Yüz Yüze / Hibrit

Databricks'te PySpark DataFrame, Spark SQL, Delta Lake MERGE, medallion mimari, performans ayarı ve Workflows ile veri mühendisliğini uygulamalı öğrenin.

Detayları Gör →
+90 (501) 369 40 14 WhatsApp [email protected] LinkedIn