Data Quality (DQ) is a first-class concern in this platform.
- Completeness – required fields present.
- Validity – values within expected ranges and code sets.
- Uniqueness – no duplicate
transaction_idfor a given source. - Timeliness – events arrive within expected time windows.
- Consistency – cross-table relationships hold.
transaction_idmust be unique per source and day.amountmust be ≥ 0 and ≤ configured upper bound per product.event_timestampmust be within ±3 days of load date (configurable).patient_idmust exist in patient reference tables.- Mandatory compliance flags must be derived for each row.
- Streaming DQ in Synapse Spark Streaming:
- Invalid records are written to DLQ tables with error codes.
- Batch DQ in Synapse / Snowflake:
- Rule bundles executed as SQL; results written to DQ summary tables.
- DQ metrics exported to Log Analytics and surfaced in dashboards.
- DQ Pass Rate (critical rules) – target ≥ 97%.
- DLQ Rate – target < 0.5% of incoming records.
- Schema compatibility – 100% of events must conform to contracts or be rejected explicitly.
Breaches feed alerts to on-call engineers and data stewards.