5.5. Azure
5.5.1. camel-azure-storage-blob-kafka-connector シンク設定
コネクターの説明: SDK v12 を使用して、Azure Storage Blob Service から BLOB を保存および取得します。
camel-azure-storage-blob-kafka-connector をシンクとして使用する場合は、次の Maven 依存関係を使用してコネクターをサポートしてください。
<dependency>
<groupId>org.apache.camel.kafkaconnector</groupId>
<artifactId>camel-azure-storage-blob-kafka-connector</artifactId>
<version>x.x.x</version>
<!-- use the same version as your Camel Kafka connector version -->
</dependency>Kafka コネクションでこのシンクコネクターを使用するには、以下の connector.class を設定する必要があります。
connector.class=org.apache.camel.kafkaconnector.azurestorageblob.CamelAzurestorageblobSinkConnectorcamel-azure-storage-blob シンクコネクターは、以下に示す 55 のオプションをサポートしています。
| 名前 | 説明 | デフォルト | 必要性 | 優先順位 |
|---|---|---|---|---|
| camel.sink.path.accountName | Azure BLOB サービスでの認証に使用される Azure アカウント名。 | null | false | MEDIUM |
| camel.sink.path.containerName | BLOB コンテナー名。 | null | false | MEDIUM |
| camel.sink.endpoint.autoDiscoverClient | autoDiscoverClient メカニズムを設定すると、true の場合、コンポーネントはレジストリー内のクライアントインスタンスを自動的に探します。それ以外の場合は、そのチェックをスキップします。 | true | false | MEDIUM |
| camel.sink.endpoint.blobName | コンテナーから特定の BLOB を使用するための BLOB 名。ただし、プロデューサーでは、BLOB レベルでの操作にのみ必要です。 | null | false | MEDIUM |
| camel.sink.endpoint.blobOffset | アップロードまたはダウンロード操作の BLOB オフセットを設定します。デフォルトは 0 です。 | 0L | false | MEDIUM |
| camel.sink.endpoint.blobServiceClient | ストレージアカウントへのクライアント。このクライアントは、特定のストレージアカウントに関する状態を保持しませんが、サービス上のリソースに適切な要求を送信する便利な方法です。また、BLOB およびコンテナーへの URL を作成するために使用することもできます。このクライアントには、サービスアカウントに対する操作が含まれています。コンテナーに対する操作は、BlobServiceClient#getBlobContainerClient(String) を介して BlobContainerClient で利用でき、ブロブに対する操作は、getBlobContainerClient(String).getBlobClient(String) を介して BlobClient で利用できます。 | null | false | MEDIUM |
| camel.sink.endpoint.blobType | 各 BLOB タイプの適切な設定を開始するための BLOB タイプ [blockblob] [appendblob] [pageblob] のいずれか | "blockblob" | false | MEDIUM |
| camel.sink.endpoint.closeStreamAfterRead | 読み取り後にストリームを閉じるか、開いたままにします。デフォルトは true です。 | true | false | MEDIUM |
| camel.sink.endpoint.credentials | StorageSharedKeyCredential を挿入して Azure クライアントを作成できます。これには重要な認証情報が保持されます。 | null | false | MEDIUM |
| camel.sink.endpoint.dataCount | 範囲に含めるバイト数。指定する場合は、0 以上である必要があります。 | null | false | MEDIUM |
| camel.sink.endpoint.fileDir | ダウンロードされた BLOB が保存されるファイルディレクトリー。これはプロデューサーとコンシューマーの両方で使用できます。 | null | false | MEDIUM |
| camel.sink.endpoint.maxResultsPerPage | すべての BlobPrefix 要素を含め、返される BLOB の最大数を指定します。要求で maxResultsPerPage が指定されていないか、5,000 を超える値が指定されている場合、サーバーは最大 5,000 項目を返します。 | null | false | MEDIUM |
| camel.sink.endpoint.maxRetryRequests | レスポンスのボディーからデータを読み取るときに作成される追加の HTTP Get 要求の最大数を指定します。 | 0 | false | MEDIUM |
| camel.sink.endpoint.prefix | 結果をフィルター処理して、名前が指定された接頭辞で始まる BLOB のみを返します。すべての BLOB を返すには null の場合があります。 | null | false | MEDIUM |
| camel.sink.endpoint.regex | 結果をフィルタリングして、指定された正規表現と名前が一致する BLOB のみを返します。接頭辞と正規表現の両方が設定されている場合は、すべてを返すために null になる場合があります。正規表現が優先され、接頭辞は無視されます。 | null | false | MEDIUM |
| camel.sink.endpoint.serviceClient | ストレージアカウントへのクライアント。このクライアントは、特定のストレージアカウントに関する状態を保持しませんが、サービス上のリソースに適切な要求を送信する便利な方法です。また、BLOB およびコンテナーへの URL を作成するために使用することもできます。このクライアントには、サービスアカウントに対する操作が含まれています。コンテナーに対する操作は、BlobServiceClient#getBlobContainerClient(String) を介して BlobContainerClient で利用でき、ブロブに対する操作は、BlobContainerClient#getBlobClient(String) を介して BlobClient で利用できます。 | null | false | MEDIUM |
| camel.sink.endpoint.timeout | それを超えると RuntimeException が発生する任意のタイムアウト値。 | null | false | MEDIUM |
| camel.sink.endpoint.blobSequenceNumber | リクエストの追跡に使用できるユーザー制御の値。シーケンス番号の値は、0 から 263 - 1 の間でなければなりません。デフォルト値は 0 です。 | "0" | false | MEDIUM |
| camel.sink.endpoint.blockListType | 返すブロックのタイプを指定します。次のいずれか: [committed] [uncommitted] [all] | COMMITTED | false | MEDIUM |
| camel.sink.endpoint.closeStreamAfterWrite | 書き込み後にストリームを閉じるか、開いたままにします。デフォルトは true です。 | true | false | MEDIUM |
| camel.sink.endpoint.commitBlockListLater | true に設定されていると、ステージングされたブロックは直接コミットされません。 | true | false | MEDIUM |
| camel.sink.endpoint.createAppendBlob | true に設定されていると、追加ブロックのコミット時に追加ブロックが作成されます。 | true | false | MEDIUM |
| camel.sink.endpoint.createPageBlob | true に設定すると、ページブロブのアップロード時にページ Blob が作成されます。 | true | false | MEDIUM |
| camel.sink.endpoint.downloadLinkExpiration | URL ダウンロードリンクのデフォルトの有効期限 (ミリ秒) をオーバーライドします。 | null | false | MEDIUM |
| camel.sink.endpoint.lazyStartProducer | 最初のメッセージでプロデューサーをレイジーに起動すべきかどうか。レイジーに起動することで、起動時にプロデューサーが失敗し、それによりルートが失敗する可能性がある状況で、CamelContext およびルートの起動を許可します。レイジーな起動を延期すると、Camel のルーティングエラーハンドラー経由でメッセージのルーティング中に起動の失敗を処理できます。最初のメッセージが処理されるときに、プロデューサーの作成および起動に若干時間がかかり、合計処理時間が長くなる可能性があることに注意してください。 | false | false | MEDIUM |
| camel.sink.endpoint.operation | プロデューサのこのコンポーネントで使用できる blob 操作。次のいずれか [listBlobContainers] [createBlobContainer] [deleteBlobContainer] [listBlobs] [getBlob] [deleteBlob] [downloadBlobToFile] [downloadLink] [uploadBlockBlob] [stageBlockBlobList] [commitBlobBlockList] [getBlobBlockList] [createAppendBlob] [commitAppendBlob] [createPageBlob] [uploadPageBlob] [resizePageBlob] [clearPageBlob] [getPageBlobRanges] | "listBlobContainers" | false | MEDIUM |
| camel.sink.endpoint.pageBlobSize | ページ BLOB の最大サイズを 8 TB まで指定します。ページ BLOB のサイズは、512 バイトの境界に合わせる必要があります。 | "512" | false | MEDIUM |
| camel.sink.endpoint.accessKey | Azure Blob サービスでの認証に使用される、関連付けられた Azure アカウント名のアクセスキー。 | null | false | MEDIUM |
| camel.component.azure-storage-blob.autoDiscover Client | autoDiscoverClient メカニズムを設定すると、true の場合、コンポーネントはレジストリー内のクライアントインスタンスを自動的に探します。それ以外の場合は、そのチェックをスキップします。 | true | false | MEDIUM |
| camel.component.azure-storage-blob.blobName | コンテナーから特定の BLOB を使用するための BLOB 名。ただし、プロデューサーでは、BLOB レベルでの操作にのみ必要です。 | null | false | MEDIUM |
| camel.component.azure-storage-blob.blobOffset | アップロードまたはダウンロード操作の BLOB オフセットを設定します。デフォルトは 0 です。 | 0L | false | MEDIUM |
| camel.component.azure-storage-blob.blobType | 各 BLOB タイプの適切な設定を開始するための BLOB タイプ [blockblob] [appendblob] [pageblob] のいずれか | "blockblob" | false | MEDIUM |
| camel.component.azure-storage-blob.closeStream AfterRead | 読み取り後にストリームを閉じるか、開いたままにします。デフォルトは true です。 | true | false | MEDIUM |
| camel.component.azure-storage-blob.configuration | コンポーネントの設定。 | null | false | MEDIUM |
| camel.component.azure-storage-blob.credentials | StorageSharedKeyCredential を挿入して Azure クライアントを作成できます。これには重要な認証情報が保持されます。 | null | false | MEDIUM |
| camel.component.azure-storage-blob.dataCount | 範囲に含めるバイト数。指定する場合は、0 以上である必要があります。 | null | false | MEDIUM |
| camel.component.azure-storage-blob.fileDir | ダウンロードされた BLOB が保存されるファイルディレクトリー。これはプロデューサーとコンシューマーの両方で使用できます。 | null | false | MEDIUM |
| camel.component.azure-storage-blob.maxResultsPer Page | すべての BlobPrefix 要素を含め、返される BLOB の最大数を指定します。要求で maxResultsPerPage が指定されていないか、5,000 を超える値が指定されている場合、サーバーは最大 5,000 項目を返します。 | null | false | MEDIUM |
| camel.component.azure-storage-blob.maxRetry Requests | レスポンスのボディーからデータを読み取るときに作成される追加の HTTP Get 要求の最大数を指定します。 | 0 | false | MEDIUM |
| camel.component.azure-storage-blob.prefix | 結果をフィルター処理して、名前が指定された接頭辞で始まる BLOB のみを返します。すべての BLOB を返すには null の場合があります。 | null | false | MEDIUM |
| camel.component.azure-storage-blob.regex | 結果をフィルタリングして、指定された正規表現と名前が一致する BLOB のみを返します。接頭辞と正規表現の両方が設定されている場合は、すべてを返すために null になる場合があります。正規表現が優先され、接頭辞は無視されます。 | null | false | MEDIUM |
| camel.component.azure-storage-blob.serviceClient | ストレージアカウントへのクライアント。このクライアントは、特定のストレージアカウントに関する状態を保持しませんが、サービス上のリソースに適切な要求を送信する便利な方法です。また、BLOB およびコンテナーへの URL を作成するために使用することもできます。このクライアントには、サービスアカウントに対する操作が含まれています。コンテナーに対する操作は、BlobServiceClient#getBlobContainerClient(String) を介して BlobContainerClient で利用でき、ブロブに対する操作は、BlobContainerClient#getBlobClient(String) を介して BlobClient で利用できます。 | null | false | MEDIUM |
| camel.component.azure-storage-blob.timeout | それを超えると RuntimeException が発生する任意のタイムアウト値。 | null | false | MEDIUM |
| camel.component.azure-storage-blob.blobSequence Number | リクエストの追跡に使用できるユーザー制御の値。シーケンス番号の値は、0 から 263 - 1 の間でなければなりません。デフォルト値は 0 です。 | "0" | false | MEDIUM |
| camel.component.azure-storage-blob.blockListType | 返すブロックのタイプを指定します。次のいずれか: [committed] [uncommitted] [all] | COMMITTED | false | MEDIUM |
| camel.component.azure-storage-blob.closeStream AfterWrite | 書き込み後にストリームを閉じるか、開いたままにします。デフォルトは true です。 | true | false | MEDIUM |
| camel.component.azure-storage-blob.commitBlockList Later | true に設定されていると、ステージングされたブロックは直接コミットされません。 | true | false | MEDIUM |
| camel.component.azure-storage-blob.createAppend Blob | true に設定されていると、追加ブロックのコミット時に追加ブロックが作成されます。 | true | false | MEDIUM |
| camel.component.azure-storage-blob.createPageBlob | true に設定すると、ページブロブのアップロード時にページ Blob が作成されます。 | true | false | MEDIUM |
| camel.component.azure-storage-blob.downloadLink Expiration | URL ダウンロードリンクのデフォルトの有効期限 (ミリ秒) をオーバーライドします。 | null | false | MEDIUM |
| camel.component.azure-storage-blob.lazyStart Producer | 最初のメッセージでプロデューサーをレイジーに起動すべきかどうか。レイジーに起動することで、起動時にプロデューサーが失敗し、それによりルートが失敗する可能性がある状況で、CamelContext およびルートの起動を許可します。レイジーな起動を延期すると、Camel のルーティングエラーハンドラー経由でメッセージのルーティング中に起動の失敗を処理できます。最初のメッセージが処理されるときに、プロデューサーの作成および起動に若干時間がかかり、合計処理時間が長くなる可能性があることに注意してください。 | false | false | MEDIUM |
| camel.component.azure-storage-blob.operation | プロデューサのこのコンポーネントで使用できる blob 操作。次のいずれか [listBlobContainers] [createBlobContainer] [deleteBlobContainer] [listBlobs] [getBlob] [deleteBlob] [downloadBlobToFile] [downloadLink] [uploadBlockBlob] [stageBlockBlobList] [commitBlobBlockList] [getBlobBlockList] [createAppendBlob] [commitAppendBlob] [createPageBlob] [uploadPageBlob] [resizePageBlob] [clearPageBlob] [getPageBlobRanges] | "listBlobContainers" | false | MEDIUM |
| camel.component.azure-storage-blob.pageBlobSize | ページ BLOB の最大サイズを 8 TB まで指定します。ページ BLOB のサイズは、512 バイトの境界に合わせる必要があります。 | "512" | false | MEDIUM |
| camel.component.azure-storage-blob.autowired Enabled | 自動ワイヤリングが有効になっているかどうか。これは、コンポーネントで設定される一致するタイプのインスタンスが 1 つあるかどうかを検出するためにレジストリーを検索することで、自動ワイアリングオプションに使用されます (オプションは自動ワイアとマーク付けされる必要があります)。これは、JDBC データソース、JMS 接続ファクトリー、AWS クライアントなどの自動設定に使用できます。 | true | false | MEDIUM |
| camel.component.azure-storage-blob.accessKey | Azure Blob サービスでの認証に使用される、関連付けられた Azure アカウント名のアクセスキー。 | null | false | MEDIUM |
camel-azure-storage-blob シンクコネクターには、すぐに使えるコンバーターはありません。
camel-azure-storage-blob シンクコネクターには、すぐに使える変換はありません。
camel-azure-storage-blob シンクコネクターには、すぐに使用できる集約ストラテジーはありません。
'%20d='M201.5%20305.5c-13.8%200-24.9-11.1-24.9-24.6%200-13.8%2011.1-24.9%2024.9-24.9%2013.6%200%2024.6%2011.1%2024.6%2024.9%200%2013.6-11.1%2024.6-24.6%2024.6zM504%20256c0%20137-111%20248-248%20248S8%20393%208%20256%20119%208%20256%208s248%20111%20248%20248zm-132.3-41.2c-9.4%200-17.7%203.9-23.8%2010-22.4-15.5-52.6-25.5-86.1-26.6l17.4-78.3%2055.4%2012.5c0%2013.6%2011.1%2024.6%2024.6%2024.6%2013.8%200%2024.9-11.3%2024.9-24.9s-11.1-24.9-24.9-24.9c-9.7%200-18%205.8-22.1%2013.8l-61.2-13.6c-3-.8-6.1%201.4-6.9%204.4l-19.1%2086.4c-33.2%201.4-63.1%2011.3-85.5%2026.8-6.1-6.4-14.7-10.2-24.1-10.2-34.9%200-46.3%2046.9-14.4%2062.8-1.1%205-1.7%2010.2-1.7%2015.5%200%2052.6%2059.2%2095.2%20132%2095.2%2073.1%200%20132.3-42.6%20132.3-95.2%200-5.3-.6-10.8-1.9-15.8%2031.3-16%2019.8-62.5-14.9-62.5zM302.8%20331c-18.2%2018.2-76.1%2017.9-93.6%200-2.2-2.2-6.1-2.2-8.3%200-2.5%202.5-2.5%206.4%200%208.6%2022.8%2022.8%2087.3%2022.8%20110.2%200%202.5-2.2%202.5-6.1%200-8.6-2.2-2.2-6.1-2.2-8.3%200zm7.7-75c-13.6%200-24.6%2011.1-24.6%2024.9%200%2013.6%2011.1%2024.6%2024.6%2024.6%2013.8%200%2024.9-11.1%2024.9-24.6%200-13.8-11-24.9-24.9-24.9z'/%3e%3c/svg%3e){kind=small}