FetchS3Object 2025.10.2.19¶
バンドル¶
org.apache.nifi | nifi-aws-nar
説明¶
S3オブジェクトのコンテンツを取得し、それを FlowFile のコンテンツに書き込みます。
入力要件¶
REQUIRED
機密動的プロパティをサポート¶
false
プロパティ¶
プロパティ |
説明 |
|---|---|
AWS 認証情報 プロバイダーサービス |
AWS 認証情報プロバイダーの取得に使用するController Service。 |
バケット |
やり取りするS3バケット |
通信タイムアウト |
AWS への接続を確立するため、または AWS からデータを受信するために、タイムアウトするまでの待機時間。 |
Custom Signer Class Name |
Fully qualified class name of the custom signer class. The signer must implement com.amazonaws.auth. Signer interface. |
Custom Signer Module Location |
カスタム署名者の JAR ファイルとその依存関係 (もしあれば) を含むファイルやディレクトリへのパスをカンマ区切りにしたリスト。 |
Encryption Service |
リクエストの構成に使用する暗号化サービスコントローラーを指定します。PutS3Object: 下位互換性のため、「サーバー側の暗号化」 がセットされている場合、この値は無視されます。FetchS3Object: サーバー側カスタマーキー、クライアント側 KMS 、クライアント側カスタマーキー暗号化の場合のみ構成が必要。 |
エンドポイントオーバーライド URL |
スキーム、ホスト、ポート、パスを含む AWS デフォルトの代わりに使用するエンドポイント URL。AWS ライブラリは AWS リージョンに基づきエンドポイント URL を選択しますが、このプロパティは選択されたエンドポイント URL を上書きし、他の S3 互換エンドポイントとの使用を可能にします。 |
オブジェクトキー |
使用するS3オブジェクトキー。これは従来のファイルシステムのファイル名に似ています。 |
Range Length |
オブジェクトからダウンロードするバイト数（Range Startから開始）。空の値やオブジェクトの終端を超える値は、オブジェクトの終端まで読み込まれます。 |
Range Start |
オブジェクトからの読み取りを開始するバイト位置。空の値またはゼロの値は、オブジェクトの先頭から読み始めます。 |
リージョン |
AWS 接続先のリージョン。 |
Requester Pays |
If true, indicates that the requester consents to pay any charges associated with retrieving objects from the S3 bucket. This sets the 'x-amz-request-payer' header to 'requester'. |
SSL コンテキストサービス |
もしプロバイダーが提供されていれば、接続の作成に使われる SSL Context Service を指定します。 |
署名者の上書き |
AWS S3ライブラリはデフォルトで署名バージョン4を使用しますが、このプロパティを使用すると、古いS3互換サービスをサポートするためにバージョン2の署名者を指定したり、独自のカスタム署名者の実装をプラグインしたりすることができます。 |
バージョン |
ダウンロードするオブジェクトのバージョン |
proxy-configuration-service |
ネットワークリクエストをプロキシするプロキシ構成Controller Serviceを指定します。 |
リレーションシップ¶
名前 |
説明 |
|---|---|
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バケットに到着した新しいファイルを取得します。 |