KCL ベースの nodejs でアプリケーションを作成しています。関数ではprocessRecords
、kinesis から取得したレコードを http リクエストで Web サービスに送信しようとしました。ただし、Web サービスが利用できない場合、http 要求は失敗します。kinesis からレコードを取得するために KCL を停止し、pagerduty にアラートを送信したいと考えています。
誰でもそれを行う方法を知っていますか?
KCL ベースの nodejs でアプリケーションを作成しています。関数ではprocessRecords
、kinesis から取得したレコードを http リクエストで Web サービスに送信しようとしました。ただし、Web サービスが利用できない場合、http 要求は失敗します。kinesis からレコードを取得するために KCL を停止し、pagerduty にアラートを送信したいと考えています。
誰でもそれを行う方法を知っていますか?
これを特定のコードではなく一般的な戦略として提供する:
まだ行っていない場合は、エラーが発生した場合に指数バックオフを使用して適切な再試行ポリシーを設定していることを確認してください。これにより、ほとんどの一時的な問題が処理されます。
あなたの場合、おそらく「永久に再試行」タイプのポリシーが必要であり、再試行の回数が定義したしきい値を超えたときに pagerduty アラートを発生させます (つまり、numRetries==30 など)。