複数の試行にわたって 1 つの論理ジョブに従います
安定したジョブ ID を維持し、試行レベルのイベントを最終結果から分離して、再試行の回復が測定可能な状態を維持できるようにします。
選考枠組み
結果がわかる境界を選択してください
キュー待機を実行から分離する
スケジュールされた、キューに入れられた、開始された、および完了したタイムスタンプにより、バックログのプレッシャーと遅いワーカー コードが区別されます。
終了状態を定義する
停止したジョブのクエリやアラートを書き込む前に、完了、永続的な失敗、キャンセル、破棄、配信不能の結果を文書化します。
共有イベント契約
最初のスキーマを相互運用可能に保つ
- job_id、job_name、queue_name、ステータス、試行、およびリリース
- scheduled_at、started_at、completed_at、duration_ms、および wait_ms
- error_type、worker_name、item_count、dead_lettered、および account_id
これらのフィールドをワークフローに適応させますが、複数のサービスが同じテーブルに依存する前に、ユニット、ステータス カテゴリ、識別子、および所有権を明示的に保ちます。
検証
アラートの前に障害パスを実行する
- 11 回成功し、リカバリを再試行し、永久に失敗し、キャンセル フィクスチャを実行します。
- 2同じ論理ジョブが試行間で相関関係を維持していることを確認します。
- 3キューの待機時間、実行時間、エンドツーエンドの時間を調整します。
- 4重複配信と冪等なダウンストリーム動作をテストします。
実装ガイド
フレームワーク、プロバイダー、またはランタイムを一致させる
ソースされた実装ガイド
Ingest and Trigger.dev ジョブ Telemetry
SQL 対応ログを使用して、非同期ワーカー、スケジュールされたジョブ、再試行、失敗、配信不能イベントを計測します。
オープンガイドソースされた実装ガイド
Django と Celery の構造化イベント監視
Django リクエストの結果と Celery タスクのライフサイクルを、安全な識別子、レイテンシ、再試行、ターミナル ステータスで結び付けます。
オープンガイドソースされた実装ガイド
ワークフローの一時的な可観測性
ワークフロー ペイロードを記録することなく、一時的なワークフローの結果、アクティビティの再試行、スケジュールから開始までの待ち時間、ビジネス マイルストーンを追跡します。
オープンガイドソースされた実装ガイド
n8n ワークフロー Telemetry
n8n ワークフローの完了、失敗、再試行、項目数、およびダウンストリーム配信結果を、HTTP 要求ノードを介して、制限された Telemetry イベントに送信します。
オープンガイドソースされた実装ガイド
BullMQ キューの監視
SQL 対応ライフサイクル イベントを使用して、BullMQ キューの待機、実行期間、再試行、失敗、配信不能レターの増加を測定します。
オープンガイドソースされた実装ガイド
AWS SQS キューの可観測性
メッセージ本文を保存せずに、SQS メッセージの経過時間、受信試行、処理結果、バッチ動作、配信不能ルーティングを追跡します。
オープンガイドソースされた実装ガイド
RabbitMQ キュー Telemetry
RabbitMQ の公開確認、配信、確認応答、再配信、キュー待機、再試行、配信不能の結果を構造化イベントで追跡します。
オープンガイドソースされた実装ガイド
Google Cloud Pub/Sub テレメトリ
安定したメッセージ識別子を使用して、Pub/Sub のパブリッシュ、配信、確認応答、再配信、順序付け、キューの経過時間、配信不能の結果を追跡します。
オープンガイドソースされた実装ガイド
Azure サービス バス Telemetry
メッセージ本文を収集せずに、Azure Service Bus の送信、受信、ロック更新、決済、再配信、延期、配信不能の結果を追跡します。
オープンガイドソースされた実装ガイド
Kafka コンシューマ ラグと処理分析
Kafka コンシューマの結果、パーティション ラグ、処理遅延、再試行、構造化イベントによる有害メッセージの処理を監視します。
オープンガイドソースされた実装ガイド
Sidekiq ジョブ Telemetry
ジョブ引数をコピーせずに、Sidekiq の実行結果、試行、キュー待機、エラー、サーバー ミドルウェアからのリリースを追跡します。
オープンガイドソースされた実装ガイド
Redis とノード Redis Telemetry
Redis コマンドの結果、レイテンシー、キャッシュ動作、再接続、および制限されたエラー カテゴリをノード Redis と並行して測定します。
オープンガイドソースされた実装ガイド
AWS Lambda 構造化イベント監視
コンパクトな構造化イベントを使用して、Lambda の呼び出し、コールド スタート、期間、再試行、ビジネスの結果を追跡します。
オープンガイドソースされた実装ガイド
Stripe ウェブフック Telemetry
Webhook 本体を保存せずに、支払い、サブスクリプション、請求書、再試行、およびダウンストリームの請求同期動作をデバッグします。
オープンガイドソースされた実装ガイド
GitHub アクション ワークフロー Telemetry の統合
実行、試行、ジョブ、結論、期間、リリース コンテキストを含む GitHub アクションから、制限されたターミナル ワークフロー結果を送信します。
オープンガイド最初に 1 つのエンドツーエンドのワークフローを確認します
無料の API キーを作成し、最も近いランタイム ガイドを選択し、カバレッジを拡大する前に既知の成功と失敗を 1 つ送信します。