利用python实现sftp文件的上传和下载

# -*- coding: utf-8 -*-import paramikoimport osimport stat# 判断sftp服务端中文件路径是否存在，若不存在则创建def create_dir(sftp,remoteDir):    try:        if stat.S_ISDIR(sftp.stat(remoteDir).st_mode): # 如果remoteDir存在且为目录，则返回True            pass    except Exception as e:        sftp.mkdir(remoteDir)        print("在远程sftp上创建目录：{}".format(remoteDir))# 上传def sftp_upload(sftp,localDir,remoteDir):    if os.path.isdir(localDir): # 判断本地localDir是否为目录        for file in os.listdir(localDir):            remoteDirTmp=os.path.join(remoteDir,file)            localDirTmp=os.path.join(localDir,file)            if os.path.isdir(localDirTmp): # 如果本地localDirTmp为目录，则对远程sftp服务器进行判断                create_dir(sftp,remoteDirTmp) # 判断sftp服务端文件目录是否存在,若不存在则创建            sftp_upload(sftp,localDirTmp,remoteDirTmp)    else:        print("upload file:",localDir)        try:            sftp.put(localDir,remoteDir)        except Exception as e:            print('upload error:',e)if __name__ == '__main__':    host = '192.168.149.153'#sftp主机     port = 22 #端口    username = 'sftpuser' #sftp用户名    password = 'passwd'  # 密码    localDir = '/test/sftp'#本地文件或目录    remoteDir = '/sftp'#远程文件或目录（注意远程路径要存在）    sf = paramiko.Transport((host,port))    sf.connect(username = username,password = password)    sftp = paramiko.SFTPClient.from_transport(sf)    sftp_upload(sftp,localDir,remoteDir)    sf.close()

#!/usr/bin/python# coding=utf-8import paramikoimport osimport statdef sftp_download(sftp,localDir,remoteDir):    if stat.S_ISDIR(sftp.stat(remoteDir).st_mode): # 如果sftp服务端的remoterDir是目录，则返回True        for file in sftp.listdir(remoteDir):            remoteDirTmp=os.path.join(remoteDir,file)            localDirTmp=os.path.join(localDir,file)            sftp_download(sftp,localDirTmp,remoteDirTmp)    else:        localPath=localDir.rpartition("/")[0]        if not os.path.exists(localPath): # 如果本地目录不存在，则创建            os.makedirs(localPath)  # 可创建多级目录        print("download file:",remoteDir)        try:            sftp.get(remoteDir,localDir)        except Exception as e:            print('download exception:',e)if __name__ == '__main__':    host = '192.168.149.128'#sftp主机     port = 22 #端口    username = 'sftp' #sftp用户名    password = '123456'      localDir = '/data/test'#本地文件或目录    remoteDir = '/'#远程文件或目录    sf = paramiko.Transport((host,port))    sf.connect(username = username,password = password)    sftp = paramiko.SFTPClient.from_transport(sf)    sftp_download(sftp,localDir,remoteDir)    sf.close()