かなり概念的な質問がありますが、一般的すぎる、または愚かすぎると見なされないことを願っています:)
データ項目が多くのステップを経る必要があるアプリケーション (たとえば、ステップ 1 - CSV ファイルからの解析とレポートの生成、ステップ 2 - 前のステップで生成されたレポートに基づくレポートの実行など) を想定してみましょう。処理は永続的なキューを使用して実装され、新しい生ファイルが検出されると、そのファイルの処理を求めるメッセージがキューに入れられます。メッセージは、ファイルを処理するコンシューマーによって選択され、次の処理ステップなどのためにその作業の結果をキューに入れる別のメッセージを入れます。
私の質問は、このプロセスの失敗を処理するためのベスト プラクティスは何ですか? ステップ 1 のコンシューマが完全に失敗したとしましょう。
キューベースのアーキテクチャにそのようなバッチ処理を実装することは、まったく論理的/効率的ですか?