FetchS3Object 2025.5.31.15¶

バンドル¶

org.apache.nifi | nifi-aws-nar

説明¶

S3オブジェクトのコンテンツを取得し、それを FlowFile のコンテンツに書き込みます。

タグ¶

AWS, Amazon, Fetch, Get, S3

入力要件¶

REQUIRED

機密動的プロパティをサポート¶

false

プロパティ¶

プロパティ	説明
AWS 認証情報プロバイダーサービス	AWS 認証情報プロバイダーの取得に使用するController Service。
バケット	やり取りするS3バケット
通信タイムアウト	AWS への接続を確立するため、または AWS からデータを受信するために、タイムアウトするまでの待機時間。
エンドポイントオーバーライド URL	スキーム、ホスト、ポート、パスを含む AWS デフォルトの代わりに使用するエンドポイント URL。AWS ライブラリは AWS リージョンに基づきエンドポイント URL を選択しますが、このプロパティは選択されたエンドポイント URL を上書きし、他の S3 互換エンドポイントとの使用を可能にします。
オブジェクトキー	使用するS3オブジェクトキー。これは従来のファイルシステムのファイル名に似ています。
リージョン	AWS 接続先のリージョン。
SSL コンテキストサービス	もしプロバイダーが提供されていれば、接続の作成に使われる SSL Context Service を指定します。
署名者の上書き	AWS S3ライブラリはデフォルトで署名バージョン4を使用しますが、このプロパティを使用すると、古いS3互換サービスをサポートするためにバージョン2の署名者を指定したり、独自のカスタム署名者の実装をプラグインしたりすることができます。
バージョン	ダウンロードするオブジェクトのバージョン
custom-signer-class-name	カスタム署名者クラスの完全修飾クラス名。署名者はcom.amazonaws.auth.Signerインターフェイスを実装する必要があります。
custom-signer-module-location	カスタム署名者の JAR ファイルとその依存関係 (もしあれば) を含むファイルやディレクトリへのパスをカンマ区切りにしたリスト。
encryption-service	リクエストの構成に使用する暗号化サービスコントローラーを指定します。PutS3Object: 下位互換性のため、「サーバー側の暗号化」がセットされている場合、この値は無視されます。FetchS3Object: サーバー側カスタマーキー、クライアント側 KMS 、クライアント側カスタマーキー暗号化の場合のみ構成が必要。
proxy-configuration-service	ネットワークリクエストをプロキシするプロキシ構成Controller Serviceを指定します。
range-length	オブジェクトからダウンロードするバイト数（Range Startから開始）。空の値やオブジェクトの終端を超える値は、オブジェクトの終端まで読み込まれます。
range-start	オブジェクトからの読み取りを開始するバイト位置。空の値またはゼロの値は、オブジェクトの先頭から読み始めます。
requester-pays	trueの場合、リクエスト送信者はS3バケットからオブジェクトを取得することに関連するすべての料金を支払うことに同意することを示します。これは 'x-amz-request-payer' ヘッダーを 'requester' にセットします。

リレーションシップ¶

名前	説明
failure	プロセッサーが指定された FlowFile を処理できない場合、それはこのリレーションシップにルーティングされます。
success	FlowFiles は、正常に処理された後、この Relationship にルーティングされます。

属性の書き込み¶

名前	説明
s3.url	S3オブジェクトへのアクセスに使用できる URL。
s3.bucket	S3のバケット名
path	ファイルのパス
absolute.path	ファイルのパス
filename	ファイル名
hash.value	ファイルの MD5 合計
hash.algorithm	MD5
mime.type	S3がコンテンツタイプ/MIME タイプを提供する場合、この属性はそのファイルを保持します。
s3.etag	ファイルが変更されたかどうかを確認するために使用できる ETag
s3.exception	プロセッサー実行中にスローされる例外のクラス名
s3.additionalDetails	S3が提供する失敗した演算子の詳細
s3.statusCode	失敗した操作の HTTP エラーコード（利用可能な場合）。
s3.errorCode	失敗した演算子のS3名
s3.errorMessage	失敗した演算子からのS3例外メッセージ
s3.expirationTime	ファイルに有効期限がある場合、この属性がセットされ、 UTC 時間でのエポックからのミリ秒が含まれます。
s3.expirationTimeRuleId	このオブジェクトの有効期限を決めるルールの ID
s3.sseAlgorithm	オブジェクトのサーバー側の暗号化アルゴリズム。
s3.version	S3オブジェクトのバージョン
s3.encryptionStrategy	S3オブジェクトの保存に使用された暗号化ストラテジーの名前（暗号化されている場合）

ユースケース¶

S3から特定のファイルを取得

他のコンポーネントを含むユースケース¶

S3バケット内の全ファイルの取得

指定した条件を満たすファイルのみをS3から取得します。

S3バケットに到着した新しいファイルを取得します。

こちらもご覧ください¶