FetchSFTP 2025.5.31.15¶

完成ストラテジー

NiFi に取り込まれた後、サーバー上のオリジナルファイルをどうするかを指定します。完成ストラテジー が失敗した場合、警告はログに記録されますが、データは転送されます。

ディレクトリの作成

「完成ストラテジー」が「ファイルの移動」の場合に使用されます。リモートディレクトリが存在しない場合に作成するかどうかを指定します。

ディレクトリリストの無効化

「完了ストラテジー」が「ファイルの移動」で「ディレクトリの作成」が有効な場合に、「移動先ディレクトリ」をどのように作成するかを制御します。「true」にセットすると、見つからないディレクトリを作成する前にディレクトリリストを作成しません。デフォルトでは、このプロセッサーは、見つからないディレクトリを作成する前に、ディレクトリリストコマンドを実行してターゲットディレクトリの存在を確認します。しかし、以下のようなディレクトリリストを無効にする必要がある場合もあります。ディレクトリのパーミッション設定（chmod 100など）によっては、ディレクトリリストに失敗することがあります。また、このプロセッサーがリストを実行した後、このプロセッサーによるディレクトリ作成リクエストが終了する前に、他の SFTP クライアントがディレクトリを作成した場合、そのディレクトリはすでに存在するため、エラーが返されます。

ホスト名

データを取得するホストの完全修飾ホスト名または IP アドレス。

許可されるキー交換アルゴリズム

SFTP 接続で許可されるキー交換アルゴリズムのカンマ区切りリスト。すべて許可する場合は未設定のままにします。利用可能 オプションは以下の通りです。 curve25519-sha256、curve25519-sha256@libssh.org、diffie-hellman-group-exchange-sha1、diffie-hellman-group-exchange-sha256、diffie-hellman-group1-sha1、diffie-hellman-group14-sha1、diffie-hellman-group14-sha256、diffie-hellman-group14-sha256@ssh.com、diffie-hellman-group15-sha256、diffie-hellman-group15-sha256@ssh.com、diffie-hellman-group15-sha384@ssh.com、diffie-hellman-group15-ha512、diffie-hellman-group16-ha256、diffie-hellman-group16-sha384@ssh.com、diffie-hellman-group16-ha512、diffie-hellman-group16-sha512@ssh.com、diffie-hellman-group17-ha512、diffie-hellman-group18-ha512、diffie-hellman-group18-sha512@ssh.com、ecdh-ha2-nistp256、ecdh-ha2-nistp384、ecdh-ha2-nistp521、ext-info-c

宛先ディレクトリの移動

NiFi に取り込まれた後、オリジナルファイルを移動するリモートサーバー上のディレクトリ。このプロパティは、完成ストラテジー が 「ファイルの移動」 にセットされていない限り、無視されます。「ディレクトリの作成」が無効になっている場合、指定されたディレクトリがリモートシステム上に既に存在する必要があります。

ポート

データを取得するためにリモートホストで接続するポート。

秘密キーパス

秘密キーファイルへの許可された完全パス。

タイムアウト時にキープアライブを送信

最大5回まで5秒ごとにKeep Aliveメッセージを送信し、全体のタイムアウトは25秒です。

コンプレッションの使用

ファイル転送時に ZLIB 圧縮を使用するかどうかを示します。

fetchfiletransfer-notfound-loglevel

プロセッサーがトリガーされたときにファイルが存在しない場合に使用するログレベル

not.found

リモートサーバーから「Not Found」メッセージを受信した FlowFile は、この Relationship に転送されます。

success

受信したすべての FlowFiles は成功にルーティングされます。

sftp.remote.port

リモート SFTP サーバーとの通信に使用されたポート。

filename

ファイル名はリモートファイルのファイル名を指すように更新されます。

fetch.failure.reason

任意の失敗リレーションシップへのルーティング時に適用される失敗リレーションシップの名前

SFTP サーバーのディレクトリ内のすべてのファイルを取得します。