0

私はすべてのアプリケーションを管理するためにSpring Cloud Data Flowサーバーを使用しようとしています。また、私は春にはすべて新しいです。ソースでもシンクでもないアプリを書くことはできますか?

SFTPからファイルを読み込んでS3に書き込むアプリケーションを作成したいと思います。ファイルは非常に大きく(それぞれ〜500MB)、メッセージのペイロードとして渡すことができます。私はSFTPから読み込んでS3に書き込むので、SFTPからローカルファイルにファイルを読み込み、S3にローカルファイルをアップロードしたり、SFTPからバイトを直接ストリームしたりすることで、ブローカを回避できると思ったS3へ。

このようなアプリケーションの作成方法については、私は迷っています。

答えて

1

まあ、物事のカップルここ

  1. 何を記述しているのはソース両方シンクまたは他の言葉でプロセッサ(単にソースおよびシンクをカプセル化し、別のステレオタイプであるアプリです)。
  2. Spring Cloud Streamは、複雑なフローを実装するためのコンフィグレーションをサポートしています。また、あらかじめ作成されたアダプタ/コネクタを使用しています。Spring Integration このようなアダプタの1つは、streaming SFTPアダプタです。SFTPアダプタを使用すると、データをメモリに読み込む代わりに、SFTPからストリームできるようになります。

本質的に、Spring Integrationによって提供される既存のコンポーネントを使用して、必要なものを正確に達成することができます。

さらに詳しい情報が必要な場合は、ドキュメントを見て、わかりやすいかどうかをご確認ください。

+0

これはSpring Integration Channel Adaptersに基づいたSpring Cloud Taskです。 –

+0

@ oleg-zhurakouskyなぜ私のアプリはプロセッサですか?私がそれを見る方法は、それもソースもシンクもありません。プロセッサはソースとシンクの両方であるため、メッセージを受信するためにブローカにバインドし、メッセージを送信するためにブローカにバインドします。メッセージを受け取ったり送信したりしたくないので、ブローカーにバインドしたくないです。 – polo

+0

。 。私が説明しようとしていたのは、Spring Cloud Streamの一般的なコンテキストでは、Source(入力、SFTP)とSink(出力、S3)を持つアプリケーションであるため、プロセッサです。それは、私はあなたの意見を見て同意すると言った。実際にはさらに進んで、必要なのは、基本的にSpring Integrationとそのアダプターを使用して、Spring Integration(Spring Cloud Streamアプリではない)の簡単なSpring-Integration有線のSpring起動アプリです。 –

関連する問題