real‑time data pipeline