如何在java中从azure存储下载目录和压缩文件夹

Question

我已经尝试过这样的尝试。我无法下载

CloudStorageAccount account = CloudStorageAccount.parse("connection string");
CloudBlobClient serviceClient = account.createCloudBlobClient();
CloudBlobContainer container = serviceClient.getContainerReference(containername);
for (com.microsoft.azure.storage.blob.ListBlobItem blobItem : container.listBlobs()) {

            // If the item is a blob, a virtual directory.
            if (blobItem instanceof CloudBlobDirectory) {
                CloudBlobDirectory blobDir = (CloudBlobDirectory) blobItem;
                downloadDirectory(blobDir);
               
            }
        }
    
    public static void downloadDirectory(CloudBlobDirectory blobDir)
            throws IOException, StorageException, URISyntaxException {
    
        if (blobDir.getPrefix().equals(destFilePath)) {          
               for (ListBlobItem blobInDir : blobDir.listBlobs()) {
                    if (blobInDir instanceof CloudBlockBlob) {
                        ByteArrayOutputStream outputStream =new ByteArrayOutputStream();
                        ((CloudBlockBlob) blobInDir).download(outputStream);
                        ((CloudBlockBlob) blobInDir).downloadToFile(destFilePath);                      
                        CloudBlockBlob blob = (CloudBlockBlob) blobInDir;
                        
                        blob.downloadToFile(destFilePath);
                    } 
                }
        }
    
     
    
    }

我尝试从Azure存储中下载文件夹，但我无法下载作为文件夹

Answer 1

您可以使用此 Java 代码从容器（Azure 存储帐户）下载该文件夹。由于我无法测试它，因此我的 IDE 存在问题。但你可以在你的环境中尝试一下。

import com.microsoft.azure.storage.CloudStorageAccount;
import com.microsoft.azure.storage.StorageException;
import com.microsoft.azure.storage.blob.*;

import java.io.IOException;
import java.net.URISyntaxException;
import java.nio.file.Files;
import java.nio.file.Paths;
import java.security.InvalidKeyException;

public class DownloadDirectory {

    public static String destFilePath = "C:\\Folder1\\";
    public static String storageConnectionString="XXXXXX";

    public static void main(String[] args)
            throws InvalidKeyException, URISyntaxException, StorageException, IOException {
        System.setProperty("server.port", "4000");

        CloudStorageAccount account = CloudStorageAccount.parse(storageConnectionString);
        CloudBlobClient serviceClient = account.createCloudBlobClient();
        CloudBlobContainer container = serviceClient.getContainerReference("testblob");

        for (ListBlobItem blobItem : container.listBlobs()) {

            // If the item is a blob, a virtual directory.
            if (blobItem instanceof CloudBlobDirectory) {

                CloudBlobDirectory blobDir = (CloudBlobDirectory) blobItem;
                downloadDirectory(blobDir);
            }
        }
    }

    public static void downloadDirectory(CloudBlobDirectory blobDir)
            throws IOException, StorageException, URISyntaxException {

        Files.createDirectories(Paths.get(destFilePath + blobDir.getPrefix()));

        for (ListBlobItem blobInDir : blobDir.listBlobs()) {

            if (blobInDir instanceof CloudBlockBlob) {
                CloudBlockBlob blob = (CloudBlockBlob) blobInDir;
                blob.downloadToFile(destFilePath + blob.getName());
            } else {
                downloadDirectory((CloudBlobDirectory) blobInDir);
            }
        }

    }
}

参考：从 blob 存储下载虚拟目录