A platform team is rebuilding ingestion from a Postgres operational database to a Snowflake warehous

A medium Pipeline Design interview practice problem on DataDriven. Write and execute real pipeline design code with instant grading.

Domain

Pipeline Design

Difficulty

medium

Problem

A platform team is rebuilding ingestion from a Postgres operational database to a Snowflake warehouse. Three tables matter. customers (2M rows, slow updates) needs hourly. orders (500M rows, +10M/day, deletes critical) needs five-minute. legacy_events (hosted Postgres, no WAL access) needs daily. Compose the ingestion: pick the load and CDC strategy per table with the trade-off named, wire bookmark stores or replication slots as appropriate, ensure each sink dedupes on a stable key, and route everything into Snowflake.

Practice This Problem

Solve this Pipeline Design problem with real code execution. DataDriven runs your solution and grades it automatically.