使用 C# 将文件从 FTP 直接传输到 Azure Blob 存储

Question

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

public static async Task FTP_TO_BLOB_TRANSFER()
{
    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 服务器上文件夹的目录列表。与此同时，您是：

逐行（逐个文件）阅读清单 – 以某种方式尝试处理个人 lines/files。
但您正在尝试将列表（同一流）上传到 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);

使用 C# 将文件从 FTP 直接传输到 Azure Blob 存储

Transferring files from FTP directly to Azure Blob storage in C#

.net

c#

ftp

ftpwebrequest

azure-blob-storage