29.2.2. クエリーパラメーター(50 パラメーター):
Name | 説明 | デフォルト | Type |
---|---|---|---|
amazonS3Client (common) | link:registry.htmlRegistry の com.amazonaws.services.sqs.AmazonS3 への参照。 | AmazonS3 | |
pathStyleAccess (common) | S3 クライアントがパススタイルアクセスを使用するかどうか。 | false | boolean |
ポリシー (共通) | com.amazonaws.services.s3.AmazonS3setBucketPolicy()メソッドに設定されるこのキューのポリシー。 | 文字列 | |
proxyHost (common) | SQS クライアントをインスタンス化するときにプロキシーホストを定義します。 | 文字列 | |
proxyPort (common) | クライアント定義内で使用されるプロキシーポートを指定します。 | 整数 | |
リージョン (共通) | S3 クライアントが機能する必要があるリージョン | 文字列 | |
useIAMCredentials (common) | S3 クライアントが EC2 インスタンスでクレデンシャルをロードすることを期待すべきか、または静的クレデンシャルが渡されることを期待すべきかどうかを設定します。 | false | boolean |
encryptionMaterials (common) | 対称/非対称クライアントの使用時に使用する暗号化資料 | EncryptionMaterials | |
useEncryption (common) | 暗号化を使用する必要があるかどうかを定義します。 | false | boolean |
bridgeErrorHandler (consumer) | コンシューマーの Camel ルーティングエラーハンドラーへのブリッジを許可します。よって、コンシューマーが受信メッセージなどの取得を試行している間に発生した例外は、メッセージとして処理され、ルーティングエラーハンドラーによって処理されます。デフォルトでは、コンシューマーは org.apache.camel.spi.ExceptionHandler を使用して例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。 | false | boolean |
deleteAfterRead (consumer) | 取得後に S3 からオブジェクトを削除します。削除は、エクスチェンジがコミットされた場合にのみ実行されます。ロールバックが発生すると、オブジェクトは削除されません。このオプションが false の場合、同じオブジェクトがポーリングで繰り返し取得されます。そのため、ルートで Idempotent Consumer EIP を使用して重複を除外する必要があります。リンク S3ConstantsBUCKET_NAME とリンク S3ConstantsKEY ヘッダーを使用するか、リンク S3ConstantsKEY ヘッダーのみを使用してフィルターを設定できます。 | true | boolean |
fileName (consumer) | 指定のファイル名を持つバケットからオブジェクトを取得します。 | 文字列 | |
includeBody (consumer) | true の場合、エクスチェンジボディーはファイルの内容へのストリームに設定されます。false の場合、ヘッダーは S3 オブジェクトメタデータで設定されますが、ボディーは null になります。このオプションは、autocloseBody オプションと密接に関係します。includeBody を true に設定し、autocloseBody を false に設定すると、S3Object ストリームを閉じるのは呼び出し元によって異なります。autocloseBody を true に設定すると、S3Object ストリームが自動的に閉じられます。 | true | boolean |
maxConnections (コンシューマー) | S3 クライアント設定の maxConnections パラメーターを設定します。 | 60 | int |
maxMessagesPerPoll (consumer) | 各ポーリングのポーリング制限としてメッセージの最大数を取得します。デフォルトは無制限ですが、0 または負の値を使用して無制限として無効にします。 | 10 | int |
prefix (consumer) | 対象のオブジェクトのみを消費するために com.amazonaws.services.s3.model.ListObjectsRequest で使用されるプレフィックス。 | 文字列 | |
sendEmptyMessageWhenIdle (consumer) | ポーリングコンシューマーがファイルをポーリングしなかった場合、このオプションを有効にして、代わりに空のメッセージ (ボディーなし) を送信できます。 | false | boolean |
autocloseBody (コンシューマー) | このオプションが true で includeBody が true の場合、エクスチェンジの完了時に S3Object.close()メソッドが呼び出されます。このオプションは includeBody オプションと密接に関係しています。includeBody を true に設定し、autocloseBody を false に設定すると、S3Object ストリームを閉じるのは呼び出し元によって異なります。autocloseBody を true に設定すると、S3Object ストリームが自動的に閉じられます。 | true | boolean |
exceptionHandler (consumer) | コンシューマーによるカスタム ExceptionHandler の使用を許可します。bridgeErrorHandler オプションが有効な場合は、このオプションは使用されていないことに注意してください。デフォルトでは、コンシューマーは例外に対応し、WARN または ERROR レベルでログに記録され、無視されます。 | ExceptionHandler | |
exchangePattern (consumer) | コンシューマーがエクスチェンジを作成する際に交換パターンを設定します。 | ExchangePattern | |
pollStrategy (consumer) | プラグ可能な org.apache.camel.PollingConsumerPollingStrategy を使用すると、エクスチェンジが作成され、Camel でルーティングされる前に、通常はポーリング操作中に発生するエラー処理を制御するカスタム実装が提供できます。 | PollingConsumerPoll Strategy | |
deleteAfterWrite (producer) | S3 ファイルのアップロード後にファイルオブジェクトを削除します。 | false | boolean |
multiPartUpload (producer) | true の場合、Camel はマルチパート形式のファイルをアップロードし、パートサイズは partSize のオプションによって決定されます。 | false | boolean |
操作 (プロデューサー) | ユーザーがアップロードのみを実行したくない場合に実行する操作 | S3Operations | |
partSize (producer) | マルチパートのアップロードで使用される partSize を設定します。デフォルトのサイズは 25M です。 | 26214400 | Long |
serverSideEncryption (producer) | AWS 管理のキーを使用してオブジェクトを暗号化する際にサーバー側の暗号化アルゴリズムを設定します。たとえば、AES256 を使用します。 | 文字列 | |
storageClass (producer) | com.amazonaws.services.s3.model.PutObjectRequest リクエストに設定するストレージクラス。 | 文字列 | |
awsKMSKeyId (producer) | KMS が有効になっている場合に使用する KMS キーの ID を定義します。 | 文字列 | |
useAwsKMS (producer) | KMS を使用する必要があるかどうかを定義します。 | false | boolean |
同期 (詳細) | 同期処理を厳密に使用するか、Camel が非同期処理を使用できるようにするかを設定します(サポートされている場合)。 | false | boolean |
accelerateModeEnabled ( advanced) | Accelerate モードが true または false かどうかを定義します。 | false | boolean |
chunkedEncodingDisabled ( advanced) | 無効な Chunked Encoding が true または false になるかどうかを定義します。 | false | boolean |
dualstackEnabled ( advanced) | Dualstack が有効かどうかを定義します。 | false | boolean |
forceGlobalBucketAccess Enabled ( advanced) | 強制グローバルバケットアクセスが true または false であるかどうかを定義します。 | false | boolean |
payloadSigningEnabled ( advanced) | Payload 署名が有効かどうかを定義します。true または false | false | boolean |
backoffErrorThreshold (scheduler) | backoffMultipler が開始する前に発生する必要がある後続のエラーポーリング (エラーによって失敗した) の数。 | int | |
backoffIdleThreshold (scheduler) | backoffMultipler が開始する前に発生する必要がある後続のアイドルポーリングの数。 | int | |
backoffMultiplier (scheduler) | 後続のアイドル状態/エラーが連続して発生した場合に、スケジュールされたポーリングコンシューマーのバックオフを許可します。乗数は、実際に次の試行が行われる前にスキップされるポーリングの数です。このオプションが使用されている場合は、backoffIdleThreshold や backoffErrorThreshold も設定する必要があります。 | int | |
遅延 (スケジューラー) | 次のポーリングまでの時間 (ミリ秒単位)。また、60 秒(60 秒)、5m30s(5 分と 30 秒)、および 1h(1 時間)などの単位を使用して時間の値を指定することもできます。 | 500 | Long |
greedy (scheduler) | greedy が有効で、以前の実行が 1 つ以上のメッセージをポーリングした場合、ScheduledPollConsumer は即座に再度実行されます。 | false | boolean |
initialDelay (scheduler) | 最初のポーリングが開始されるまでの時間 (ミリ秒単位)。また、60 秒(60 秒)、5m30s(5 分と 30 秒)、および 1h(1 時間)などの単位を使用して時間の値を指定することもできます。 | 1000 | Long |
runLoggingLevel (scheduler) | コンシューマーはポーリング時に開始/完了のログ行を記録します。このオプションを使用すると、ログレベルを設定できます。 | TRACE | LoggingLevel |
scheduledExecutorService (scheduler) | コンシューマーに使用するカスタム/共有スレッドプールを設定できます。デフォルトでは、各コンシューマーに独自の単一スレッドのスレッドプールがあります。 | ScheduledExecutor Service | |
scheduler (scheduler) | camel-spring または camel-quartz2 コンポーネントからの cron スケジューラーを使用するには、以下を実行します。 | none | ScheduledPollConsumer Scheduler |
schedulerProperties (scheduler) | カスタムスケジューラーまたは Quartz2、Spring ベースのスケジューラーを使用する場合に追加のプロパティーを設定します。 | マップ | |
startScheduler (scheduler) | スケジューラーを自動起動するかどうか。 | true | boolean |
timeUnit (scheduler) | initialDelay および delay オプションの時間単位。 | ミリ秒 | TimeUnit |
useFixedDelay (scheduler) | 固定遅延または固定レートを使用するかどうかを制御します。詳細は、JDK の ScheduledExecutorService を参照してください。 | true | boolean |
accessKey (security) | Amazon AWS Access Key | 文字列 | |
secretKey (security) | Amazon AWS Secret Key | 文字列 |
必要な S3 コンポーネントオプション
Amazon の S3Client にアクセスするためにレジストリーまたは accessKey および secretKey で amazonS3Client を提供する必要が あります。