0

私は自分の要件で同時/並列処理を実現しようとしていますが、この点に関して何度も試みても適切な助けが得られませんでした。

ログ ファイルを含む 5 つのリモート ディレクトリ (追加または削除される可能性があります) があり、それらをローカル ディレクトリに 15 分ごとに Dow ロードし、ftp 転送ジョブの完了後に Lucene インデックス作成を実行したいと考えています。ルーターを追加したいと考えています。動的に。

これらのリモート マシンはすべて異なるエンド ポイントであり、異なるルートであるためです。これらすべてを開始する特定のエンドポイントはありません。

Start 
<parallel>
        <download remote dir from: sftp1>
       <download remote dir from: sftp2>
          .... 
</parallel>
<After above task complete>
<start Lucene indexing>
<end>

上記を15分ごとに繰り返し、

すべてのフォルダを並列にダウンロードしたいのですが、誰かが同様の要件に取り組んでいる場合は、解決策を教えてください。

スターターエンドポイントがない場合に、これらの複数のルート (この複数のリモートディレクトリなど) をキックスタートする方法を知りたいです。すべてのftp操作を並行して開始し、それらを完了してからインデックス付けしたいと思います。この投稿をお読みいただきありがとうございます。

このようにしてみましたが、

from (bean:foo? Method=start).multicast ().to (direct:a).to (direct:b)... 

From (direct:a) .from (sftp:xxx).to (localdir) 
from (direct:b).from (sftp:xxx).to (localdir)
4

1 に答える 1

0
  • camel-ftp は、consumer.delay プロパティによる定期的なポーリングをサポートします
  • この単体テストに示されているように、サーバーごとに camel-ftp コンシューマ ルートを動的に追加します。
  • 次に、サイズまたはタイムアウト値に基づいて結果を集計して、Lucene のインデックス作成などを開始できます。

【todo - 例をまとめる】

于 2013-10-10T06:12:46.817 に答える