An error related to content-length occurs while uploading an image file to AWS S3 Bucket in Spring webflux.

[ke2007]

Problem

• hi Nice to meet you ,
• I apologize for using a translator.
• I really want to solve this problem
• An error related to content-length occurs while uploading an image file to AWS S3 Bucket in Spring webflux.

background

• I tried to upload image to aws s3 using spring webflux.
• In my code "No content length specified for stream data. Stream contents will be buffered in memory and could result in out of memory errors." has occurred
• So, I specified the contentLength of FilePart in metadata. [ "file.headers().getContentLength() " 1-1]
• this is the code

@Service
@RequiredArgsConstructor
@Slf4j
public class AwsS3Service {
    private final AmazonS3Client amazonS3Client;
    @Value("${aws.S3.bucket}")
    private String bucketName;

    public String StoreImage(FilePart file) {
        //validate Exists file
        validateFileExists(file);
        //create uuid name
        String fileName = createFileName(file.filename());

        ObjectMetadata metadata = new ObjectMetadata();
        metadata.setContentType(String.valueOf(file.headers().getContentType()));
        metadata.setContentLength(file.headers().getContentLength()); //   " I specified the contentLength "

        file.content().map(DataBuffer::asInputStream).map(inputStream -> {
            log.info("transfer start");
            log.info("contents  length: {}", metadata.getContentLength());

            return amazonS3Client.putObject(new PutObjectRequest(bucketName, fileName, inputStream, metadata)
                    .withCannedAcl(CannedAccessControlList.PublicRead));
        }).subscribe();

        //return s3object url
        return amazonS3Client.getUrl(bucketName, fileName).toString();

    }

• However, the log result of getContentLength() in the FilePart class is '-1'.
• this is the result
  
• and error console

reactor.core.Exceptions$ErrorCallbackNotImplemented: com.amazonaws.services.s3.model.AmazonS3Exception: The request signature we calculated does not match the signature you provided. Check your key and signing method. (Service: Amazon S3; Status Code: 403; Error Code: SignatureDoesNotMatch; Request ID: YRCSMZ7Q18TF3H28; S3 Extended Request ID: ha6p1admq3OnBTaIKSnrCgBdwZVKMFVueH3Fd8JvxVMlrkMGGeTh+4l/i1QcG424Ik42gqPzm+QFc9zYZZn6Qw==; Proxy: null), S3 Extended Request ID: ha6p1admq3OnBTaIKSnrCgBdwZVKMFVueH3Fd8JvxVMlrkMGGeTh+4l/i1QcG424Ik42gqPzm+QFc9zYZZn6Qw==
Caused by: com.amazonaws.services.s3.model.AmazonS3Exception: The request signature we calculated does not match the signature you provided. Check your key and signing method. (Service: Amazon S3; Status Code: 403; Error Code: SignatureDoesNotMatch; Request ID: YRCSMZ7Q18TF3H28; S3 Extended Request ID: ha6p1admq3OnBTaIKSnrCgBdwZVKMFVueH3Fd8JvxVMlrkMGGeTh+4l/i1QcG424Ik42gqPzm+QFc9zYZZn6Qw==; Proxy: null)
	at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleErrorResponse(AmazonHttpClient.java:1879) ~[aws-java-sdk-core-1.12.386.jar:na]
	at com.amazonaws.http.AmazonHttpClient$RequestExecutor.handleServiceErrorResponse(AmazonHttpClient.java:1418) ~[aws-java-sdk-core-1.12.386.jar:na]
	at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeOneRequest(AmazonHttpClient.java:1387) ~[aws-java-sdk-core-1.12.386.jar:na]
	at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeHelper(AmazonHttpClient.java:1157) ~[aws-java-sdk-core-1.12.386.jar:na]
	at com.amazonaws.http.AmazonHttpClient$RequestExecutor.doExecute(AmazonHttpClient.java:814) ~[aws-java-sdk-core-1.12.386.jar:na]
	at com.amazonaws.http.AmazonHttpClient$RequestExecutor.executeWithTimer(AmazonHttpClient.java:781) ~[aws-java-sdk-core-1.12.386.jar:na]
	at com.amazonaws.http.AmazonHttpClient$RequestExecutor.execute(AmazonHttpClient.java:755) ~[aws-java-sdk-core-1.12.386.jar:na]
	at com.amazonaws.http.AmazonHttpClient$RequestExecutor.access$500(AmazonHttpClient.java:715) ~[aws-java-sdk-core-1.12.386.jar:na]
	at com.amazonaws.http.AmazonHttpClient$RequestExecutionBuilderImpl.execute(AmazonHttpClient.java:697) ~[aws-java-sdk-core-1.12.386.jar:na]
	at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:561) ~[aws-java-sdk-core-1.12.386.jar:na]
	at com.amazonaws.http.AmazonHttpClient.execute(AmazonHttpClient.java:541) ~[aws-java-sdk-core-1.12.386.jar:na]
	at com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:5456) ~[aws-java-sdk-s3-1.12.386.jar:na]
	at com.amazonaws.services.s3.AmazonS3Client.invoke(AmazonS3Client.java:5403) ~[aws-java-sdk-s3-1.12.386.jar:na]
	at com.amazonaws.services.s3.AmazonS3Client.access$300(AmazonS3Client.java:421) ~[aws-java-sdk-s3-1.12.386.jar:na]
	at com.amazonaws.services.s3.AmazonS3Client$PutObjectStrategy.invokeServiceCall(AmazonS3Client.java:6532) ~[aws-java-sdk-s3-1.12.386.jar:na]
	at com.amazonaws.services.s3.AmazonS3Client.uploadObject(AmazonS3Client.java:1861) ~[aws-java-sdk-s3-1.12.386.jar:na]
	at com.amazonaws.services.s3.AmazonS3Client.putObject(AmazonS3Client.java:1821) ~[aws-java-sdk-s3-1.12.386.jar:na]
	at com.example.webflux_demo.post.post_file.AwsS3Service.lambda$StoreImage$0(AwsS3Service.java:53) ~[main/:na]
	at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:106) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.publisher.FluxSubscribeOn$SubscribeOnSubscriber.onNext(FluxSubscribeOn.java:151) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.publisher.FluxUsing$UsingFuseableSubscriber.onNext(FluxUsing.java:353) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.publisher.FluxGenerate$GenerateSubscription.next(FluxGenerate.java:178) ~[reactor-core-3.5.1.jar:3.5.1]
	at org.springframework.core.io.buffer.DataBufferUtils$ReadableByteChannelGenerator.accept(DataBufferUtils.java:916) ~[spring-core-6.0.3.jar:6.0.3]
	at org.springframework.core.io.buffer.DataBufferUtils$ReadableByteChannelGenerator.accept(DataBufferUtils.java:891) ~[spring-core-6.0.3.jar:6.0.3]
	at reactor.core.publisher.FluxGenerate.lambda$new$1(FluxGenerate.java:58) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.publisher.FluxGenerate$GenerateSubscription.fastPath(FluxGenerate.java:232) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.publisher.FluxGenerate$GenerateSubscription.request(FluxGenerate.java:211) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.publisher.FluxUsing$UsingFuseableSubscriber.request(FluxUsing.java:320) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.publisher.FluxSubscribeOn$SubscribeOnSubscriber.requestUpstream(FluxSubscribeOn.java:131) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.publisher.FluxSubscribeOn$SubscribeOnSubscriber.onSubscribe(FluxSubscribeOn.java:124) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.publisher.FluxUsing$UsingFuseableSubscriber.onSubscribe(FluxUsing.java:347) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.publisher.FluxGenerate.subscribe(FluxGenerate.java:85) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.publisher.FluxUsing.subscribe(FluxUsing.java:102) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.publisher.FluxSubscribeOn$SubscribeOnSubscriber.run(FluxSubscribeOn.java:194) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:84) ~[reactor-core-3.5.1.jar:3.5.1]
	at reactor.core.scheduler.WorkerTask.call(WorkerTask.java:37) ~[reactor-core-3.5.1.jar:3.5.1]
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[na:na]
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304) ~[na:na]
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[na:na]
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[na:na]
	at java.base/java.lang.Thread.run(Thread.java:833) ~[na:na]

• Why "The request signature we calculated does not match the signature you provided." does it happen
• what should i do ? ?. I've been debugging this for 8 hours.
• please help me..🙏

-How can I specify the proper content-length in the FilePart?