ORTA SEVİYE APACHE AIRFLOW: İŞ AKIŞLARINI OPTİMİZASYON VE ÖLÇEKLENDİRME EĞİTİMİ

Airflow'u ölçekleyin ve hızlandırın

Celery/Kubernetes executor, paralellik, pool, dinamik task mapping ve performans ayarıyla Airflow'u üretim ölçeğine taşıyın.

Executor seçimi, paralellik ayarları, pool/priority, dinamik task mapping, deferrable operatörler ve scheduler/parsing performansıyla Airflow iş akışlarını optimize edip ölçekleyen orta seviye eğitim.

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

Eğitim Hakkında

Airflow iş akışlarının optimizasyonu ve ölçeklendirilmesi

Bu eğitim, Apache Airflow iş akışlarının performansını artırmayı ve ölçeklendirmeyi öğretir. Executor seçimi (LocalExecutor, CeleryExecutor, KubernetesExecutor) ve mimari etkileri, paralellik ayarları (parallelism, dag_concurrency, max_active_tasks, max_active_runs) işlenir. Pool ile kaynak sınırlama, priority_weight, queue yönlendirme, dinamik task mapping (expand/partial), TaskGroup ile düzen ve deferrable operatörlerle verimli bekleme ele alınır. DAG parsing süresi optimizasyonu, scheduler performansı, veritabanı yükü, SLA/retry stratejisi ve izleme (metrikler, log) uygulamalı gösterilir.

Süre ve Format

3 Gün. Her gün dört modül; executor, paralellik ve dinamik mapping ayar lableri.

Seviye

Orta Seviye — Airflow iş akışlarını optimize etme ve ölçeklendirme; executor seçimi, paralellik, pool ve performans ayarını kapsar.

Öğrenme Metodu

Çalışan bir Airflow kümesinde executor, pool ve paralellik ayarlarını değiştirip etkisini ölçerek uygulanır.

Neden Bu Eğitim?

⚡Daha Hızlı

Paralellik ve executor ayarıyla iş akışı süresini belirgin kısaltırsınız.

📈Ölçek

Celery/Kubernetes executor ile yükü yatayda ölçeklersiniz.

🎚️Kontrol

Pool ve priority ile kaynakları iş yüküne göre adil dağıtırsınız.

Anahtar Konular

airflow ölçeklendirmeairflow optimizasyoncelery executorkubernetes executorairflow pooldinamik task mappingdeferrable operatorairflow performans
“Ölçek, doğru ayarlanmış kaynaklarla sessizce gelir.”

Ön Koşullar

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

1
Airflow Temeli

DAG, operatör ve zamanlama bilgisi gerekir.

2
Python

Orta düzey Python bilgisi beklenir.

3
Ortam

Çalışan bir Airflow kurulumu (tercihen Docker/K8s) gerekir.

4
Sistem Fikri

CPU/bellek ve eşzamanlılık kavramına aşinalık faydalıdır.

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ı executor seçer ve paralellik ayarlarını doğru yapılandırabilir.
Modül 1
Executor Seçimi
  • LocalExecutor
  • CeleryExecutor mimarisi
  • KubernetesExecutor
  • CeleryKubernetes hibrit
  • Worker ölçeklendirme
  • Seçim ölçütleri
Modül 2
Paralellik Ayarları
  • parallelism (kurulum geneli)
  • max_active_tasks_per_dag
  • max_active_runs_per_dag
  • worker_concurrency
  • Varsayılanları ayarlama
  • Darboğaz tespiti
Modül 3
Kuyruk ve Dağıtım
  • Celery queue tanımı
  • queue ile görev yönlendirme
  • Worker-queue eşleme
  • İzole iş yükü
  • Ölçeklenebilir worker
  • Kaynak ayrımı
Modül 4
İzleme
  • Scheduler/worker metrikleri
  • StatsD/Prometheus
  • Görev süreleri
  • Kuyruk gecikmesi
  • Kaynak kullanımı
  • Darboğaz analizi
Günün hedefiKatılımcı pool/priority ile kaynak yönetir ve dinamik task mapping uygular.
Modül 1
Pool ve Öncelik
  • Pool oluşturma ve slot
  • Görevi pool'a atama
  • priority_weight
  • weight_rule
  • Kaynak kıtlığı yönetimi
  • Adil dağıtım
Modül 2
Dinamik Task Mapping
  • expand() ile dinamik görev
  • partial() sabit argüman
  • Map index ve XCom
  • map_index_template
  • Dinamik fan-out/fan-in
  • Sınır ve performans
Modül 3
TaskGroup ve Düzen
  • TaskGroup ile gruplama
  • İç içe grup
  • Bağımlılık sadeleştirme
  • Dinamik TaskGroup
  • UI okunabilirliği
  • Yeniden kullanım
Modül 4
Verimli Bekleme
  • Sensor poke vs reschedule
  • Deferrable operator
  • Triggerer kullanımı
  • Worker slot tasarrufu
  • Zaman aşımı
  • Kaynak dostu desenler
Günün hedefiKatılımcı parsing/scheduler ve veritabanı yükünü optimize edebilir.
Modül 1
DAG Parsing
  • DAG dosyası parsing süresi
  • Top-level kod kaçınma
  • min_file_process_interval
  • DAG sayısı etkisi
  • Import optimizasyonu
  • dagbag ölçümü
Modül 2
Scheduler Performansı
  • Scheduler ayarları
  • Birden çok scheduler (HA)
  • Metadata DB yükü
  • Connection pooling
  • Query optimizasyonu
  • Loop süresi
Modül 3
Güvenilirlik
  • Retry/retry_delay stratejisi
  • SLA ve kaçırma
  • Zombie görev yönetimi
  • Idempotent görev
  • Catchup/backfill kontrolü
  • Hata izolasyonu
Modül 4
Üretim İyi Uygulamaları
  • Kaynak profilleme
  • Yük testi
  • Log yönetimi/temizlik
  • Metadata DB temizliği
  • Kapasite planlama
  • Maliyet dengesi

Eğitim Kazanımları

Program sonunda katılımcılar:

✅
Executor

İş yüküne uygun executor seçip yapılandırırsınız.

✅
Paralellik

parallelism ve max_active_* ayarlarını doğru belirlersiniz.

✅
Kuyruk

Queue ile görevleri izole worker'lara yönlendirirsiniz.

✅
Pool & Öncelik

Pool ve priority_weight ile kaynakları adil dağıtırsınız.

✅
Dinamik Mapping

expand/partial ile dinamik fan-out/fan-in kurarsınız.

✅
Verimli Bekleme

Deferrable operatörlerle worker kaynağını korursunuz.

✅
Parsing & Scheduler

DAG parsing ve scheduler performansını optimize edersiniz.

✅
İzleme

Metriklerle darboğazları bulup kapasite planlarsınız.

Kimler İçin Uygundur?

  • Airflow'u üretimde çalıştıran veri mühendisleri
  • performans/ölçek sorunları yaşayan platform ekipleri

Sıkça Sorulan Sorular

Bu eğitim kimler için uygundur?
Airflow'u üretimde çalıştıran ve performans/ölçek sorunları yaşayan veri mühendisleri ile platform ekipleri için uygundur.
Hangi executor ne zaman?
LocalExecutor küçük kurulumlar, CeleryExecutor yatay ölçek, KubernetesExecutor izole ve elastik iş yükleri için işlenir.
Dinamik task mapping nedir?
expand/partial ile çalışma zamanında girdi sayısına göre görevlerin dinamik üretilmesidir (fan-out/fan-in).
Deferrable operator ne sağlar?
Uzun beklemelerde worker slotunu boşaltarak triggerer üzerinden verimli asenkron bekleme sağlar.
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. Orta Seviye Apache Airflow: İş Akışlarını Optimizasyon ve Öl 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ıTraditional Data Architectures: Data Warehousing and ETL Systems Eğitimi
Veri ve Analitik Eğitimleri

Traditional Data Architectures: Data Warehousing and ETL Systems Eğitimi

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

OLTP/OLAP, EDW katmanları, ETL süreçleri ve yıldız/kar tanesi boyutsal modelleme ile geleneksel veri ambarı mimarisi eğitimi.

Detayları Gör →
Veri Mühendisliği ve AmbarıUsing Streamlit with Snowflake Eğitimi
Veri ve Analitik Eğitimleri

Using Streamlit with Snowflake Eğitimi

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

Streamlit in Snowflake ile Snowpark'tan veri çekip etkileşimli veri uygulaması geliştirme, cache, RBAC ve Snowflake içi dağıtım eğitimi.

Detayları Gör →
Veri Mühendisliği ve AmbarıUsing Tasks and Architecting Snowflake Data Pipelines Eğitimi
Veri ve Analitik Eğitimleri

Using Tasks and Architecting Snowflake Data Pipelines Eğitimi

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

Snowflake Task graph (DAG), finalizer, serverless orkestrasyon, hata yönetimi ve gözlemlenebilirlikle ölçeklenebilir pipeline mimarisi eğitimi.

Detayları Gör →
Veri Mühendisliği ve AmbarıVeri Ambarı (DWH) Mimari ve Modelleme Teknikleri Eğitimi
Veri ve Analitik Eğitimleri

Veri Ambarı (DWH) Mimari ve Modelleme Teknikleri Eğitimi

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

Kimball, Inmon, Data Vault 2.0 ve lakehouse ile boyutsal modelleme, SCD, fact türleri ve modern DWH mimari tasarımı eğitimi.

Detayları Gör →
Veri Mühendisliği ve AmbarıVeri Entegrasyonu için Make Eğitimi
Veri ve Analitik Eğitimleri

Veri Entegrasyonu için Make Eğitimi

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

Make (Integromat) ile senaryo, modül, router, iterator/aggregator, webhook ve HTTP modülüyle kodsuz veri entegrasyonu eğitimi.

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