使用AWS SDK将SFTP服务器文件迁移至S3存储桶的实现方案及SDK相关功能咨询

阿华AIGC实验室

2026-4-8

AWS SDK将SFTP服务器文件迁移至S3存储桶的实现方案及SDK相关功能咨询

嘿，我来帮你理清这个问题～首先明确一点：AWS SDK并没有提供像你现有S3跨桶移动那样的一键式SFTP到S3迁移函数，不过你完全不用从零开始搭建，我们可以用通用SFTP客户端库结合AWS S3 SDK来实现需求，下面给你详细拆解：

核心实现思路

因为SFTP服务器和S3是完全独立的存储系统，不存在直接的跨服务复制接口，所以流程需要拆分成三步：

从SFTP服务器下载目标文件到Lambda的临时存储目录（/tmp）
将临时文件上传到指定的S3存储桶
确认S3上传成功后，删除SFTP服务器上的源文件

具体代码示例（Kotlin）

这里我们用常用的JSch库作为SFTP客户端（你需要在项目依赖里添加JSch），结合AWS S3 SDK来实现：

import com.jcraft.jsch.*
import software.amazon.awssdk.core.sync.RequestBody
import software.amazon.awssdk.services.s3.S3Client
import software.amazon.awssdk.services.s3.model.PutObjectRequest
import java.io.File

fun sftpToS3Move(
    sftpHost: String,
    sftpPort: Int,
    sftpUsername: String,
    sftpPassword: String,
    sftpRemotePath: String,
    s3Bucket: String,
    s3Key: String,
    s3: S3Client
) {
    val jsch = JSch()
    var session: Session? = null
    var channelSftp: ChannelSftp? = null

    try {
        // 建立SFTP连接
        session = jsch.getSession(sftpUsername, sftpHost, sftpPort)
        session.setPassword(sftpPassword)
        session.setConfig("StrictHostKeyChecking", "no")
        session.connect()

        channelSftp = session.openChannel("sftp") as ChannelSftp
        channelSftp.connect()

        // 下载文件到Lambda临时目录
        val tempFile = File("/tmp/${File(sftpRemotePath).name}")
        channelSftp.get(sftpRemotePath, tempFile.absolutePath)

        // 上传到S3
        val putObjectRequest = PutObjectRequest.builder()
            .bucket(s3Bucket)
            .key(s3Key)
            .build()
        s3.putObject(putObjectRequest, RequestBody.fromFile(tempFile))

        // 确认上传成功后删除SFTP上的文件
        channelSftp.rm(sftpRemotePath)

    } catch (e: JSchException) {
        // 处理SFTP连接/操作异常
        throw RuntimeException("SFTP操作失败: ${e.message}", e)
    } catch (e: SftpException) {
        // 处理SFTP文件操作异常
        throw RuntimeException("SFTP文件处理失败: ${e.message}", e)
    } finally {
        // 关闭资源
        channelSftp?.disconnect()
        session?.disconnect()
        // 清理临时文件
        File("/tmp/${File(sftpRemotePath).name}").delete()
    }
}

关键注意事项

Lambda资源限制：Lambda的/tmp目录最大可用空间为10GB，超时时间最长15分钟，如果你的文件过大，建议考虑分段上传S3，或者改用EC2/ECS等更适合大文件处理的服务。
异常处理：一定要确保S3上传成功后再删除SFTP上的文件，避免上传失败导致数据丢失；同时要处理连接超时、权限不足等异常场景。
备选方案：AWS Transfer Family：如果你们未来考虑替换现有SFTP服务器，可以使用AWS Transfer Family托管的SFTP服务，它可以直接映射到S3存储桶，文件上传到Transfer Family后会自动同步到S3，省去手动迁移的步骤。