从 FTP 获取文件大小(在 SSIS 中,使用 Dts.Connections)

Get File Size from FTP (in SSIS, using Dts.Connections)

我在将大文件发送到 FTP 站点时遇到问题,我想在传输后检查文件大小(有时成功有时失败)。传输在 SSIS 中进行,我在 C# 中使用 Dts.Connections。

我的代码:

public long TransferFile(string file)
{
    long filesize = 0L;

    try
    {
        string[] newfile = new[] { file };

        ConnectionManager ftpCM = Dts.Connections["ftp_server"];
        string remoteDir = Dts.Variables["FtpWorkingDirectory"].Value.ToString();

        FtpClientConnection ftpClient = new FtpClientConnection(ftpCM.AcquireConnection(null));
        ftpClient.UsePassiveMode = true;
        ftpClient.Connect();
        ftpClient.Retries = 10;
        ftpClient.SetWorkingDirectory(remoteDir);

        ftpClient.SendFiles(newfile, remoteDir, true, false);

        ftpClient.Close();
    }
    catch (Exception ex)
    {
        throw ex;
    }

    return filesize;
}

我找到了使用 FtpWebRequest 的示例,但我没有可用的 ftp uri,所以我不知道如何使用此方法。我怎样才能得到这个文件大小?

更新: 添加这个:

        FtpWebRequest request = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + ftpCM.ConnectionString + remoteDir + "/" + file));
        request.Proxy = null;

        DtsProperty ServerUsername = ftpCM.Properties["ServerUserName"];
        DtsProperty ServerPassword = ftpCM.Properties["ServerPassword"];
        request.Credentials = new NetworkCredential(ServerUsername.GetValue(ftpCM).ToString(), ServerPassword.GetValue(ftpCM).ToString());
        request.Method = WebRequestMethods.Ftp.GetFileSize;

        FtpWebResponse response = (FtpWebResponse)request.GetResponse();
        filesize = response.ContentLength;
        response.Close();

我收到错误消息:属性 ServerPassword 是只写的。

最终的解决方案是将用户名和密码存储在变量中,而不是连接参数中。

并使用以下代码:

public long TransferFile(string file)
{
    long filesize = 0L;

    try
    {
        string[] newfile = new[] { file };

        ConnectionManager ftpCM = Dts.Connections["ftp_server"];
        string remoteDir = Dts.Variables["FtpWorkingDirectory"].Value.ToString();
        string ServerUsername = Dts.Variables["ServerUsername"].Value.ToString();
        string ServerPassword = Dts.Variables["ServerPassword"].Value.ToString();

        FtpClientConnection ftpClient = new FtpClientConnection(ftpCM.AcquireConnection(null));
        ftpClient.UsePassiveMode = true;
        ftpClient.ServerUserName = ServerUsername;
        ftpClient.ServerPassword = ServerPassword;

        ftpClient.Connect();
        ftpClient.Retries = 10;
        ftpClient.SetWorkingDirectory(remoteDir);

        ftpClient.SendFiles(newfile, remoteDir, true, false);

        ftpClient.Close();

        FtpWebRequest request = (FtpWebRequest)FtpWebRequest.Create(new Uri("ftp://" + ftpCM.ConnectionString + remoteDir + "/" + Path.GetFileName(file)));
        request.Proxy = null;

        request.Credentials = new NetworkCredential(ServerUsername, ServerPassword);
        request.Method = WebRequestMethods.Ftp.GetFileSize;

        FtpWebResponse response = (FtpWebResponse)request.GetResponse();
        filesize = response.ContentLength;
        response.Close();
    }
    catch (Exception ex)
    {
        throw ex;
    }

    return filesize;
}