問題タブ [retry-logic]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
183 問題
0
投票する
2
に答える
1114
参照
java - フローのいずれかの段階で障害が発生した場合、akka でストリームを再試行します
私は akka ストリームを使用してデータを処理しています。要素UUIDで構成される1つのソースがあります。
流れは次のとおりです。
- プロパティを含む完全な Element を返すサードパーティの HTTP サービスから Element を取得しています。
- 次に、その要素から必要なデータを取得し、アプリケーションが理解できるオブジェクトに変換します。
- 次に、そのオブジェクトのデータを DB に書き込みます。
- 最後に、ストリーム内のすべての要素のステータスで DB を更新します。
ここで、このフローに再試行メカニズムを追加して、フローのステージのいずれかが失敗した場合にステージを再試行する回数を 3 回に設定し、その後失敗した場合はストリームの唯一の失敗が発生するようにします。たとえば、HTTP 504 エラーのようなサードパーティ サービスに問題がある場合、ほとんどの場合、この要素を再試行すると成功します。akka でこれを達成する方法はありますか。
現在、失敗したすべての要素 ID を以下のように保存する 1 つのリストを維持しています。
コード :