← Stillwater Technology Group

Data collected and checked every day

Summary of one scheduled run of a pipeline that gathers daily price history for 13 items at three time intervals.

Example output. The requests, websites and records are invented.

39 of 39Data series updated
13,844Rows loaded
0Duplicate records
0Failed sources

Steps in every run

StepWhat happens
FetchEach source is requested with automatic retries if it fails.
StandardiseTimestamps are converted to one time zone and one format.
ValidateImpossible values and duplicate records are detected before anything is saved.
CalculateDerived figures such as moving averages are added to every series.
LoadRows are written to the database so that re-running never creates duplicates.
ReportA summary of what was loaded and what failed is produced for every run.

Why it matters