問題タブ [retrypolicy]

Azure Service Bus Queue 関数を操作しているときに、例外が発生するたびに、azure 関数が既定の再試行ポリシー (最大カウント = 10) を実行することがわかっています。やりたいことは、retryCountというプロパティを使用してメッセージを表示することです。したがって、例外が生成されると、retryCount += 1を増やし、現在の例外をメッセージに追加します。次に、関数が再試行を実行しているときに、これが x レコードと一緒に来る x 回目であることがわかります。例外。MessageオブジェクトにdeliveryCountという読み取り専用プロパティがあることはわかっていますが、追加情報をバインドしたり、最後の配信失敗の理由を特定したりすることはできません。メッセージオブジェクトから。

しかし、アイデアを実装しようとした後、関数が再試行を実行するたびに、更新されたメッセージではなく、常にキューから最初のメッセージをリロードすることがわかりました。更新されたメッセージを現在のキューに強制的に再送信することなく、更新されたメッセージで再試行できるようにする方法はありますか?

さらに、現在の再試行ロジックをカスタマイズするにはどうすればよいでしょうか。たとえば、最大再試行回数を 10 から 1 に減らし、Polly を使用して関数内のいくつかのシナリオを処理するにはどうすればよいでしょうか?

バージョン 2.1.7 で実行されているスプリング ブート アプリケーションがあります。接続と読み取りタイムアウトを設定するために、Rest Template Builder を使用してカスタム Rest テンプレートを実装しようとしています。私は 2.1.7 で実行しているので、Rest Template Builder を使用する必要があることを知りました。カスタム レスト テンプレートのコードを以下に示します。この残りのテンプレートはアプリケーションのさまざまなコンポーネントで使用されるため、コードの他の領域でこの残りのテンプレートを呼び出すには支援が必要ですが、そうするのに助けが必要です。これに関するアドバイスは大歓迎です。ありがとう！

以下のようにDefaultRetryPolicyのinitialTimeoutMsとして 1500 を設定しましたが、タイムアウトは考慮されません。

デバイスの WiFi を切断してタイムアウトをテストしたところ、Logcatでこれらの時間が表示されました。

1.5 秒後に onResponse または onError のいずれかをキャッチすると予想していたのに、20 秒以上かかりました!!!

SNS のドキュメントでは、SNS の HTTP/S サブスクリプションの配信ポリシーを設定できることが指定されています: https://docs.aws.amazon.com/sns/latest/dg/sns-message-delivery-retries.html。の最大制限number of retriesが 100 でありmaxDelayTarget、次の構成が 3600 であるとすると、可能な最大制限ですか?

これにより、1 時間間隔で再試行が構成され、合計で最大 4 日 (100 時間) 追加されます。SNS の保持期間は 4 日間ですか? Amazon IPNの状態

別の応答を送信すると、Amazon SNS は 14 日間、1 時間ごとに再試行します。

制限を 4 日以上増やすことはできますか?

SQS を使用して SNS でメッセージの永続性をシミュレートする古い回答では、1 時間の保持期間が言及されています。これは変わりましたか？

RxJSrepeatWhenオペレーターを使用してネットワーク再試行を作成しようとしています。新しいリクエストがスケジューラーに届いたら、そのリクエストを直接試し、結果としてネットワーク障害が発生した場合は、それをプールに追加して後で再試行するという考え方です。したがって、私のスケジューラの開始点は、次のようなジョブを実行するキュー関数です。

ワーカーの通知者として使用されるですthis.notifier。Subjectしたがって、ワーカー自体は次のようになります。

また、ノーティファイアーは、次のような配列ですべての元に戻されたリクエストを追跡します。

私が知っているように、ワーカーのサイクルが完了していない場合、repeatWhen は何の関係もありません。たとえば、パーツを削除すると:

ワーカーから、ワーカーの最初の試行 (空のサイクル) で、Observable は完了せず、repeatWhen は何もしません。しかし一方で、ご覧// subscriber.complete();のとおり、ジョブが存在する場合にコメントしましたが、繰り返しが発生しています。そして、問題の最悪の部分は、ワーカーの多くの異なるインスタンスが並行して実行され、多くの重複したリクエストが作成されることです。

私はこの問題に多くの時間を費やしましたが、追跡する手がかりがありません。

タイトルの通り、Pollyを使ってリトライの仕組みを作りました。問題は、独自のカスタム例外ではなく、常に System.AggregateException を取得することです。ここにコードを追加します。

これは、私が作成した polly 静的クラスです。

リトライ ポリーの実際の呼び出しは次のとおりです。

MyException をスローすると、polly も呼び出し元メソッドに MyException をスローすることが期待されます。代わりに、スローされる例外は System.AggregateException です。

ここで何が間違っていますか？ありがとう

編集 1: さらにデバッグした後、AggregateException が内部例外として MyException を持っているようです。これは意図した動作ですか、それとも何か間違っていますか?