王绍宏
87fee6fe69
- 新增 start-lag-ms 配置，默认15分钟内全量保留 - 在15分钟至1小时之间按10级逐步降低保留率 - 延迟达到1小时后使用普通10%、非标20%的最低保留率 - 校验起始延迟必须小于最低保留率阈值 - 状态接口新增 start_lag_ms 配置展示 - 将采样策略版本升级为 v2 - 更新 Docker Compose 和 v4 升级配置说明 - 补充采样时间边界及非法配置单元测试
57 lines
2.0 KiB
SQL
57 lines
2.0 KiB
SQL
-- v4 Kafka 积压分级采样升级验证：只读。
|
|
|
|
-- 应返回 SYSLOG_BACKLOG_RETENTION_HOURLY 一行。
|
|
SELECT table_name
|
|
FROM user_tables
|
|
WHERE table_name = 'SYSLOG_BACKLOG_RETENTION_HOURLY';
|
|
|
|
-- 应返回 22 个字段。
|
|
SELECT column_id, column_name, data_type, nullable
|
|
FROM user_tab_columns
|
|
WHERE table_name = 'SYSLOG_BACKLOG_RETENTION_HOURLY'
|
|
ORDER BY column_id;
|
|
|
|
-- 两个约束都应为 ENABLED。
|
|
SELECT constraint_name, constraint_type, status
|
|
FROM user_constraints
|
|
WHERE constraint_name IN (
|
|
'PK_SYSLOG_BACKLOG_RET_HOURLY',
|
|
'CK_SYSLOG_BACKLOG_RET_BPS'
|
|
)
|
|
ORDER BY constraint_name;
|
|
|
|
-- 索引应为 VALID。
|
|
SELECT index_name, uniqueness, status
|
|
FROM user_indexes
|
|
WHERE index_name = 'IDX_SYSLOG_BACKLOG_RET_UPDATED';
|
|
|
|
-- 结构验证后应能执行；首次建表且还未发生积压采样时返回 0。
|
|
SELECT COUNT(*) AS audit_row_count
|
|
FROM syslog_backlog_retention_hourly;
|
|
|
|
-- 查看每个来源小时的实际选择率。该值反映采样选择，不代表后续存储一定写入成功。
|
|
-- 没有发生积压采样时，本查询返回空属于正常。
|
|
SELECT
|
|
source_hour,
|
|
SUM(message_total) AS message_total,
|
|
SUM(alarm_rows_total) AS alarm_rows_total,
|
|
SUM(alarm_rows_saved) AS alarm_rows_saved,
|
|
SUM(normal_rows_total) AS normal_rows_total,
|
|
SUM(normal_rows_saved) AS normal_rows_saved,
|
|
SUM(normal_rows_dropped) AS normal_rows_dropped,
|
|
CASE WHEN SUM(normal_rows_total) = 0 THEN 1
|
|
ELSE SUM(normal_rows_saved) * 1.0 / SUM(normal_rows_total) END AS normal_actual_rate,
|
|
SUM(non_normal_rows_total) AS non_normal_rows_total,
|
|
SUM(non_normal_rows_saved) AS non_normal_rows_saved,
|
|
SUM(non_normal_rows_dropped) AS non_normal_rows_dropped,
|
|
CASE WHEN SUM(non_normal_rows_total) = 0 THEN 1
|
|
ELSE SUM(non_normal_rows_saved) * 1.0 / SUM(non_normal_rows_total) END AS non_normal_actual_rate,
|
|
SUM(raw_total) AS raw_total,
|
|
SUM(raw_saved) AS raw_saved,
|
|
SUM(raw_dropped) AS raw_dropped,
|
|
MIN(min_lag_ms) AS min_lag_ms,
|
|
MAX(max_lag_ms) AS max_lag_ms
|
|
FROM syslog_backlog_retention_hourly
|
|
GROUP BY source_hour
|
|
ORDER BY source_hour DESC;
|