Mikä on Tietoputki
Automatisoitu tiedonkäsittelyvirta
Mikä on Data Pipeline
Data Pipeline on automatisoitu vaiheiden sarja tietojen poimimiseen, käsittelyyn ja toimittamiseen lähteistä kohdejärjestelmiin.
Putken tyypit
| Tyyppi | Kuvaus | Esimerkit | |--------|--------|-----------| | Batch | Ajoitettu eräkäsittely | Päiväraportit | | Streaming | Reaaliaikainen käsittely | IoT-tiedot, lokit | | Hybridi | Batch- ja streaming-yhdistelmä | Lambda/Kappa-arkkitehtuuri |
Putken komponentit
- Source — tietolähteet (DB, API, tiedostot)
- Ingestion — lataus järjestelmään
- Processing — muunnokset ja rikastus
- Storage — tallennus (DWH, Data Lake)
- Serving — toimitus kuluttajille
Suositut työkalut
| Kategoria | Työkalut | |-----------|----------| | Orkestrointi | Apache Airflow, Prefect, Dagster | | Streaming | Apache Kafka, Spark Streaming | | Batch | Apache Spark, dbt | | Pilvi | AWS Glue, Azure Data Factory, GCP Dataflow |
Parhaat käytännöt
- Idempotentit operaatiot
- Retry eksponentiaalisella backoffilla
- Data lineage ja seuranta
- Skeeman validointi syötteessä
- Osiointi suorituskyvyn parantamiseksi
Virheenkäsittelymallit
- Dead Letter Queue epäonnistuneille tietueille
- Circuit breaker upstream-järjestelmille
- Checkpointing palautukseen