Blob Herese Azure ⇐ JAVA

[Anonymous]

Я использую приведенный ниже код для генерации Bytestream из Sasurl of Azure Storage < /p>
ConnectionProvider connectionProvider =
ConnectionProvider.builder("custom-connection-provider")
.maxConnections(200)
.pendingAcquireMaxCount(5000)
.build();

BlobClient blobClient = new BlobClientBuilder()
.endpoint(searchMultipleWrapper.getSasUrl().trim()) // IT IS MY VALID SAS URL
.httpClient(new NettyAsyncHttpClientBuilder()
.connectionProvider(connectionProvider)
.readTimeout(Duration.ofMinutes(10))
.writeTimeout(Duration.ofMinutes(10))
.responseTimeout(Duration.ofMinutes(10))
.build())
.retryOptions(new RequestRetryOptions(
RetryPolicyType.EXPONENTIAL,
5,
2,
null,
null,
null
))
.buildClient();

log.info("BlobClient Object check {} ", blobClient);

// Use try-with-resources to ensure InputStream is closed
try (InputStream inputStream = blobClient.openInputStream();
ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream()) {

// Transfer data from InputStream to ByteArrayOutputStream
inputStream.transferTo(byteArrayOutputStream);

// Convert to Base64
byte[] imageBytes = byteArrayOutputStream.toByteArray();
String base64Image = Base64.getEncoder().encodeToString(imageBytes);

log.info("Base 64 : {} ", base64Image);

// Log the Base64 string (truncated for safety)
log.info("Base64 Image (truncated): " + base64Image.substring(0, Math.min(base64Image.length(), 100)) + "...");
} catch (Exception e) {
log.error("Error while processing blob content", e);

}

< /code>
Исключение, которое я получаю, как ниже:-< /p>

stack_trace":"Reactor.core.exceptions $ reactiveexception:
io.netty.channel.stacklessClosedChannelException \TAT
Heading ## recector.core.exceptions.propagate (exceptions.java:410) \ n \ tat < /h2 >
reactor.core.publisher.blocksinglesubscriber.blockget(blocksinglesubscriber.java:102)\n\tat
Reactor.core.publisher.mono.block(mono.java:1779)\n \ tat
comm.azure.storage.blob.specialized.blobclientbase.openinputstream(blobclientbase.java:393)\n\tat
com.azure.storage.blob.specialized.blobclientbase.openinpteream. java: 323) \ n \ tat
comm.azure.storage.blob.specialized.blobclientbase.openinputstream(blobclientbase.java:312)\n\tat
com.azure.storage.blob.specialized. Blobclientbase.openinputstream (blobclientbase.java:299) \ n < /p>
< /blockquote>
Я думаю, что это проблема об управлении версией, которая имеет ошибку в системе окон. Пожалуйста, проверьте ссылку на это
нажмите здесь < /p>
Пожалуйста, помогите мне выйти из этой проблемы < /p>

Подробнее здесь: https://stackoverflow.com/questions/793 ... lexception