イベント契約
クエリが期待するフィールド
| フィールド | 種類 | なぜ存在するのか |
|---|---|---|
| timestamp_utc | Timestamp | 試行完了時間。 |
| job_id | Utf8 | 安定した論理ジョブ識別子。 |
| job_name | Utf8 | 安定した職種です。 |
| attempt | Int64 | 1 から始まる試行番号。 |
| status | Utf8 | 完了、再試行、または失敗。 |
DataFusion SQL
クエリをコピーする
sql
SELECT
date_trunc('hour', timestamp_utc) AS hour,
job_name,
COUNT(*) AS attempts,
COUNT(DISTINCT job_id) AS logical_jobs,
SUM(CASE WHEN attempt > 1 THEN 1 ELSE 0 END) AS retry_attempts,
100.0 * SUM(CASE WHEN attempt > 1 THEN 1 ELSE 0 END)
/ NULLIF(COUNT(*), 0) AS retry_attempt_rate_pct,
100.0 * SUM(CASE WHEN status = 'failed' THEN 1 ELSE 0 END)
/ NULLIF(COUNT(*), 0) AS failed_attempt_rate_pct
FROM job_attempts
WHERE timestamp_utc >= now() - INTERVAL '24 hours'
GROUP BY date_trunc('hour', timestamp_utc), job_name
HAVING COUNT(*) >= 20
ORDER BY retry_attempt_rate_pct DESC, attempts DESC;この読み取り専用クエリは、空の型付きテーブルに対して計画され、実行されます。 アパッチ DataFusion 45.2.0。決定論的なサンプル出力は合成され、個別にレビューされます。フィールド タイプ、しきい値、ビジネス定義を独自のデータと照合して検証します。 テスト方法を読んでください。
クエリ結果
ジョブ別のリトライ率
CRM 同期では、論理ジョブよりもはるかに多くの試行が行われ、繰り返しの作業によりワーカーのキャパシティが消費されます。
sync_crm_accounts
60.76%
send_receipt_email
3.74%
| hour | job_name | attempts | logical_jobs | retry_attempts | retry_attempt_rate_pct | failed_attempt_rate_pct |
|---|---|---|---|---|---|---|
| 2026-07-27 14:00 | sync_crm_accounts | 1,840 | 492 | 1,118 | 60.76 | 22.34 |
| 2026-07-27 14:00 | send_receipt_email | 3,180 | 3,061 | 119 | 3.74 | 0.44 |
合成出力例。運用上の決定に使用する前に、独自のイベント スキーマとしきい値に対してクエリを実行します。
例を再現する
パブリックフィクスチャをダウンロードする
JSON バンドルには、型付きイベント コントラクトが含まれています。 illustrative 入力行、正確な SQL、予想される出力、レビューメモ、およびエンジンのバージョン。 CSV には、表示された結果が含まれます。
SQL の仕組み
- 1個別のジョブ ID は有用な論理作業を推定し、生のカウントはワーカーの試行を測定します。
- 2試行回数が 1 を超えると、最終的な成功を最初の試行として扱わずに、繰り返しの作業が分離されます。
- 3失敗率は再試行シェアの横にあるため、意図的に再試行された一時的な依存関係は最終的な失敗と区別できます。
決定すべきエッジケース
- ファンアウト ジョブは、合法的に複数の子 ID を作成できます。カウントを比較する前に、論理作業識別子を定義します。
- 即時再試行とスケジュールされたバックオフでは容量への影響が異なるため、別のフィールドが必要になる場合があります。
- 再試行の嵐は時間ごとのバケット間を移動する可能性があります。応答時間が重要な場合は、より短い操作クエリを追加します。
推奨されるダッシュボード
- バー: ジョブ別 retry_attempt_rate_pct
- 傾向: 試行回数と logical_jobs
- 表: 試行回数が最も多く、エラーの種類が最も新しいジョブ
レシピを活用する
関連する機器とガイド
分析を続ける
実際のイベントで実行する
テーブルを作成し、フィールドを調整して、結果を保存します
無料で始めて、構造化されたイベントを送信し、クエリ結果をグラフ、共有ダッシュボード ウィジェット、またはアラート入力として使用します。