This feature is available with Conduktor Scale Plus only.
- Amazon S3 (Amazon Simple Storage Service) is a service offered by AWS (Amazon Web Services) that provides object storage through a web service interface.
- Azure Blob Storage is a service offered by Microsoft Azure that provides blob storage.
Configuration
Key | Type | Default | Description |
---|---|---|---|
topic | String | .* | Topics that match this regex will have the Interceptor applied |
s3Config | S3 | Amazon S3 configuration | |
azureConfig | Azure | Azure Blob Storage configuration | |
minimumSizeInBytes | int | Only upload to S3 if batch/message record has size greater than or equal to this minimumSizeInBytes | |
localDiskDirectory | string | Local temp storage, used when we download file from S3 while fetching messages |
Amazon S3
The S3 credentials default to managed identity. They will be overwritten if a specificbasic credentials
(accessKey
and secretKey
) or session credentials
(accessKey
, secretKey
and sessionToken
) are configured.
Key | Type | Description |
---|---|---|
accessKey | string | S3 access key |
secretKey | string | S3 secret key |
sessionToken | string | S3 session token |
bucketName | string | S3 bucket name |
uri | string | S3 URI |
region | string | S3 region |
Azure Blob Storage
Note that your application will require at least Storage Blob Data Contributor permissions to be able to read/write the data.Key | Type | Description |
---|---|---|
tenantId | string | Azure tenant ID |
clientId | string | Azure client ID |
secret | string | Azure client secret |
blobEndpoint | string | Azure Blob Storage endpoint to use |
bucketName | string | Bucket (container) name in Blob Storage configured to store in |
Examples
Large batches
Each batch that’s above theminimumSizeInBytes
threshold will be saved in one file on Amazon S3, with credentials defaulting to managed identity:
basic credentials
:
session credentials
:
Large messages
Each individual message that’s above theminimumSizeInBytes
threshold will be saved in one file on Amazon S3, with credentials defaulting to managed identity:
basic credentials
:
sessionCredentials
: