如何将文件压缩为 zip 并上传到 azure blob 存储？

Question

我对这段代码有一个奇怪的问题，它基本上是压缩文件 (docs) 并将它们上传到 blob 存储。

v11SDK： (docs)

var blockBlobClient = new BlockBlobClient(ConnectionString, ContainerName, "test-blob.zip");

// Saved zip is valid
// using (FileStream zipStream = new FileStream(@"C:\Users\artur\Desktop\test-local.zip", FileMode.OpenOrCreate))

// Uploaded zip is invalid
using (var stream = await blockBlobClient.OpenWriteAsync(true))
using (var archive  = new ZipArchive(stream, ZipArchiveMode.Create))
{
    var readmeEntry = archive .CreateEntry("Readme.txt");
    using (StreamWriter writer = new StreamWriter(readmeEntry.Open()))
    {
            writer.WriteLine("Information about this package.");
            writer.WriteLine("========================");
    }
    await stream.FlushAsync();
}

v12SDK： (docs)

var blobClient = new BlobClient(ConnectionString, InputContainerName, "test-blob.zip");

using var stream = new MemoryStream();
using (var archive = new ZipArchive(stream, ZipArchiveMode.Create))
{
    var readmeEntry = archive.CreateEntry("Readme.txt");
    using StreamWriter writer = new StreamWriter(readmeEntry.Open());
    {
        writer.WriteLine("Information about this package.");
        writer.WriteLine("========================");
        await writer.FlushAsync();
    }
    stream.Position = 0;
    await blobClient.UploadAsync(stream, true);
    await stream.FlushAsync();
}

在本地保存 zip 文件会生成一个有效的 zip（164 字节）。将 zip 保存到 blob 存储（使用存储模拟器）会产生无效的 zip（102 字节）。 我不知道为什么

Answer 1

这是正确的代码。 问题是 ZipArchive 过早地处理内部流。请注意，在下面的代码中，我在创建 ZipArchive 时将 leaveInnerStreamOpen 作为 true 传递，因为我们已经在外部使用中处理流。同样对于 V11 代码，我已切换到 MemoryStream 而不是 Blob 流的 OpenWrite，因为如果我们使用 OpenWrite，则无法控制将流位置设置为 0。而且你不需要任何 Flush :)

v11SDK：

        var blockBlobClient = new BlockBlobClient(ConnectionString, ContainerName, "test-blob.zip");
        using var stream = new MemoryStream();
        using (var archive = new ZipArchive(stream, ZipArchiveMode.Create, true))
        {
            var readmeEntry = archive.CreateEntry("Readme.txt");
            using (StreamWriter writer = new StreamWriter(readmeEntry.Open()))
            {
                writer.WriteLine("Information about this package.");
                writer.WriteLine("========================");
            }
        }
        stream.Position = 0;
        await blockBlobClient.UploadAsync(stream);

v12SDK：

        var blobClient = new BlobClient(ConnectionString, InputContainerName, "test-blob.zip");
        using var stream = new MemoryStream();
        using (var archive = new ZipArchive(stream, ZipArchiveMode.Create, true))
        {
            var readmeEntry = archive.CreateEntry("Readme.txt");
            using StreamWriter writer = new StreamWriter(readmeEntry.Open());
            {
                writer.WriteLine("Information about this package.");
                writer.WriteLine("========================");
            }
        }

        stream.Position = 0;
        await blobClient.UploadAsync(stream, true);