嵐の文書では、処理がタイムアウトしたタプルを嵐が再生していると言われています。私の質問は、嵐がこれを自動的に(原点スパウトでfail()を呼び出さずに)行うのか、それともタプルを再生するために元のスパウトの責任であるか(fail()が呼び出され、リプレイが外部)? http://storm.apache.org/documentation/Guaranteeing-message-processing.htmlから処理がタイムアウトした嵐の再生タプルはありますか?
5
A
答えて
6
タイムアウトに適切な再生をするには、吐水口から放出するときにタプルにIDを固定する必要があります。タイムアウトが発生すると、アンカーとして使用したものがfailメソッド(fail(object anchorId))に返されます。これで、タイムアウトタプルでやりたいことを再生するために、失敗した/タイムアウトされたタプルのanchorIdを使うことができます。各アンカーIDは一意でなければなりません。アンカーIDの例は、データベースIDです。タプルが失敗すると、databse idを使用してタプルを再作成して再表示することができます。だからあなたの質問に答えるには、失敗の内部にリプレイロジックを持っていなければならず、anchorIdを使ってタプルを再作成することができます。この情報が役立つことを願っています
4
、
タプル回アウトストームはそうです、
fail
が呼び出されますSpout
にfail
メソッドを呼び出します場合。
関連する問題
- 1. 嵐のトライデントをバッチ処理タプルに使用する方法?
- 2. SqlExceptionが発生することがあります:タイムアウトがタイムアウトしました
- 3. バッチ処理を処理するJavaキューオブジェクトまたはメカニズムがありますか?
- 4. タプルをマクロに渡す必要がありますか?タプルが処理される
- 5. Paypal API DoDirectPaymentでエラー10001が発生しました:タイムアウト処理リクエスト
- 6. WCFタイムアウト処理
- 7. getJSONタイムアウト処理
- 8. 与えられたフィールドを持つすべてのタプルが処理されたかどうかを確かめるための嵐ボルト
- 9. 処理が完了するとタイムアウトまたは閉じる
- 10. XSLT処理コマンドラインツールはありますか?
- 11. 未処理の例外が発生した場合は、WPFアプリケーションをシャットダウンする必要がありますか?
- 12. CXFでのマルチパートの長時間処理により、504(タイムアウト)が発生する
- 13. 申し訳ありません、あなたのリクエストの処理中にエラーが発生しました
- 14. ロード処理とサウンド再生
- 15. ストームを使用すると、1つのサーバがクラッシュした場合(シャットダウンなど)、ホスト上で一度処理されたタプルが再び処理されます。
- 16. このPHPスクリプトをより適切に処理する方法はありますか? - タイムアウトの問題
- 17. カフカストリームには処理にかかる時間がタイムアウトしていますか?
- 18. NServiceBus:「失敗した処理が完了しました」メッセージ処理のイベントが発生します。
- 19. JavaScriptでエラーが発生した後でコードを処理する方法はありますか?
- 20. ReadTimeoutHandlerのタイムアウトの処理
- 21. GnomeでのGNotificationのタイムアウトを処理しますか?
- 22. Actionmailer、タイムアウトし、エラーがあれば再開しますか?
- 23. マクロ内のタプル/オブジェクトのフィールド(名前+型)を反復処理する方法はありますか?
- 24. SSL_read()はSSL_ERROR_WANT_WRITEを処理する必要がありますか?
- 25. OutputStream close()関数で発生したIOExceptionを処理するか無視する必要がありますか?
- 26. ハードウェアとタイムアウトの処理.net
- 27. akkaと再生の間のファイル処理
- 28. 非常にスケーラブルで効率的な残りのjson処理にスプレーまたは再生を使用する必要がありますか?
- 29. 申し訳ありませんが、リクエストの処理中にエラーが発生しました。 MVC3モデルエンティティで
- 30. 再生フレームワークでのセッション処理
Spoutのfail()メソッドでどのボルトが失敗したのか知る方法はありますか?基本的には、ack()またはfail()を実行しているときに、タプルにボルト固有の情報を送りたいと思います。どのようにこれを行うことができますか? –