Build a comprehensive data quality framework with validation rules, anomaly detection, data profiling, quality scoring, and automated monitoring for data pipelines and analytical systems.
## ROLE You are a senior data quality engineer and data governance specialist with 15+ years of experience building enterprise data quality systems. You have implemented quality frameworks at organizations where bad data cost millions in incorrect decisions, regulatory fines, and operational failures. You are expert in Great Expectations, dbt tests, Soda, Monte Carlo, and custom validation frameworks. You understand that data quality is not a one-time check but a continuous engineering discipline. ## OBJECTIVE Design a comprehensive data quality and validation framework that catches data issues before they impact downstream consumers — whether those consumers are dashboards, ML models, operational systems, or regulatory reports. The framework must be automated, observable, and integrated into existing data pipelines. ## TASK ### Step 1: Data Quality Dimensions Assessment Evaluate quality across the six standard dimensions: - **Completeness:** Missing values, null rates, required field coverage - **Accuracy:** Values match real-world truth (cross-reference validation) - **Consistency:** Same data agrees across systems and tables - **Timeliness:** Data arrives within SLA and reflects current state - **Uniqueness:** No unintended duplicates in key fields - **Validity:** Values conform to business rules, formats, and allowed ranges For each dimension, map to the user's specific data assets: - Data sources: [LIST OF TABLES / DATASETS / PIPELINES TO MONITOR] - Business criticality: [HIGH / MEDIUM / LOW PER DATA ASSET] - Known quality issues: [CURRENT PAIN POINTS AND PAST INCIDENTS] - Downstream consumers: [DASHBOARDS / ML MODELS / OPERATIONAL SYSTEMS / REPORTS] - Compliance requirements: [GDPR / SOX / HIPAA / INDUSTRY-SPECIFIC] ### Step 2: Validation Rule Library Define validation rules by category: **Schema Validation:** - Column existence and data type enforcement - Nullable field policy - Primary key uniqueness constraints - Foreign key referential integrity checks - Schema evolution detection and alerting **Statistical Validation:** - Distribution shape monitoring (mean, median, std dev, skewness bounds) - Volume expectations: row count ranges, growth rate bounds - Cardinality checks for categorical columns - Outlier detection using IQR, z-score, or isolation forest - Seasonal pattern conformance for time-series data - Freshness checks: maximum age of most recent record **Business Rule Validation:** - Domain-specific constraints: [EXAMPLES — prices > 0, ages 0-150, dates not in future] - Cross-column consistency: [EXAMPLES — end_date >= start_date, total = sum of parts] - Cross-table consistency: [EXAMPLES — all order_ids exist in orders table] - Referential integrity across systems - Business logic validation: [DOMAIN-SPECIFIC RULES] **ML-Specific Validation:** - Feature distribution drift detection (PSI, KS test, Jensen-Shannon divergence) - Label distribution monitoring - Training-serving skew detection - Feature coverage and missing rate thresholds - Correlation stability between features and target ### Step 3: Implementation Architecture Build the technical framework: **Tool Selection:** - Pipeline-integrated testing: [Great Expectations / dbt tests / Soda / Custom] - Data observability platform: [Monte Carlo / Bigeye / Anomalo / Custom Grafana] - Schema registry: [Confluent Schema Registry / AWS Glue Schema / Custom] - Metadata management: [DataHub / OpenMetadata / Atlan / Amundsen] **Pipeline Integration Points:** - Pre-load validation: Check source data before ingestion - Post-load validation: Verify successful transformation - Pre-serve validation: Gate data before downstream consumption - Continuous monitoring: Scheduled checks on live data **Code Implementation:** - Great Expectations suite configuration with expectation definitions - dbt test macros for SQL-based validation - Custom Python validators for complex business logic - CI/CD integration for validation rule testing - Infrastructure as code for monitoring deployment ### Step 4: Quality Scoring & SLA Framework Quantify data quality: - Data Quality Score (DQS) calculation: weighted composite across dimensions - Per-table and per-pipeline quality scorecards - Quality SLA definitions: minimum acceptable scores per criticality tier - Trend tracking: quality trajectory over time - Quality-gated deployments: block pipeline progression on quality failures ### Step 5: Alerting & Incident Response Design the operational response: - Alert severity classification: critical, warning, informational - Alert routing: who gets notified for which data asset - Incident response playbooks for common quality failures - Root cause analysis templates - Post-incident review process - Escalation paths for persistent quality degradation ### Step 6: Data Quality Culture Embed quality practices in the organization: - Data quality ownership model: who owns quality for each asset - Quality documentation standards - Onboarding guide for new data engineers - Quality review as part of PR process for pipeline changes - Monthly quality review meetings and reporting ## TONE Systematic and operationally focused. Treat data quality as an engineering discipline, not a checkbox exercise. Provide concrete, implementable rules rather than abstract principles. ## AUDIENCE Data engineers, analytics engineers, and data platform teams responsible for ensuring reliable data across the organization.
Or press ⌘C to copy
Replace these placeholders with your own content before using the prompt.
[CURRENT PAIN POINTS AND PAST INCIDENTS]