上载后Azure存储zip文件损坏（使用Azure存储Blob客户端库Java）

Question

问题：从数据生成的包含csv文件的zip文件在上传到Azure Blob存储后似乎已损坏。

上传前的zip文件如下所示：

在上传过程中，我使用了Azure Storage Blob client library for Java（12.7.0版，但我也尝试了以前的版本）。这是我使用的代码（类似于SDK自述文件中提供的示例）：

public void uploadFileFromPath(String pathToFile, String blobName) {
     BlobClient blobClient = blobContainerClient.getBlobClient(blobName);
     blobClient.uploadFromFile(pathToFile);
}

我得到了上传的文件：

当我直接从storage explorer下载文件时，文件已经损坏。我做错了什么？

Answer 1

最终是我的错。我没有在上传文件之前关闭ZipOutputStream。当你使用try与资源并只想生成本地文件时，这不是什么大问题。但是在我的情况下，我想将文件上传到Blob存储（仍在try部分）。文件不完整（未关闭），所以它出现在存储中，数据已损坏。这是我从一开始就应该做的。

private void addZipEntryAndDeleteTempCsvFile(String pathToFile, ZipOutputStream zipOut,
        File file) throws IOException {
    LOGGER.info("Adding zip entry: {}", pathToFile);
    zipOut.putNextEntry(new ZipEntry(pathToFile));
    try (FileInputStream fis = new FileInputStream(file)) {
        byte[] bytes = new byte[1024];
        int length;
        while ((length = fis.read(bytes)) >= 0) {
            zipOut.write(bytes, 0, length);
        }
        zipOut.closeEntry();
        file.delete()
    }
    zipOut.close(); // missing part
}

毕竟，谢谢你的帮助@JimXu。我真的很感激。

Answer 2

根据您的描述，我建议您使用以下方法上传zip文件

public void uploadFromFile(String filePath, ParallelTransferOptions parallelTransferOptions, BlobHttpHeaders headers, Map<String,String> metadata, AccessTier tier, BlobRequestConditions requestConditions, Duration timeout)

我们可以使用该方法设置内容类型

举个例子

BlobHttpHeaders headers = new BlobHttpHeaders()
     .setContentType("application/x-zip-compressed");
 Integer blockSize = 4* 1024 * 1024; // 4MB;
 ParallelTransferOptions parallelTransferOptions = new ParallelTransferOptions(blockSize, null, null);
blobClient.uploadFromFile(pathToFile,parallelTransferOptions,headers,null, AccessTier.HOT, null, null);

有关详细信息，请参阅文件