如何使用 Azure Function 在 Azure 文件共享中解压缩文件？

Question

我有一个带有 Azure 文件共享的 Azure 存储帐户。我想使用 Azure 函数将 zip 存档文件提取到文件共享中的另一个目录。我用 C# 编写了这段代码：

    CloudFileDirectory rootDirectory = cloudFileShare.GetRootDirectoryReference();
    CloudFileDirectory output = rootDirectory.GetDirectoryReference("output");
    CloudFile cloudFile = input.GetFileReference("archive1.zip");
    
    using (var stream = await cloudFile.OpenReadAsync())
    {

       var file1 = new ZipArchive(stream);

       foreach (var zipEntry in file1.Entries)
       {

          var file2 = output.GetFileReference(zipEntry.Name);

          var fileStream = zipEntry.Open();

          await file2.UploadFromStreamAsync(fileStream); //error is in this line

        }

   }

但我得到了错误：

System.Private.CoreLib: Exception while executing function: HttpTriggerExtract. Microsoft.WindowsAzure.Storage: 
Operation is not valid due to the current state of the object.

如何解决这个问题？

编辑：此外，我使用 MemoryStream 修复了错误，此代码有效：

        foreach (var zipEntry in file1.Entries) {

            var fsz = output.GetFileReference(zipEntry.Name);

            using (var ms = new MemoryStream())
            {

                using (var fileStream = zipEntry.Open())
                {
                    await fileStream.CopyToAsync(ms);

                    ms.Seek(0, SeekOrigin.Begin);
                    await fsz.UploadFromStreamAsync(ms);

                }

            }

Answer 1

关于问题，请参考以下代码（我使用包WindowsAzure.Storage 9.3.1来做到这一点）

            CloudStorageAccount storageAccount = CloudStorageAccount.Parse(connectionString);
            CloudFileClient cloudFileClient = storageAccount.CreateCloudFileClient();
            CloudFileShare cloudFileShare = cloudFileClient.GetShareReference("share2");
            CloudFileDirectory rootDirectory = cloudFileShare.GetRootDirectoryReference();
            CloudFileDirectory input = rootDirectory.GetDirectoryReference("input");
            CloudFileDirectory output = rootDirectory.GetDirectoryReference("output");
            CloudFile cloudFile = input.GetFileReference("sample.zip");
            using (var stream = await cloudFile.OpenReadAsync())
            using (var zipArchive = new ZipArchive(stream)) {
                foreach (var entry in zipArchive.Entries)
                {
                    if (entry.Length > 0) {
                        CloudFile extractedFile = output.GetFileReference(entry.Name);

                        using (var entryStream = entry.Open())
                        {
                            byte[] buffer = new byte[16 * 1024];
                            using (var ms = await extractedFile.OpenWriteAsync(entry.Length))
                            {
                                int read;
                                while ((read = await entryStream.ReadAsync(buffer, 0, buffer.Length)) > 0)
                                {
                                    ms.Write(buffer, 0, read);
                                }
                            }
                        }
                    }
                
                }

            }

Answer 2

以上答案帮助我解决了我的问题。 使用新的 Azure 库 (12.7.0)，您必须这样编写代码：

        string srcDir = @"sourcePath";
        string destDir = @"sourcePath\testStorageUnzip";
        string srcFileName = "AzureStorageZip.zip";

        string azureConnectionString = ConfigurationManager.AppSettings["beecloudfileshare_AzureStorageConnectionString"];

        StorageSharedKeyCredential credential = BeeFileManager.GetAzureStorageKeyCredential(azureConnectionString);
        Uri srcUri = new Uri("https:" + Path.Combine(srcDir, srcFileName).Replace("\\", "/"), UriKind.Absolute);
        Uri destDirUri = new Uri("https:" + Path.Combine(destDir).Replace("\\", "/"), UriKind.Absolute);
        // Get a reference to the file we created previously
        ShareFileClient sourceFile = new ShareFileClient(srcUri, credential);

        ShareDirectoryClient shareDirectoryClient = new ShareDirectoryClient(destDirUri,credential);
        shareDirectoryClient.CreateIfNotExistsAsync().GetAwaiter().GetResult();

        using (var stream = sourceFile.OpenRead())
        using (var zipArchive = new ZipArchive(stream))
        {
            foreach (var entry in zipArchive.Entries)
            {
                if (entry.Length > 0)
                {
                    //CloudFile extractedFile = output.GetFileReference(entry.Name);
                    Uri destUri = new Uri("https:" + Path.Combine(destDir, entry.Name).Replace("\\", "/"), UriKind.Absolute);
                    ShareFileClient extractedFile = new ShareFileClient(destUri, credential);

                    
                    using (var entryStream = entry.Open())
                    {
                        using (MemoryStream ms = new MemoryStream())
                        {
                            entryStream.CopyTo(ms);
                            //
                            //Sorry I have this part in another method
                            //
                            Uri fileUri = new Uri("https:" + Path.GetDirectoryName(filePath).Replace("\\", "/"), UriKind.Absolute);
                            // Get a reference to the file we created previously
                            ShareDirectoryClient directory = new ShareDirectoryClient(fileUri, credential);
                            ShareFileClient file = directory.GetFileClient(Path.GetFileName(filePath));
                            ms.Seek(0, SeekOrigin.Begin);
                            file.Create(ms.Length);
                            file.Upload(ms);
                            //
                            //
                            //
                        }
                    }
                }

            }

        }
    }