The Fare Aggregator

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

Domain

Pipeline Design

Difficulty

medium

Seniority

L5

Problem

We aggregate airfares from dozens of airline APIs and global distribution systems, and we check 80 billion prices per day to power flight search for 100 million users. The problem is that every GDS and direct airline API has a completely different schema - one calls it departure_time, another calls it dep_utc, another sends it as a Unix timestamp. Our prices also go stale within seconds during booking surges. Design a pipeline that keeps prices fresh and routes users away from sold-out flights before they see a failed booking.

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 grades it automatically.