Configurer le client asynchrone S3 basé sur Java pour utiliser les transferts parallèles

Depuis la version 2.27.5, le client asynchrone S3 standard basé sur Java prend en charge les transferts parallèles automatiques (chargements partitionnés et téléchargements). Vous configurez la prise en charge des transferts parallèles lorsque vous créez le client asynchrone S3 basé sur Java.

Cette section explique comment activer les transferts parallèles et comment personnaliser la configuration.

Créez une instance de S3AsyncClient

Lorsque vous créez une S3AsyncClient instance sans appeler aucune des multipart* méthodes du générateur, les transferts parallèles ne sont pas activés. Chacune des instructions suivantes crée un client asynchrone S3 basé sur Java sans prise en charge des chargements partitionnés et des téléchargements.

Créez sans support en plusieurs parties

import software.amazon.awssdk.auth.credentials.ProcessCredentialsProvider;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.s3.S3AsyncClient;


S3AsyncClient s3Client = S3AsyncClient.create();

S3AsyncClient s3Client2 = S3AsyncClient.builder().build();

S3AsyncClient s3Client3 = S3AsyncClient.builder()
        .credentialsProvider(ProcessCredentialsProvider.builder().build())
        .region(Region.EU_NORTH_1)
        .build();

Créez avec un support en plusieurs parties

Pour activer les transferts parallèles avec les paramètres par défaut, appelez multipartEnabled le générateur et true transmettez-le comme indiqué dans l'exemple suivant.

S3AsyncClient s3AsyncClient2 = S3AsyncClient.builder()
        .multipartEnabled(true)
        .build();

La valeur par défaut est de 8 MiB pour les paramètres thresholdInBytes etminimumPartSizeInBytes.

Si vous personnalisez les paramètres partitionnés, les transferts parallèles sont automatiquement activés comme indiqué ci-dessous.

import software.amazon.awssdk.services.s3.S3AsyncClient;
import static software.amazon.awssdk.transfer.s3.SizeConstant.MB;


S3AsyncClient s3AsyncClient2 = S3AsyncClient.builder()
        .multipartConfiguration(b -> b
                .thresholdInBytes(16 * MB)
                .minimumPartSizeInBytes(10 * MB))
        .build();