1

2

3

4

5

6

7

8

9

10

11

12

13

14

def upload(f, remote_path, local_path):

    fp = open(local_path, "rb") #,encoding='utf-8'

    buf_size = 1024

    # f.storbinary("STOR {}".format(remote_path), fp, buf_size)

    # f.storbinary("STOR {}"+remote_path, fp, buf_size)

    # f.storbinary("STOR {}".format(remote_path)+r"/20250413_抖音_XXX服饰旗舰店_视频合作视频数据_1744606680.xlsx", fp, buf_size)

    # f.storbinary("STOR "+remote_path+r"/aa.xls", fp, buf_size)   #单文件ok

    filenam2=local_path[local_path.rfind('\\')+1:].strip()

    print(filenam2+"#"+remote_path+"#"+local_path)

    filenam3=filenam2.encode('utf-8').decode('iso-8859-1')

    f.storbinary("STOR "+remote_path+filenam3, fp, buf_size)

    fp.close()

1

ftp.encoding="iso-8859-1"

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

def upload_file_via_ftp(hostname, port, username, password, local_file_path, remote_file_path):

    # 创建SSH客户端实例

    client = paramiko.SSHClient()

    # 自动添加策略，保存服务器的主机名和密钥信息

    # client.set_missing_host_key_policy(paramiko.AutoAddPolicy())

    try:

        # 连接到服务器

        client.connect(hostname, port, username, password)

        # 使用SFTPClient进行文件传输

        sftp = client.open_sftp()

        sftp.put(local_file_path, remote_file_path)

        print(f"文件 {local_file_path} 已成功上传到 {remote_file_path}")

        # 关闭SFTP连接

        sftp.close()

    except Exception as e:

        print(f"上传文件时发生错误: {e}")

    finally:

        # 关闭SSH连接

        client.close()

1

2

3

4

5

6

def main(args):

    with pysftp.Connection(glv['gvarFtpSerIP'], username=glv['gvarFtpUid'], password=glv['gvarFtpPs'],port=30000) as sftp:

    # sftp.get('远程中文文件.txt', '本地文件.txt')  # 下载

        sftp.put(r"C:\20250413_抖音_XXX服饰旗舰店_视频合作视频数据_1744606680.xlsx", '20250413_抖音_XXXX服饰旗舰店_视频合作视频数据_1744606680.xlsx')  # 上传

        sftp.close()

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

from ftplib import FTP

def upload(f, remote_path, local_path):

    fp = open(local_path, "rb") #,encoding='utf-8'

    buf_size = 1024

    # f.storbinary("STOR "+remote_path+r"/aa.xls", fp, buf_size)   #纯英文文件名ok

    filenam2=local_path[local_path.rfind('\\')+1:].strip()

    print(filenam2+"#"+remote_path+"#"+local_path)

    f.storbinary("STOR "+remote_path+filenam2, fp, buf_size)  

    fp.close()

def main(args):

    ftp = FTP()

    ftp.encoding='gbk'#  ok  这里最重要

    ftp.connect(glv['gvarFtpSerIP'], 30000)      # 第一个参数可以是ftp服务器的ip或者域名，第二个参数为ftp服务器的连接端口，默认为21

    ftp.set_debuglevel(2)

    ftp.login(glv['gvarFtpUid'], glv['gvarFtpPs'])     # 匿名登录直接使用ftp.login()

    ftp.cwd(glv['gvarRemotPath'])                # 切换到tmp目录

    upload(ftp,"/sjzt/pp/ds/douyin/",r"C:\[20250411]_[抖音]_[XXXX服饰旗舰店]_[视频合作视频数据]_[1744461854].xlsx")   # 将当前目录下的a.txt文件上传到ftp服务器的tmp目录，命名为ftp_a.txt 

    # 上面也是Ok 的

    # download(ftp, "ftp_a.txt", "b.txt")  # 将ftp服务器tmp目录下的ftp_a.txt文件下载到当前目录，命名为b.txt

    ftp.quit()