在SSIS/C中的两个远程FTP和SFTP服务器之间传输文件，然后将源文件归档到另一个目录

Question

我已经为此挣扎了一段时间，但我真的不知道如何使用SSIS解决这种情况（我正在考虑用C#创建一个脚本任务）

这是我的问题：每天都会创建一个文件并将其存储在特定服务器的某个目录中（我可以通过使用客户端-服务器应用程序（例如FileZilla或任何其他程序）中的FTP协议来访问它）。我想将该文件传输到使用SFTP协议的不同服务器。然后，一旦它成功放置在该服务器中，将原始文件移动到源FTP服务器上的不同文件夹。

看看这个例子：

我需要将文件myfiletest.csv传输到不同的SFTP服务器。路径是：秒服务器/位置这里。

最后，文件传输后，我想将源文件移动到文件夹Process。

一直试图将文件从第一台服务器复制并移动到第二台服务器，但没有成功，我现在有点迷路了。

能帮我解决吗？

这就是我尝试从FTP服务器读取文件的方式（我无法正确读取它，甚至无法将其保存在本地环境中）。

 public void Main()
 {
    var directory =
        new DirectoryInfo(Dts.Variables["User::FolderPath"].Value.ToString());

    FileInfo[] files = directory.GetFiles();
    DateTime lastModified = DateTime.MinValue;

    foreach (FileInfo file in files)
    {
        if (file.LastWriteTime > lastModified)
        {
            lastModified = file.LastWriteTime;
            Dts.Variables["User::FileName"].Value = file.ToString();
        }
    }

     MessageBox.Show(Dts.Variables["User::FileName"].Value.ToString());


     Dts.TaskResult = (int)ScriptResults.Success;
 }

Answer 1

您的代码不会访问任何服务器。它不使用FTP或SFTP。它适用于本地文件。

无论如何，如果FTP和SFTP是您唯一可用的接口，则无法将文件直接从FTP复制到SFTP服务器。

您必须从FTP服务器下载文件，然后将其上载到SFTP服务器。

>

要在FTP服务器上查找最新文件，请从FTP服务器下载最新文件

有关FTP下载，请参阅在C#/中向/从FTP服务器上传和下载文件。NET

有关SFTP上载，请参阅C#SFTP上载文件

要移动文件，请参阅如何使用FTP在目录之间移动文件？

您可以将文件从下载直接流式传输到上传，以避免将文件存储到临时本地文件中。

如果您想使用内置的。NET FTP实现（WebClient/FtpWebRequest）和本机。NET SFTP库（如SSHH. NET），您可以这样做：

var ftpClient = new WebClient();
ftpClient.Credentials = new NetworkCredential("ftpuser", "ftppass");
var ftpUrl = "ftp://ftp.example.com/ftp/path/file.csv";
using (var ftpStream = ftpClient.OpenRead(ftpUrl))
using (var sftpClient = new SftpClient("sftp.example.com", "sftpuser", "sftppass"))
{
    sftpClient.UploadFile(ftpStream, "/sftp/path/file.csv");
}

要移动处理过的文件：

FtpWebRequest ftpRequest = new FtpWebRequest(ftpUrl);
ftpRequest.Method = WebRequestMethods.Ftp.Rename;
ftpRequest.RenameTo = "/ftp/path/processed/file.csv";
ftpRequest.GetResponse(); 

如果有这两个SFTP服务器，使用我的WinSCP.NET程序集会更容易一些。虽然不是本机的.NET库，但它可以从SSIS中使用。使用WinSCP时，代码如下：

// Setup session options
SessionOptions sftpSessionOptions1 = new SessionOptions
{
    Protocol = Protocol.Sftp,
    HostName = "sftp1.example.com",
    UserName = "username1",
    Password = "password",
};

SessionOptions sftpSessionOptions2 = new SessionOptions
{
    Protocol = Protocol.Sftp,
    HostName = "sftp2.example.com",
    UserName = "username2",
    Password = "password",
    SshHostKeyFingerprint = "ssh-rsa 2048 xxxxxxxxxxx...="
};

using (Session sftpSession1 = new Session())
using (Session sftpSession2 = new Session())
{
    // Connect to SFTP 1
    ftpSession1.Open(sftpSessionOptions1);

    // Get list of files in the FTP directory
    string sftpRemoteDir1 = "/ftp/remote/path";
    RemoteDirectoryInfo dirInfo = sftpSession1.ListDirectory(sftpRemoteDir1);

    // Select the most recent file
    RemoteFileInfo latest =
        dirInfo.Files
            .Where(file => !file.IsDirectory)
            .OrderByDescending(file => file.LastWriteTime)
            .First();

    // Connect to SFTP
    sftpSession2.Open(sftpSessionOptions2);

    string sftpRemoteDir2 = "/sftp/remote/path";
    string sftpRemotePath2 = RemotePath.Combine(sftpRemoteDir2, latest.Name);

    // Transfer from SFTP 1 to SFTP 2
    using (Stream downloadStream = sftpSession1.GetFile(latest.FullName))
    {
        sftpSession2.PutFile(downloadStream, sftpRemotePath2);
    }

    // Move the source file to the "processed" folder
    string processedDir = "/sftp/remote/path/processed";
    string processedPath = RemotePath.Combine(processedDir, latest.Name);
    ftpSession.MoveFile(latest.FullName, processedPath);
}

未经测试。需要WinSCP 5.19或更新版本。