活动合约
查询期望的字段
| 字段 | 类型 | 为什么存在 |
|---|---|---|
| timestamp_utc | Timestamp | 副本读取完成时间。 |
| region | Utf8 | 应用区域。 |
| replica_role | Utf8 | 主目标、副本目标或故障转移目标。 |
| replay_lag_ms | Float64 | 观察到或报告的重播延迟。 |
| consistency_outcome | Utf8 | 新鲜的、陈旧的、失败的或未知的。 |
| operation_name | Utf8 | 受控的应用程序读取操作。 |
DataFusion SQL
复制查询
sql
SELECT
region,
replica_role,
operation_name,
COUNT(*) AS reads,
approx_percentile_cont(replay_lag_ms, 0.95) AS p95_replay_lag_ms,
SUM(CASE WHEN consistency_outcome = 'stale' THEN 1 ELSE 0 END)
AS stale_reads,
SUM(CASE WHEN consistency_outcome = 'failed' THEN 1 ELSE 0 END)
AS failed_reads
FROM database_replica_read_events
WHERE timestamp_utc >= now() - INTERVAL '24 hours'
GROUP BY region, replica_role, operation_name
ORDER BY stale_reads DESC, p95_replay_lag_ms DESC;此只读查询是针对空类型表计划和执行的 阿帕奇 DataFusion 45.2.0。确定性样本输出是综合的并单独审查;根据您自己的数据验证字段类型、阈值和业务定义。 阅读测试方法。
查询结果
副本区域的陈旧读取
ap-southeast 订阅读取具有最高的观察到的陈旧性和重播滞后尾部。
ap-southeast
214
comparison 4,820
eu-west
31
comparison 740
| region | replica_role | operation_name | reads | p95_replay_lag_ms | stale_reads | failed_reads |
|---|---|---|---|---|---|---|
| ap-southeast | replica | subscription-status | 18,400 | 4,820 | 214 | 18 |
| eu-west | replica | project-list | 42,100 | 740 | 31 | 2 |
综合示例输出。在将其用于操作决策之前,针对您自己的事件架构和阈值运行查询。
SQL 是如何工作的
- 1副本角色和区域标识读取路径。
- 2应用程序一致性结果将用户可见的陈旧性与报告的延迟分开记录。
- 3操作名称显示哪些工作流程需要更强的写后读行为。
需要决定的边缘情况
- 一致性结果需要进行可防御的应用程序检查。
- 重播延迟单位因数据库和收集器而异。
- 数据库本机复制和故障转移工具仍然是服务器诊断的来源。
推荐仪表板
- 酒吧:stale_reads(按地区)
- 趋势:p95_replay_lag_ms(按角色)
- 表:按操作读取失败
让查询示例发挥作用
相关埋点和指南
继续分析
在真实事件中运行它
创建表,调整字段并保存结果
免费开始,发送结构化事件,并将查询结果用作图表、共享仪表板小部件或警报输入。