Vad är Datapipeline
Automatiserat databehandlingsflöde
Vad är Data Pipeline
Data Pipeline är en automatiserad sekvens av steg för att extrahera, bearbeta och leverera data från källor till målsystem.
Pipeline-typer
| Typ | Beskrivning | Exempel | |-----|-------------|---------| | Batch | Schemalagd batchbearbetning | Dagliga rapporter | | Streaming | Realtidsbearbetning | IoT-data, loggar | | Hybrid | Batch och streaming-kombination | Lambda/Kappa-arkitektur |
Pipeline-komponenter
- Source — datakällor (DB, API, filer)
- Ingestion — laddning i systemet
- Processing — transformationer och berikande
- Storage — lagring (DWH, Data Lake)
- Serving — leverans till konsumenter
Populära verktyg
| Kategori | Verktyg | |----------|---------| | Orkestrering | Apache Airflow, Prefect, Dagster | | Streaming | Apache Kafka, Spark Streaming | | Batch | Apache Spark, dbt | | Moln | AWS Glue, Azure Data Factory, GCP Dataflow |
Bästa praxis
- Idempotenta operationer
- Retry med exponentiell backoff
- Data lineage och övervakning
- Schemavalidering vid intag
- Partitionering för prestanda
Felhanteringsmönster
- Dead Letter Queue för misslyckade poster
- Circuit breaker för upstream-system
- Checkpointing för återställning