技能创建器
skill-creator
创建、改进和评估自定义技能,把专业流程转化为可重复使用的 AI 能力。
monitor-model-drift【数据与研究】Implement comprehensive model drift monitoring using Evidently AI, statistical tests (PSI, KS), and custom metrics to detect data drift and concept drift in production ML systems. Set up automated alerting and reporting workflows to catch degradation before it impacts business metrics. Use when production models show unexplained performance degradati…
独立 GitHub 快照 · 自动分类 · 以原作者文档为准
See Extended Examples for complete configuration files + templates.
Detect + alert on data drift + concept drift in production ML models using statistical tests + automated monitoring.
Set up monitoring framework with appropriate dependencies.
# Create virtual environment
python -m venv venv
source venv/bin/activate # On Windows: venv\Scripts\activate
# Install Evidently and dependencies
pip install evidently pandas scikit-learn prometheus-client
# Create monitoring directory structure
mkdir -p monitoring/{reports,config,alerts}
Create configuration file:
# monitoring/config/drift_config.py
from evidently.metric_preset import DataDriftPreset, TargetDriftPreset
from evidently.metrics import (
DatasetDriftMetric,
DatasetMissingValuesMetric,
ColumnDriftMetric,
)
# ... (see EXAMPLES.md for complete implementation)
Got: Configuration file created with thresholds matching model's tolerance.
If fail: Start with conservative thresholds (PSI > 0.2, KS p-value < 0.01) + tune based on false positive rate.
Create drift detection pipeline with multiple statistical tests.
# monitoring/drift_detector.py
import pandas as pd
import numpy as np
from scipy.stats import ks_2samp, chi2_contingency
from evidently.report import Report
from evidently.metric_preset import DataDriftPreset
from evidently.metrics import ColumnDriftMetric, DatasetDriftMetric
from datetime import datetime, timedelta
# ... (see EXAMPLES.md for complete implementation)
Got: Drift detection runs successfully, produces JSON report with per-feature statistics, identifies drifted features.
If fail: Check for missing values (impute or drop), ensure reference + current data have same columns, verify data types match between datasets.
Create visual HTML reports for human review + debugging.
# monitoring/generate_reports.py
from evidently.report import Report
from evidently.metric_preset import DataDriftPreset, TargetDriftPreset
from evidently.metrics import (
ColumnDriftMetric,
DatasetDriftMetric,
DatasetMissingValuesMetric,
)
# ... (see EXAMPLES.md for complete implementation)
Got: HTML reports generated in monitoring/reports/, viewable in browser with interactive charts showing distribution comparisons.
If fail: Verify write permissions to output directory, check Evidently version is >= 0.4.0, ensure data frames have sufficient rows (>100 recommended).
Monitor prediction performance to detect concept drift (relationship between features + target changes).
# monitoring/concept_drift.py
import pandas as pd
import numpy as np
from sklearn.metrics import roc_auc_score, mean_squared_error, accuracy_score
from typing import Dict, List
import json
# ... (see EXAMPLES.md for complete implementation)
Got: Performance monitoring detects when model accuracy/AUC drops below threshold, signaling potential concept drift.
If fail: Ensure ground truth labels are available (may require delayed validation batch job), verify prediction scores properly calibrated (0-1 range for classification), check for label leakage in features.
Integrate drift detection with alerting systems (Slack, PagerDuty, email).
# monitoring/alerting.py
import requests
import json
from typing import Dict, List
import logging
logging.basicConfig(level=logging.INFO)
logger = logging.getLogger(__name__)
# ... (see EXAMPLES.md for complete implementation)
Got: Alerts sent to Slack/PagerDuty when drift detected, with severity based on drift share + critical feature involvement.
If fail: Test webhook URLs with curl first, verify PagerDuty integration key has correct permissions, check firewall rules for outbound HTTPS, implement retry logic for transient network failures.
Automate drift detection to run on schedule (daily or weekly).
# monitoring/scheduler.py
import schedule
import time
import logging
from datetime import datetime, timedelta
import pandas as pd
logging.basicConfig(
# ... (see EXAMPLES.md for complete implementation)
Alternatively, use cron:
# Add to crontab (crontab -e)
# Run daily at 2 AM
0 2 * * * cd /path/to/monitoring && /path/to/venv/bin/python scheduler.py >> logs/cron.log 2>&1
Or use Airflow DAG:
# airflow/dags/drift_monitoring_dag.py
from airflow import DAG
from airflow.operators.python import PythonOperator
from datetime import datetime, timedelta
default_args = {
'owner': 'ml-team',
'depends_on_past': False,
# ... (see EXAMPLES.md for complete implementation)
Got: Monitoring runs automatically on schedule, generates reports, sends alerts only when drift exceeds thresholds, logs all activity.
If fail: Check scheduler process running (ps aux | grep scheduler), verify cron service active, ensure data sources accessible, review logs for exceptions, set up dead man's switch alert if job doesn't run.
detect-anomalies-aiops — Time series anomaly detection for operational metricsdeploy-ml-model-serving — Model deployment patterns + versioningsetup-prometheus-monitoring — Infrastructure metrics collectionreview-data-analysis — Statistical analysis validation + peer review