The Fare Aggregator

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

Domain

Pipeline Design

Difficulty

medium

Seniority

L5

Problem

We aggregate airfares from dozens of airline APIs and global distribution systems, checking 80 billion prices per day to power flight search for 100 million users, but every GDS and direct airline API has a completely different schema (one calls it departure_time, another dep_utc, another sends it as a Unix timestamp). Our prices go stale within seconds during booking surges, so the price shown when a user clicks book has to be the live price rather than a stale cache. Design a pipeline that keeps search fast and fresh across every source and, when a flight is delayed or cancelled, alerts the users already on the booking page for that route before they pay.

Summary

Airfares shift every minute. Catch the best ones.

Practice This Problem

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