Skip to main content

Peliqan

data-pipeline-architecture-diagram-feature-image

Data pipeline architecture diagram: batch and streaming

InfoGraphics

Related Diagrams

Peliqan data platform

All-in-one Data Platform

Built-in data warehouse, superior data activation capabilities, and AI-powered development assistance.

data-pipeline-architecture-diagram

A data pipeline moves data from where it is produced to where it is analysed. There are two ways it can arrive – in batches, or as it happens – and the diagram below shows both landing in the same modelled layer, with the obligations that apply either way.

The two paths

  1. 1Batch runs on a schedule. Extract on an interval, land the raw records, then transform them into models. Simpler to reason about and to re-run, and correct for the large majority of reporting. Most teams should start here and stay here longer than they expect to.
  2. 2Streaming reacts as events occur. Capture changes continuously, move them through a log, process them on the way. Worth its extra operational cost when a decision genuinely cannot wait for the next batch – fraud checks, stock levels, live personalisation.

The obligations that apply either way

  • Schedule or trigger: something has to decide when work runs and what it depends on.
  • Schema drift: the source will add, rename and drop fields without warning you.
  • Retries: transient failures are normal, so the pipeline must resume rather than start again from nothing.
  • Idempotent writes: running the same load twice must not create the data twice – this is the one that quietly corrupts numbers.
  • Freshness alerts: a pipeline that silently stops is worse than one that fails loudly, because nobody stops trusting the dashboard.

Why replayability is the design constraint

Every serious pipeline decision follows from one question: can you run it again? Keeping raw data as it arrived means a modelling mistake is fixed by rebuilding, not by re-extracting from a source that may no longer hold the history. This is the practical reason ELT overtook ETL for most workloads.

How this relates to ETL and ELT

Batch and streaming describe when data moves. ETL and ELT describe where it is transformed. They are independent choices, and the transform position is drawn out on our ETL vs ELT diagram; the full stage-by-stage view is on the ETL architecture diagram.

What this looks like in Peliqan

Peliqan runs managed incremental pipelines from 300+ sources into your warehouse, with scheduling, retries and schema handling included, so the obligations above are the platform’s job rather than a set of scripts somebody has to maintain.

Use this diagram wherever you like

The diagram is free to use, including commercially, as long as there is a visible link back to this page. Download the PNG for slides and documents, or the SVG if you want to edit the labels. No email required. You can browse the rest of the set in the Peliqan diagram library.

Ready to build this on your own data? Get started with Peliqan.

FAQs

A data pipeline is the set of steps that moves data from where it is produced to where it is analysed: extraction from a source, landing the raw records, transformation into models, and delivery to BI tools, queries or agents.

No. ETL is one kind of data pipeline – extract, transform, load. Data pipeline is the broader term, and also covers ELT, streaming pipelines, change data capture and reverse ETL.

Decide where the transform runs, keep the raw data as it arrived so the pipeline can be re-run, then handle the four things that actually break in production: scheduling and dependencies, schema drift, retries with idempotent writes, and freshness alerts.

In ETL the pipeline is the sequence extract, transform, load, with the transform running before the warehouse. ELT runs the same stages in a different order, transforming inside the warehouse on raw data that stays replayable.

Get instant access to all your company data

Connect 300+ sources, serve any BI tool, and give every AI agent one governed endpoint to read, and write back where the app supports it.