問題タブ [camel-ftp]

FTP サーバーからファイルを読み取るために Apache Camel を使用しています。数日間再起動せずに、新しいファイルをリッスンする必要があります。ダウンロードするファイルがある日もあれば、ない日もあります。

私が抱えていた最初の問題は、長期間 (たとえば 1 日) 非アクティブな状態が続いた後にファイルを FTP フォルダーに配置すると、ファイルが Apache Camel によって選択されず、機能させるために再起動する必要があったことでした。

disconnectこの場合、フラグが役立つのではないかと考えました。ただし、切断フラグを使用すると、次のエラーが発生します。

ファイルはダウンロードされ、preMoveフォルダに残されますが、 で指定された最終的なアーカイブ フォルダには移動されませんmove。したがって、ファイルが読み取られて preMove フォルダーに移動された後、接続が閉じられると思いますが、アーカイブフォルダーに移動しようとすると失敗します。ただし、オプションを削除しようとしましたが、それでも失敗するため、フラグが問題の原因であるpreMoveと思われます。move

この問題を回避する方法はありますか?

かなり単純なルートを使用して、SFTP 経由でリモート サーバーからローカル ディレクトリにファイルをダウンロードしようとしています。

私が直面している問題は、ルートが小さなファイル (200 バイト) をダウンロードできるが、大きなファイル (200 KB) では正確に 98265 バイトでスタックすることです。約 30 秒後、Pipe Closed エラーが発生します。

私は Apache Camel バージョンを使用しています: 2.15.3

From: sftp://xxx.xxx.xxx.xxx:xx//User/User01?delay=30s&include=File.*.csv&initialDelay=1m&password=xxxxxx&stepwise=false&streamDownload=true&username=User01

宛先: file:///var/opt/myfolder/incoming?doneFileName=${file:name}.done

このエラーの後、このファイルと残りのファイルはダウンロードされません。また、localWorkDirectory を使用してみましたが、tmp ディレクトリにダウンロードされたファイルも 98265 バイトでスタックしていました。

+ アップデート:

さらに調査した結果、Apache Camel が内部的に使用する JSCH ライブラリに問題があるようです。待機時間後に以下のエラーが発生します。ダウンロード用に JSCH を使用してスタンドアロン コードを作成しましたが、これもダウンロードの間にハングしています。また、ファイルを正常にダウンロードできる別の sftp API (JSCH ではない) を使用してスタンドアロン コードを作成しました。

質問 1:何が問題になっている可能性がありますか? この問題はどのように修正できますか?

質問 2: Apache Camel for SFTP で他のライブラリを使用する方法はありますか?

任意の提案をいただければ幸いです。

前もって感謝します。

apache-camel に ftp カスタム コンポーネントが必要な場合、ftp uri パラメータを ftpConfiguration に設定するにはどうすればよいですか? Uri param アノテーションを使用して uri パラメータを取得しようとしましたが、失敗しました。誰にもアイデアはありますか？以下は私のサンプルコードです：

ファイルの処理および削除中に Camel 構成からいくつかの問題を取得します。以下に 3 つのユースケースを追加しました

目的: SFTP を使用してファイルを読み込み、ローカル ディレクトリにコピーします。完了したら、SFTP の場所から削除します。以下は構成です

ユースケース 1: SFTP の場所にファイルが 1 つしかない場合。

特性 :<from uri="sftp://xxxx@xxxxxx:xxxx/testFolder/ToClient/?password=xxx& delete=true& scheduler=spring& scheduler.cron=0/15+*+*+?+*+MON-SAT& antInclude=*OECExport *.txt"/> 加工 : 全てGOOD

UseCase2 :複数のファイルがある場合

プロパティ ：<from uri="sftp://xxxx@xxxxxx:xxxx/testFolder/ToClient/?password=xxx& delete=true& scheduler=spring& scheduler.cron=0/15+*+*+?+*+MON-SAT& antInclude=*OECExport *.txt"/>

処理中 : 期待どおりに動作していません。警告：

UseCase3 :複数のファイルがある場合

新しいプロパティ: disconnect=true

プロパティ ：<from uri="sftp://xxxx@xxxxxx:xxxx/testFolder/ToClient/?password=xxx& disconnect=true&delete=true& scheduler=spring& scheduler.cron=0/15+*+*+?+*+MON-SAT& antInclude=*OECExport *.txt"/>

処理中 : 期待どおりに動作していません。警告：

camel FTP コンポーネントを介してリモート サーバーにファイルを送信しようとしたときに、リモート サーバーからファイルを取得する場合と同様に、要件を満たすように PUT の動作をカスタマイズしたいと考えています。

ただし、どのメソッドが実際にFTPコンポーネントを介してファイルをリモートに送信しているのかわかりません。

すべてのファイルとサブフォルダーをローカル マシンから sftp サーバーにコピーしたいのですが、フォルダー内のファイルを転送できましたが、ネストされたフォルダーを転送できませんでした。私のカスタムルートビルダーの構成方法は次のとおりです