代码如下：

import paramiko
import os
from ftplib import FTP
import paramiko, os
import json
# def callback(current, total):
#     print("文件大小为：{}，已经下载了：{}".format(total, current))


# def ssh_download(fromPath, toPath, timeout=120, host='你的第一个服务器的IP地址', port='21', username='你的第一个服务器的用户名', password='你的第一个服务器的密码'):
#     """
#     下载文件操作
#     :param host：主机地址
#     :param port：端口
#     :param username：用户名
#     :param password：密码
#     :param fromPath：文件路径(需要下载的文件)
#     :param toPath：下载至文件路径
#     """
#     client = paramiko.SSHClient()
#     client.set_missing_host_key_policy(paramiko.AutoAddPolicy())
#     client.connect(hostname=host, port=port, username=username, password=password, timeout=timeout)
#
#     sftp_client = paramiko.SFTPClient.from_transport(client.get_transport())
#     print('1111111111111111111111111')
#     sftp_client.get(fromPath, toPath, callback=callback)
#     print('2222222222222222222222')
#     sftp_client.close()
#
#     client.close()

# 下载单个文件
def ftpDownloadFile(ftp, ftpfile, localfile):
    # fid = open(localfile, 'wb') # 以写模式打开本地文件
    bufsize = 1024
    with open(localfile, 'wb') as fid:
        ftp.retrbinary('RETR {0}'.format(ftpfile), fid.write, bufsize)  # 接收服务器文件并写入本地文件
    return True


# 连接ftp服务器
def ftpConnect(ftpserver, port, usrname, password):
	"""
    :param ftpserver:  服务器IP
    :param port:  端口
    :param usrname:  用户名
    :param password:  密码
    :return: 
    """
    ftp = FTP()
    try:
        ftp.connect(ftpserver, port)
        ftp.login(usrname, password)
    except:
        raise IOError('\n FTP connection failed, please check the code!')
    else:
        print(ftp.getwelcome())  # 打印登陆成功后的欢迎信息
        print('\n+------- ftp connection successful!!! --------+')
        return ftp
# 退出ftp连接
def ftpDisConnect(ftp):
    ftp.quit()

def ssh_upload(from_path, to_file_name, ip='你的第三个服务器的IP地址', port=22, username='你的第三个服务器的用户名', password='你的第三个服务器的密码',to_path='/data1/auth-priv/ftper/yxd/2022/1'):
    """
    :param from_path:  要上传的文件路径
    :param to_file_name: 带后缀的文件命(注意不带父级目录)
    :param ip: 服务器的IP地址
    :param port: 服务器的端口
    :param username: 服务器的用户名
    :param password: 服务器的密码
    :param to_path: 要上传的文件的路径(到文件后缀名的父级目录)
    :return:
    """
    transport = paramiko.Transport((ip, port))
    transport.connect(username=username, password=password)
    sftp = paramiko.SFTPClient.from_transport(transport)  # 如果连接需要密钥，则要加上一个参数，hostkey="密钥"
    sftp.put(from_path, os.path.join(to_path, to_file_name))  # 将本地的Windows.txt文件上传至服务器/root/Windows.txt
    sftp.close()
    transport.close()  # 关闭连接


if __name__ == "__main__":
    fromPath = "2022/01/"
    ftpserver = '存储文件的服务器的IP地址(第一个服务器)'
    port = 21 # 端口
    usrname = '' # '第一个服务器的用户名'
    pwd = '' #  '第一个服务器的密码'
    # fromPath = '/2022/01/0003e5bf-33a7-40ad-a485-793ad16af5e3.zip'
    dir_list = os.listdir(fromPath)
    # json.dump([], open('/home/xy/ftper/yxd/2021/record.json', 'w'))

    try:
    	# 防止断网重新下载，用一个数组文件记录已经下载过的，下次可以直接跳过已下载的
        with open('/home/xy/ftper/yxd/2021/record.json', 'r') as f:
            file_name_list = json.load(f)
    except Exception as e:
        file_name_list = []

    for each_dir in dir_list:
        if each_dir not in file_name_list:
            file_name_list.append(each_dir)
            json.dump(file_name_list, open('/home/xy/ftper/yxd/2021/record.json', 'a'))
            ftp = ftpConnect(ftpserver, 21, usrname, pwd)
            # print('name_list \n', '/home/xy/ftper/yxd/2021/'+each_dir.split('/')[-1])
            # print('each_dir \n', each_dir)
            result = ftpDownloadFile(ftp, fromPath+each_dir, '/home/xy/ftper/yxd/2021/'+each_dir.split('/')[-1])
            # print('result \n', result)
            ftpDisConnect(ftp)
            print(each_dir, '下载完成')
            ssh_upload('/home/xy/ftper/yxd/2021/'+each_dir.split('/')[-1], each_dir)
            print(each_dir, '上传已完成')
            os.remove('/home/xy/ftper/yxd/2021/'+each_dir.split('/')[-1])
            print(each_dir, '删除已完成')