栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Python

利用python实现本地文件上传到sftp

Python 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

利用python实现本地文件上传到sftp

实现功能: 利用python自动连接sftp,并实现本地文件(文件夹)自动上传到远程sftp服务中指定路径下,且保持本地目录结构
系统环境:centos7
python版本:python3
使用模块包:paramiko ,若未安装,可使用 pip install paramiko 进行安装

难点分析:
(1)sftp.put(localfile,remotefile) 函数必须是两个文件名,且sftp远端的文件路径要存在,因此需要提前创建好目录
(2)sftp.mkdir() 函数只能创建一级目录,不能循环创建多级目录,本文通过一级一级获取本地路径,然后判断远程路径是否存在,若不存在就创建好,由此来保证上传的文件能够在sftp远端找到对应的目录
(3)用到的重点函数有 sftp.mkdir 、sftp.stat,更多函数可参见帮助文档:https://docs.paramiko.org/en/stable/api/sftp.html
(4)关于sftp文件下载的方法,参考博文:https://blog.csdn.net/d1240673769/article/details/106295184
(5)关于sftp文件上传和下载,另一种最简单的方法就是利用 shell脚本,lftp工具,详情参考:https://blog.csdn.net/d1240673769/article/details/106307421

实现代码:

# -*- coding: utf-8 -*-

import paramiko
import os
import 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()
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/350323.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号