Obtenga valores de Azure Blob Storage Java usando Proxy

Puedo conectarme a Azure Blob Storage con Proxy. Ahora quiero leer todas las imágenes del almacenamiento de blobs de Azure.

            // ConnectionString
        String storageConnectionString =
                "DefaultEndpointsProtocol=https;" +
                "AccountName=xxxxxxx;" +
                "AccountKey=xxxxxxddfcfdcddrc==";

        //Authetication
        Authenticator.setDefault(new Authenticator() {
              protected PasswordAuthentication getPasswordAuthentication() {
                return new
                   PasswordAuthentication(proxyName,passowrd.toCharArray());
            }});

        //Set Proxy Host name and Port
        Proxy proxy = new Proxy(Proxy.Type.HTTP, new InetSocketAddress("xxxxxxxxx", 8080));
        OperationContext op = new OperationContext();
        op.setProxy(proxy);

        // Retrieve storage account from connection-string.
        CloudStorageAccount storageAccount = CloudStorageAccount.parse(storageConnectionString);

        // Create the blob client.
       CloudBlobClient blobClient = storageAccount.createCloudBlobClient();

       // Get a reference to a container.
       // The container name must be lower case
       CloudBlobContainer container = blobClient.getContainerReference("test");

       // Create the container if it does not exist with public access.
       System.out.println("Creating container: " + container.getName());


       // Create the container if it does not exist.
       //container.createIfNotExists(BlobContainerPublicAccessType.CONTAINER, new BlobRequestOptions(), op);

       // Delete the blob.
       //container.deleteIfExists(null, null, op);
        LinkedList<String> blobNames = new LinkedList<>();
        Iterable<ListBlobItem> blobs = container.listBlobs();
        blobNames = new LinkedList<>();

       **// the line that hit an error**
        for(ListBlobItem blob: blobs) { 
            blobNames.add(((CloudBlockBlob) blob).getName());
        }

        System.out.println(blobNames.size());

        System.out.println("********Success*********");

Cuando ejecuto el script anterior, tengo el siguiente problema:

java.util.NoSuchElementException: An error occurred while enumerating the result, check the original exception for details.java.util.NoSuchElementException: An error occurred while enumerating the result, check the original exception for details.
at com.microsoft.azure.storage.core.LazySegmentedIterator.hasNext(LazySegmentedIterator.java:113)
at com.microsoft.azure.storage.StorageException: An unknown failure occurred : Connection refused: connect
at com.microsoft.azure.storage.StorageException.translateException(StorageException.java:66)
at com.microsoft.azure.storage.core.ExecutionEngine.executeWithRetry(ExecutionEngine.java:209)
at com.microsoft.azure.storage.core.LazySegmentedIterator.hasNext(LazySegmentedIterator.java:109)
... 1 moreCaused by: java.net.ConnectException: Connection refused: connect

No sé por qué ocurre este error, pero arroja la excepción anterior y Connection se negó.

Respuesta 1

Debe pasar su OperationContext a la llamada container.listBlobs () a través de esta sobrecarga:

public Iterable<ListBlobItem> listBlobs(final String prefix, final boolean useFlatBlobListing, final EnumSet<BlobListingDetails> listingDetails, BlobRequestOptions options, OperationContext opContext)

En tu caso eso significaría

Iterable<ListBlobItem> blobs = container.listBlobs(null, false, EnumSet.noneOf(BlobListingDetails.class), null, op);
Respuesta: 2

Estoy usando el portal java liferay, en el que hay múltiples portlets. Quiero crear un portlet con un formulario que cuando se envía se recuperan los datos y el resultado específico se muestra en algunos ...

He desarrollado una aplicación GCM, donde una aplicación de servidor envía notificaciones a la aplicación de Android a través de GCM. Ahora quiero ofrecer esta aplicación a los usuarios, pero ¿cómo trato con el SENDER_ID y la clave API? ...

Tengo una pregunta sobre la autenticación en la aplicación Spring Boot REST. Creo una aplicación pequeña y simple con registro de usuario e inicio de sesión para practicar Spring Rest, Spring Boot, Spring Data y ...

En su documentación de la función ChangeMessageVisibility, Amazon da el siguiente ejemplo: Por ejemplo, tiene un mensaje con un tiempo de espera de visibilidad de 5 minutos. Después de 3 minutos, llamas ...