c# - 如何将blob文件下载到内存流中？

Question

我编写的代码仅将第一个文件提取到内存流中，我需要在 SFTP 上发送该文件，因此只有第一个文件被发送到 SFTP 并且我有 3 个 blob 文件。 这是我的代码。

foreach (var blob in blobs)
{
    string str = blob.StorageUri.PrimaryUri.LocalPath;
    string fileName = blob.StorageUri.PrimaryUri.LocalPath.Replace("/output/ServiceNowExtract/", "");
    var blobPath = string.Format("{0}", blob.StorageUri.PrimaryUri.OriginalString);
    CloudBlockBlob blobSNow = container.GetBlockBlobReference(fileName.Replace(fileName, blob.StorageUri.PrimaryUri.LocalPath.Replace("/output/", "")));
    string ftpFilePathSNow = string.Format("{0}/{1}", ftpUploadPathSNow, fileName);
    var latestblob = container.ListBlobs();
    using (var stream = new MemoryStream())
    {

        // Downloading the blob containt to the memory stream
        blobSNow.DownloadToStream(stream);
        try
        {
            using (var client = new SftpClient(ftpConnectionSNow))
            {
                client.BufferSize = 999424;
                client.Connect();
                stream.Position = 0;
                client.UploadFile(stream, ftpFilePathSNow, true);
                client.Disconnect();
            }
        }

Answer 1

请尝试使用以下代码，它在我这边工作正常。我测试了容器中的 4 个 blob，blob 构造如下。

演示代码:

  var connectionString = "DefaultEndpointsProtocol=https;AccountName=accountxxxx;AccountKey=xxxxxxxxx;EndpointSuffix=core.windows.net";
  CloudStorageAccount storageAccount = CloudStorageAccount.Parse(connectionString);
  CloudBlobClient blobClient = storageAccount.CreateCloudBlobClient();
  CloudBlobContainer container = blobClient.GetContainerReference("output");
  var blobs = container.ListBlobs();
  var ftpConnectionSNow = new ConnectionInfo("HostName", "username", new PasswordAuthenticationMethod("username","password"));
  const string ftpUploadPathSNow = "/home/xxx/sftptest4tom"; //sftp path
  foreach (var blob in blobs)
  {
       CloudBlockBlob blobSNow = (CloudBlockBlob) blob;
       var fileName = blobSNow.Name;
       Console.WriteLine($"BlobName:{fileName} ---BlobSize:{blobSNow.Properties.Length}");
       var ftpFilePathSNow = $"{ftpUploadPathSNow}/{fileName}";
       using (var stream = new MemoryStream())
       {
          // Downloading the blob containt to the memory stream
          blobSNow.DownloadToStream(stream);
          try
            {
               using (var client = new SftpClient(ftpConnectionSNow))
               {
                   client.BufferSize = 999424;
                   client.Connect();
                   stream.Position = 0;
                   client.UploadFile(stream, ftpFilePathSNow, true);
                   client.Disconnect();
                }
            }
            catch (Exception)
            {
                        // ToDo
            }
       }
  }

通过命令检查上传的 blob