Ingestion Python Résiliente
Traitez les pannes d'APIs, les limites de débit et les reprises sans perdre une seule transaction.
Devenez l'architecte data de votre organisation : développez des pipelines d'ingestion Python robustes, concevez des entrepôts PostgreSQL en schéma en étoile, transformez avec dbt Core et orchestrez avec Apache Airflow et Docker.
De l'extraction d'API avec reprises à la modélisation en étoile testée par dbt et orchestrée par Airflow.
with DAG(
dag_id="koryxa_sales_platform",
schedule_interval="0 2 * * *",
start_date=datetime(2026, 1, 1),
catchup=False,
max_active_runs=1
) as dag:
extract_sales = PythonOperator(
task_id="extract_sales_api",
python_callable=fetch_incremental_sales
)
run_dbt_models = BashOperator(
task_id="dbt_run_marts",
bash_command="dbt run --models marts"
)
test_contracts = BashOperator(
task_id="dbt_test_quality",
bash_command="dbt test"
)
extract_sales >> run_dbt_models >> test_contractsPacks d'Exercices & Fichiers Sources
customers.csv & sales.csv
Tables sources de ventes réelles
api_sales_pages.json
Flux API paginé pour les tests d'ingestion
12 Modules Starter
Code de départ avec tests unitaires
12 Modules Solutions
Implémentations de référence complètes
docker-compose.yml
Stack Airflow + Postgres + dbt prête
Stack 100% Reproductible
Lancez l'ensemble de la plateforme en une seule commande `docker compose up`.
Les entreprises ont accumulé des données dispersées, cassées et non fiabilisées. Le rôle du Data Engineer est de créer des autoroutes de données automatisées, vérifiées et disponibles en temps voulu.
Traitez les pannes d'APIs, les limites de débit et les reprises sans perdre une seule transaction.
Finis les scripts SQL géants et illisibles : découpez vos transformations en modèles testés et versionnés.
Automatisez l'exécution quotidienne avec des graphes de dépendances (DAGs) et des alertes automatiques.
Conteneurisez toute la plateforme pour une portabilité totale entre votre poste local et les serveurs de production.
Une pédagogie axée sur la construction : chaque module fournit du code starter et une solution complète commentée.
Rôle du Data Engineer, architectures modernes (Modern Data Stack), Data Lake vs Warehouse et cycle de vie de la donnée.
Consommation d'APIs REST avec retry exponentiel, gestion des formats JSON imbriqués, conversion Parquet et stockage brut.
Schémas staging/production, typage strict, contraintes CHECK, clés primaires/étrangères et commandes \copy volumétriques.
Spécification de contrats d'interface, validation de schéma Pydantic, détection des cassures (schema drift) et alertes.
Techniques de watermark, colonnes modified_at, rechargement idempotent, déduplication et gestion des purges historiques.
Tests d'unicité, non-nullité, intégrité référentielle, seuils d'anomalies volumétriques et blocage automatique du pipeline.
Modélisation dimensionnelle de Kimball : tables de faits, dimensions lentes (SCD Type 1 & 2) et clés de substitution.
Structure d'un projet dbt, modèles staging et marts, tests dbt (schema tests & data tests), macros Jinja et documentation générée.
Conception de DAGs, opérateurs Bash/Python/dbt, gestion des dépendances en cascade, retries automatiques et backfills.
Images Docker personnalisées, orchestration multi-conteneurs (Postgres, Airflow, MinIO, dbt) et volumes persistants.
Métriques de débit de pipeline, alerting Slack/Email sur échec de tâche, SLA de rafraîchissement et runbooks de reprise.
Pipelines GitHub Actions, tests automatisés en pré-production, sécurité des identifiants et livraison de la plateforme complète.
Vous concevez et déployez la plateforme de données centralisée d'une entreprise de commerce panafricaine connectant ventes en ligne et points de vente physiques.
Connectez l'API de facturation et les exports clients, validez les schémas avec Pydantic et stockez les données en zone raw.
Bâtissez le schéma en étoile PostgreSQL, écrivez les modèles staging et marts avec dbt, appliquez les tests d'intégrité référentielle.
Assemblez le DAG Airflow quotidien avec gestion des retries, configurez la stack sous Docker Compose et rédigez le runbook d'exploitation.
Une expertise pratique sur les outils les plus demandés du marché mondial.
Concevoir et déployer une architecture moderne de données (Modern Data Stack) de bout en bout
Ingérer des flux hétérogènes (APIs, CSV, JSON, Parquet) avec logique incrémentale et idempotence
Modéliser un Data Warehouse relationnel en schéma en étoile certifié pour le reporting
Structurer, tester et documenter des dizaines de modèles SQL avec dbt Core
Orchestrer des pipelines quotidiens avec Apache Airflow et gérer les pannes en autonomie
Conteneuriser l'ensemble de l'infrastructure avec Docker Compose et sécuriser les secrets
Une bonne maîtrise du langage SQL (jointures, agrégations) et des bases solides en Python sont nécessaires. Les cours SQL Data Analyst et Python Data Analyst sont d'excellentes préparations.
Non. Toute la stack est conçue pour fonctionner localement sur votre poste grâce à Docker Compose (PostgreSQL, Apache Airflow, dbt). Vous apprendrez les mêmes standards que dans le cloud sans aucun frais d'infrastructure.
Python, SQL, PostgreSQL 16, dbt Core, Apache Airflow, Docker, Docker Compose, Git et GitHub Actions pour la CI/CD.
Vous réalisez un projet fil rouge complet noté sur 60 points : pipeline d'ingestion API, projet dbt avec tests, DAG Airflow orchestré et stack Docker Compose fonctionnelle.
Maîtrisez la stack moderne de données et devenez un profil incontournable.
Accès complet & illimité
Paiement unique · Aucun abonnement caché
Paiement sécurisé instantané via Mobile Money ou Carte Bancaire