2026-05-11_s3_mdp_run_monitor.sql 1.1 KB

12345678910111213141516171819202122232425
  1. -- S3 MDP 运行监控日志
  2. -- 记录整轮 source -> mdp_stg_* -> mdp_std_* -> dwd_* 同步转换结果。
  3. CREATE TABLE IF NOT EXISTS mdp_transform_run_log (
  4. id BIGINT AUTO_INCREMENT PRIMARY KEY,
  5. tenant_id BIGINT NOT NULL DEFAULT 0,
  6. job_code VARCHAR(100) NOT NULL,
  7. job_name VARCHAR(200) NOT NULL,
  8. trigger_type VARCHAR(30) NOT NULL DEFAULT 'AUTO',
  9. batch_id VARCHAR(100) NOT NULL,
  10. status VARCHAR(30) NOT NULL DEFAULT 'RUNNING',
  11. start_time DATETIME NOT NULL,
  12. end_time DATETIME NULL,
  13. duration_ms INT NULL,
  14. stage_rows INT NOT NULL DEFAULT 0,
  15. standard_rows INT NOT NULL DEFAULT 0,
  16. dwd_rows INT NOT NULL DEFAULT 0,
  17. error_message TEXT NULL,
  18. summary_json JSON NULL,
  19. create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
  20. update_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  21. UNIQUE KEY uk_batch (batch_id),
  22. KEY idx_job_start (job_code, start_time),
  23. KEY idx_status_start (status, start_time)
  24. ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci COMMENT='MDP整轮同步转换运行日志';