問題タブ [aggregator]

私はいくつかの問題を抱えています。私は ESB の初心者です。WSO2 ESB を試してみました。2 つの Web サービスを集約する wso2 ESB Aggregator の例を試してみたい。

http://docs.wso2.org/display/IntegrationPatterns/Aggregator

私はすべての手順を実行しました。しかし、私はいくつかのエラーが発生します。

=================

============

誰でも私を助けることができますか？

ありがとう。

しばらくの間 Graphite を使用しており、最近、一部のメトリックのソースを statsd から yammer/codahale-metrics に変更しました。通常、メトリクスは多数の異なるサーバーから送信されるため、それを処理するために Graphite 独自のアグリゲーターをセットアップします。

ここでの問題は、個々のサーバーの統計が表示され、問題なく動作することですが、集計された統計は常に最後の 1 時間程度のものしか正しくありません。古い集計値は、しばらくすると何らかの形で変更されることを意味します。これがどのように見えるかのイメージです: 緑色の線は、集計されるべきメトリックの単なる sumSeries であり、青色の線は、アグリゲーターが生成したものです。両方の線が過去 1 時間だけ調和していることに注意してください。

もちろん、ストレージ/集約/保持ルールを調べましたが、それらはすべて非常に基本的なものであり、すべてのメトリックを均等にカバーする必要があります (基本的に、わずか 1 時間後には有効になりません)。

storage-schemas.conf

storage-aggregation.conf

実際のアグリゲーターの構成は、おそらくここでの盲点です。なぜなら、本当に詳細なドキュメントを見つけることができず、すべてをそのままにしておいたからです。

carbon.conf

ルート(Apache Camel の言い回し) についての私の理解では、ルートはあるエンドポイントから別のエンドポイントへのデータの流れを表し、途中でデータに対して EIP タイプの操作を実行するさまざまなプロセッサで停止します。

それがルートの正しい/公正な評価である場合、同じ内部に複数のルートが必要であると思わCamelContextれる問題をモデル化しています(私はSpringを使用しています):

1. ルート 1: Source-1 からデータを抽出して処理し、に変換してList<SomePOJO>から、アグリゲーターに送信します。
2. ルート 2: Source-2 からデータを抽出して処理し、さらに に変換してからList<SomePOJO>アグリゲーターに送信します。
3. ルート 3:ルート 1 とルート 2 の両方List<SomePOJO>からを受信するまで待機し、その後、集約リストの処理を続行するアグリゲーターが含まれています。

ここに問題があります:両方List<SomePOJO>の s が同時にアグリゲーターに到着する必要があります。または、アグリゲーター Bean は、2 つのリストを 1 つに集約して集約されたリストを送信する前に、両方のルートからデータを受信するまで待機List<SomePOJO>する必要があります国道3号線の残り。

これまでのところ、次の疑似コードがあります<camelContext>。

次にJavaで：

私の質問

1. 私の基本設定は正しいですか？つまり、direct:aggregatorエンドポイントを正しく使用して、のアグリゲーターroute-1との間route-2でデータを送受信していますか?route-3
2. アグリゲーターは期待どおりに機能しますか? Beanの実行には 5 秒しかかからないが、extractor1Beanの実行には 2 分かかるとします。t=5 で、アグリゲーターは からデータを受信し、終了するまで (2 分間) 待機を開始し、残りのデータを集約する必要があります。はい？route-1extractor2route-2extractor1extractor2

次のキャメルルートがあります：

ご覧のとおり、 が<aggregator/>受信した最初の 500 メッセージ、または 1 分間隔内のすべてのメッセージを集約し、集約したメッセージを という Bean に送信しますpostProcessor。

この集計ロジックは、次のように考えることができます。

または疑似コードで: aggregateUntil(weHave500Message() || 1minHasElapsed()). このロジックを次のように変更したいと思います。

または、再び疑似コードで: aggregateUntil(weHave500Message() || 1minHasElapsed() || messageHasProperty("fireNow", "true")).

つまり、3 つの条件のいずれかが満たされるまで集計します。これを実装する方法はありますか？私はおそらく とでこれを仕上げることができると感じていますが、ここの木を通して森を見ることはできません.completionPredicateeagerCheckCompletion

私は自分自身を書こうとしていますが、アグリゲーター/ヒストグラムとして使用できる宝石/ライブラリがあるかどうか疑問に思っていました

私の目標は、一致するキーに基づいて値を合計することです:

一意のキーごとに値を合計して、 を返す必要が["fish","42"]あり["meat","57"] ます。集約する必要があるファイルは比較的大きく、tsv キーと値のペアで構成される約 4 GB のテキスト ファイルです。私の目標は、一時ファイルを使用しないようにすることです。マシン上に多くのスペースがあるので、すでに最適化された同様のものが既に存在するかどうか疑問に思っていました.githubで「ヒストグラム」という名前のジェブを見つけましたが、必要な機能が実際には含まれていませんThx

現在の状況があります。私はApache Camelを使用し、大きなファイルを小さな交換用に分割し（スプリッターを使用、以下を参照）、それらを検証します。次に、集約メッセージが必要ですが、集約器を使用しており、セットアップの完了サイズなどが必要です。制限を設定せずに、現在のドキュメントからすべての交換を集約できますか?

私のルート:

アグリゲーターを設定するには、交換の数または時間を設定するために使用しますが、交換がいくつになるかわかりません。