Core idea
Infra already has telemetry: CPU, memory, storage, network, latency, availability, capacity, cost, incidents, predictability.
Data needs the same thing.
Not just:
“Is the data quality good?”
But:
“Where did the data come from, how did it move, how was it transformed, who used it, what broke, what changed, what is trusted, what is risky, and what business process depends on it?”
This becomes a Data Telemetry Observatory.
1. What data telemetry should cover
End-to-end flow
Source
↓
Ingestion
↓
Landing / Raw / T1
↓
Standardization / Integration / T2
↓
Serving / Analytics / T3
↓
Distribution
↓
Consumption
↓
Business outcome / report / model / decision
For every hop, capture telemetry.
2. Telemetry categories to capture
1. Data movement telemetry
This answers:
“How is data physically moving?”
Track:
Area
What to capture
Source system
Which app/system produced the data
Feed/API/file/topic
Mode of movement
Schedule
Real-time, near-real-time, batch, ad hoc
Volume
Rows, files, messages, size
Latency
Source-to-landing, landing-to-serving
SLA
Expected vs actual arrival
Failed loads
Count, reason, retry status
Reprocessing
How often data is replayed
Duplicate movement
Same data moving through multiple routes
Manual movement
Excel, email, SFTP, manual uploads
Good cop: This creates operational control over data like infra monitoring.
Bad cop: If we only capture pipeline logs, we get technical telemetry, not business data telemetry.
2. Data freshness telemetry
This answers:
“Is the data current enough for the business process?”
Track:
Area
What to capture
Last source update
When source changed
Last successful ingestion
When platform received it
Last transformation
When it was processed
Last publish time
When consumers received it
Freshness gap
Difference between source and consumer
SLA breach
Late beyond agreed threshold
Staleness risk
Report/model using old data
Business impact
Which process/report is affected
Example:
Customer Risk Rating source updated at 9:00 AM
T1 received at 9:05 AM
T2 processed at 10:30 AM
T3 report refreshed at 4:00 PM
Telemetry says:
Freshness gap = 7 hours
Business impact = AML dashboard using stale rating
3. Data quality telemetry
This is needed, but it is only one part.
Track:
Dimension
Example
Completeness
Customer ID missing
Validity
Invalid product code
Accuracy
Wrong customer risk rating
Consistency
Different rating across systems
Timeliness
Late arrival
Uniqueness
Duplicate customer/account
Referential integrity
Account has no valid customer
Reconciliation
Source count vs target count mismatch