Elle a rejoint l'équipe data engineering d'une entreprise de services informatiques majeure pour concevoir et optimiser des pipelines de données hautement performants et rentables traitant des volumes importants de données structurées et non structurées.
- A conçu et automatisé un pipeline ETL horaire en Databricks traitant des fichiers CSV envoyés via SFTP vers une localisation S3 avec un script maître qui détecte dynamiquement les nouveaux fichiers, déclenche les jobs ETL pertinents, applique les transformations (casting, aliasing, explosion de tableaux, CASE WHEN) et charge les données dans les tables et vues staging en assurant un accès sécurisé via le partage au niveau des vues contrôlées par Databricks pour les équipes d'analyse.
- A développé et maintenu des pipelines ETL basés sur les API REST en Databricks pour ingérer quotidiennement des données CRM, de réseaux sociaux et de plateformes marketing, en gérant l'authentification API, la récupération incrémentale de données avec logique de buffer et l'élimination des doublons, en stockant les réponses API sous forme de fichiers JSON/CSV compressés en S3, en appliquant les transformations et en chargeant les données dans les tables staging avec vues construites pour l'équipe d'analyse.
- A construit et optimisé des pipelines ETL basés sur JDBC en Databricks pour ingérer les données des bases Oracle et MySQL dans les tables staging en utilisant les charges complètes et incrémentales, améliorant les performances pour les grandes tables (7M+ enregistrements) en ajustant la taille de récupération et réduisant le temps de traitement d'environ 5 heures à 15 minutes (réduction de ~95% du temps) générant une économie de coûts estimée à 80%.
- A conçu un pipeline de données temps réel rentable en migrant depuis les streams coûteux vers une approche de batch basée sur S3, permettant trois mises à jour horaires via Databricks, implémentant la logique d'insertion, mise à jour et suppression de records dans les tables Delta en utilisant MERGE, réduisant les coûts de streaming de ~70% tout en maintenant la disponibilité des données opportune pour l'analyse.
Environnement technique
DatabricksPySparkPythonSQLApache SparkSpark StreamingAWS (S3LambdaGlueAthena)AWS Transfer FamilyJDBCREST APIOracleMySQLDelta tablesRedshiftSnowflake.