活動合約
查詢期望的欄位
| 欄位 | 型別 | 為什麼存在 |
|---|---|---|
| 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（按角色）
- 資料表：按操作讀取失敗
讓查詢範例發揮作用
相關埋點和指南
繼續分析
在真實事件中執行它
建立資料表，調整欄位並儲存結果
免費開始，傳送結構化事件，並將查詢結果用作圖表、共享儀表板小工具或警示輸入。