Comment démarrer un ETL personnalisé en Scala
Scala est un excellent choix pour l'ETL lorsque vous recherchez un développement natif Spark, une forte sécurité de typage et une implémentation capable d'évoluer d'un simple batch vers une plateforme de données plus large.
Quand Scala est pertinent pour l'ETL
Scala devient particulièrement utile lorsque la logique ETL est assez complexe pour que les abstractions solides, les bibliothèques réutilisables et les vérifications à la compilation réduisent réellement la maintenance. Le couple Scala + Apache Spark est particulièrement naturel.
Choisissez Scala si vous voulez que votre pipeline se comporte comme un logiciel, et non comme une collection de scripts.
What Spark, Hadoop, and HDFS Actually Are
These technologies are related, but they are not the same layer of the stack.
Spark
Spark is a distributed compute engine. It parallelizes reads, joins, aggregations, and writes across many workers. For ETL, think of Spark as the execution layer rather than the long-term storage layer.
Hadoop
Hadoop is a broader ecosystem that historically bundled distributed storage, cluster resource management, and batch processing. Modern teams often borrow concepts from Hadoop without running a classic Hadoop cluster end to end.
HDFS
HDFS is Hadoop Distributed File System. It stores files across many machines and was the standard storage layer for self-hosted big data clusters before object storage became the default in many cloud environments.
Catalog and table metadata
As soon as multiple jobs and analysts rely on the same curated datasets, you also need a catalog or metastore. It keeps schemas, partitions, and table definitions consistent across your ETL and query tools.
Should You Use HDFS?
Usually not as a default. HDFS still has a place, but many modern ETL stacks use object storage instead.
- - Choose HDFS mainly when you operate your own cluster, want data locality, and already accept the operational cost of managing distributed storage nodes.
- - Prefer S3, ADLS, or GCS when your compute can be ephemeral, your storage should scale independently, or you want simpler disaster recovery and cross-service integration.
- - Do not adopt Hadoop just because you use Spark. Spark can run on Kubernetes, YARN, Databricks, EMR, Synapse, or other managed runtimes without HDFS being the center of the design.
Commencer avec la bonne structure
Couches de base
- - Configuration : chemins, secrets, environnements, tables cibles
- - Readers : JDBC, fichiers, files de messages ou adaptateurs API
- - Transformations : normalisation, enrichissement, déduplication, règles métier
- - Validations : contrôles de schéma, de volumes et de logique métier
- - Writers : sorties vers lake, warehouse ou services cibles
Objectifs de conception initiaux
- - Chargements idempotents pour éviter les doublons
- - Logs structurés avec contexte de batch ou de partition
- - Frontières d'échec claires entre extract, transform et load
- - Transformations petites et testables plutôt qu'un gros job monolithique
- - Un mode de déploiement aligné dès le départ avec la runtime
Do You Have to Use Spark?
No. Spark is powerful, but it is not the mandatory starting point for every ETL pipeline.
Use Spark when
You need distributed joins, large historical scans, partitioned batch outputs, or multi-hundred-gigabyte to multi-terabyte processing windows that no longer fit comfortably on one machine.
Skip Spark when
Your ETL is mostly SQL against Postgres, the data volume is still modest, one server can finish the workload inside the SLA, and operational simplicity matters more than horizontal scale.
Common alternatives
Start with Postgres SQL, dbt, Airflow plus Python, DuckDB, or Polars when the pipeline is small or medium. Move to Spark when the workload proves it needs a distributed compute engine.
Squelette du projet
Un projet ETL minimal basé sur Spark peut commencer avec build.sbt, une seule classe main et une structure src/main/scala classique. Adaptez les versions d'exemple à votre cluster cible.
name := "custom-etl"
version := "0.1.0"
scalaVersion := "2.13.17"
val sparkVersion = "4.1.2" // Replace to match your target cluster
libraryDependencies ++= Seq(
"org.apache.spark" %% "spark-sql" % sparkVersion % "provided",
"com.typesafe" % "config" % "1.4.3",
"org.scalatest" %% "scalatest" % "3.2.19" % Test
)Squelette minimal de job
Même un petit job de départ devrait accepter les chemins d'entrée et de sortie en arguments, créer une SparkSession, appliquer une chaîne de transformation simple et écrire dans un format déterministe comme Parquet.
package dev.ryware.etl
import org.apache.spark.sql.SparkSession
import org.apache.spark.sql.functions.{col, to_timestamp}
object CustomEtlJob {
def main(args: Array[String]): Unit = {
val inputPath = args(0)
val outputPath = args(1)
val spark = SparkSession.builder()
.appName("custom-etl-job")
.getOrCreate()
val curated = spark.read
.option("header", "true")
.csv(inputPath)
.filter(col("transaction_id").isNotNull)
.withColumn("amount", col("amount").cast("decimal(18,2)"))
.withColumn("updated_at", to_timestamp(col("updated_at")))
curated.write
.mode("overwrite")
.parquet(outputPath)
spark.stop()
}
}When Postgres Is Enough and When to Move to a Warehouse
Raw database size matters, but query concurrency, data shape, retention, and the cost of long analytical scans matter more.
| Workload stage | When Postgres is still reasonable | When you should plan the move | Typical target |
|---|---|---|---|
| Early analytics | Up to roughly 50-100 GB of curated analytical data, a few internal dashboards, light concurrency, and daily batch updates. | Stay put unless queries already compete with transactional traffic or refresh windows are missing the SLA. | Postgres plus SQL, dbt, and simple orchestration. |
| Growing reporting stack | Roughly 100-300 GB, moderate joins, fewer than 10-20 active analysts, and mostly structured tables. | Plan a warehouse when refresh jobs grow brittle, vacuum and index tuning turns into constant work, or semi-structured data starts piling up. | Postgres can still work, but start evaluating BigQuery, Snowflake, Redshift, Synapse, or a lakehouse pattern. |
| Heavy analytics | Possible only with careful tuning, but the tradeoff gets worse once scans span hundreds of gigabytes, concurrency climbs, and retention grows fast. | Move when BI workloads, historical backfills, and ML feature extraction all want the same data at the same time. | Columnar warehouse or lakehouse with separated storage and compute. |
| Platform scale | Rarely the right long-term shape once you are in multi-terabyte territory, ingesting many domains, or supporting self-service analytics. | At this point the question is usually not whether to move, but which warehouse, lakehouse, governance model, and cost controls fit the business. | Warehouse or lakehouse platform with catalog, partitioning, and workload isolation. |
What If the Source Files Are XML and You Need XPath?
Spark can process XML, but the best approach depends on how irregular the documents are and how much XPath logic you need.
Spark can read XML
On open-source Spark, teams commonly add the spark-xml package and define an explicit row tag and schema. That works well when the XML documents are repetitive enough to map into tabular records.
XPath is possible, but expensive
XPath-style extraction is reasonable for a few known fields, but deeply nested or dynamic XPath rules can become CPU-heavy and awkward to test at scale. Flatten the documents as early as you can.
Sometimes pre-processing is better
If the XML is highly irregular, namespace-heavy, or validated against complex XSD rules, it can be cleaner to parse it first with a dedicated XML library in Scala or Java and then land normalized JSON or Parquet for downstream Spark work.
Operational advice
Keep the raw XML, version the mapping rules, capture malformed files separately, and build test fixtures from real samples. Special formats fail at the edges, so sample coverage matters more than happy-path demos.
Ce qu'il faut ajouter ensuite en production
Validation et qualité
- - Ajouter des assertions de schéma avant d'écrire les sorties curées
- - Conserver les volumes de lignes et taux de nullité à chaque run
- - Rejeter ou mettre en quarantaine les partitions invalides au lieu de tout coercer silencieusement
Tests et packaging
- - Tests unitaires de transformation avec de petits DataFrames en mémoire
- - Tests d'intégration pour les connecteurs source et cible
- - Packaging avec sbt et exécution via spark-submit ou le launcher du cluster
Un premier jalon raisonnable
Le premier objectif ne doit pas être de construire toute la plateforme data. Il doit être de lire une source de façon fiable, appliquer un chemin de transformation propre, écrire une sortie curée et rendre le run observable.
Jalon 1
Un seul job batch avec des sorties déterministes.
Jalon 2
Des environnements pilotés par configuration et des règles de validation.
Jalon 3
Orchestration, alertes, lineage et bases de qualité.
Guides ETL associés
Poursuivez avec le choix de plateforme, la détection d'anomalies ou les options spécifiques à AWS Glue.
AWS vs Azure vs GCP vs On-Premises for ETL
Compare managed ETL stacks, hybrid patterns, and the tools teams commonly use on each platform.
Anomaly Detection in ETL Pipelines
See which data and operational signals matter, how to baseline them, and how to react before bad data spreads.
AWS Glue for Anomaly Detection, Data Quality, and Debugging
Use Glue Data Quality, historical row-count checks, and run-time logging to catch ETL issues quickly.