python如何上传或下载ftp文件

2021-08-09  本文已影响0人  轻丨尘

需要借助Paramiko,Paramiko模块是基于Python实现的SSH远程安全连接,用于SSH远程执行命令、文件传输等功能

默认Python没有自带,需要手动安装:
pip3 install paramiko

上传文件

# -*- coding: utf-8 -*-
import paramiko

def sftp_upload_file(host,user,password,server_path, local_path,timeout=10):
    """
    上传文件,注意:不支持文件夹
    :param host: 主机名
    :param user: 用户名
    :param password: 密码
    :param server_path: 远程路径,比如:/home/sdn/tmp.txt
    :param local_path: 本地路径,比如:D:/text.txt
    :param timeout: 超时时间(默认),必须是int类型
    :return: bool
    """
    try:
        t = paramiko.Transport((host, 22))
        t.banner_timeout = timeout
        t.connect(username=user, password=password)
        sftp = paramiko.SFTPClient.from_transport(t)
        sftp.put(local_path, server_path)
        t.close()
        return True
    except Exception as e:
        print(e)
        return False

下载文件

def sftp_down_file(host,user,password,server_path, local_path,timeout=10):
    """
    下载文件,注意:不支持文件夹
    :param host: 主机名
    :param user: 用户名
    :param password: 密码
    :param server_path: 远程路径,比如:/home/sdn/tmp.txt
    :param local_path: 本地路径,比如:D:/text.txt
    :param timeout: 超时时间(默认),必须是int类型
    :return: bool
    """
    try:
        t = paramiko.Transport((host,port))
        t.banner_timeout = timeout
        t.connect(username=user,password=password)
        sftp = paramiko.SFTPClient.from_transport(t)
        sftp.get(server_path, local_path)
        t.close()
        return True
    except Exception as e:
        print(e)
        return False

Paramiko不支持下载目录,如果要下载目录下所有文件到本地,需要遍历下载

def sftp_down_all_files(self, remote_path, local_path):
    try:
        t = paramiko.Transport((self.ip, self.port))
        t.connect(username=self.username, password=self.password)
        sftp = paramiko.SFTPClient.from_transport(t)
        all_files = sftp_get_all_files(self, remote_path)
        for x in all_files:
            local_file = local_path + "\\" + x
            remote_file = remote_path +"/" + x
            print  local_file
            sftp.get(remote_file, local_file)
        t.close()
        return True
    except Exception as e:
        print(e)
        return False

def sftp_get_all_files(self, remote_path):
  try:
        t = paramiko.Transport((self.ip, self.port))
        t.connect(username=self.username, password=self.password)
        sftp = paramiko.SFTPClient.from_transport(t)
        all_files = list()
        files = sftp.listdir_attr(remote_path)
        for x in files:
            all_files.append(x.filename)
        return all_files
    except Exception as e:
        print(e)
        return all_files
上一篇下一篇

猜你喜欢

热点阅读