c# - 在 C# 中将文件从 FTP 直接传输到 Azure Blob 存储

Question

我编写了一个将文件从 FTP 服务器移动到 Azure Blob 存储的函数。我想将流从 FTP 传递到 blob，以便我可以上传文件。我正在为每个文件运行一个 while 循环，并尝试使用 UploadFromStreamAsync() 将文件移动到 blob 存储。但是当我接到这个电话时，我的流对象被处理掉了，因为哪个文件正在传输到 blob 但没有任何内容。在传输所有文件之前，我不想处理我的流对象。谁能告诉我这是怎么回事？？

string ftpPath = ConfigurationSettings.AppSettings.Get("ftpPath");
string ftpUserName = ConfigurationSettings.AppSettings.Get("ftpUserName");
string ftpPassword = ConfigurationSettings.AppSettings.Get("ftpPassword");

FtpWebRequest request = (FtpWebRequest)WebRequest.Create(ftpPath);
request.Method = WebRequestMethods.Ftp.ListDirectory;
request.Credentials = new NetworkCredential(ftpUserName, ftpPassword);
FtpWebResponse response = (FtpWebResponse)request.GetResponse();
Stream responseStream = response.GetResponseStream();
StreamReader reader = new StreamReader(responseStream);

string connectionString = ConfigurationSettings.AppSettings.Get("connectionString");
string folderName = "Inbox/";
string file = reader.ReadLine();
while (!string.IsNullOrEmpty(file))
{
    string fileName = Path.GetFileNameWithoutExtension(file);
    string guid = Guid.NewGuid().ToString();
    string extension = Path.GetExtension(file);
    try
    {
        Stream fileForBlobStorage = reader.BaseStream;
        if (CloudStorageAccount.TryParse(connectionString, out storageAccount))
        {
            CloudBlobClient cloudBlobClient = storageAccount.CreateCloudBlobClient();
            CloudBlobContainer cloudBlobContainer = cloudBlobClient.GetContainerReference("falcon");
            BlobContainerPermissions permissions = new BlobContainerPermissions
            {
                PublicAccess = BlobContainerPublicAccessType.Blob
            };
            await cloudBlobContainer.SetPermissionsAsync(permissions);

            CloudBlockBlob cloudBlockBlob = cloudBlobContainer.GetBlockBlobReference(folderName + fileName + "-" + '[' + guid + ']' + guid + extension.ToString());

            await cloudBlockBlob.UploadFromStreamAsync((Stream  )fileForBlobStorage);
        }
        else
        {
            Console.WriteLine("Connection string not defined.");
        }
    }
    catch (Exception e)
    {
        string message = e.Message;
        Console.WriteLine(message);
    }
    file = reader.ReadLine();
}

Answer 1

您正在请求 FTP 服务器上文件夹的目录列表。与此同时，您是:

• 逐行(逐文件)阅读列表——尝试以某种方式处理单独的行/文件。
• 但您正在尝试将列表(同一流)上传到 blob。

那永远行不通。而且这毫无意义。

我假设您实际上想要上传文件，而不是列表。

为此，您需要开始从循环中的 FTP 服务器下载单个文件:

FtpWebRequest fileRequest = (FtpWebRequest)WebRequest.Create(ftpPath + file);
fileRequest.Method = WebRequestMethods.Ftp.DownloadFile;
fileRequest.Credentials = new NetworkCredential(ftpUserName, ftpPassword);
FtpWebResponse fileResponse = (FtpWebResponse)fileRequest.GetResponse();
Stream fileStream = fileResponse.GetResponseStream();

await cloudBlockBlob.UploadFromStreamAsync(fileStream);