Python实现FTP文件定时自动下载的步骤

Felix

发布时间：2026-10-14 | 5人浏览过

原创

本文详细介绍如何使用Python的ftplib模块实现FTP文件的定时自动下载。通过判断当前时间是否在指定窗口内，并结合os模块检查本地文件状态，脚本可在后台持续运行并自动处理日期切换与断点续传逻辑，无需依赖系统计划任务，适合日常数据同步场景。

此前在技术博客中常获启发，感谢各位作者的无私分享。因自身水平有限且发文较少，知识积累与总结受限。今后将加强总结与分享，既回馈社区，也恳请读者批评指正。

一、需求：

某数据公司每日15:00至17:00期间，通过FTP发布当日数据供下载，我方需在此时段内及时将当日数据下载至指定的本地目录。

二、分析：

1、需实现FTP登录、目录查询及文件下载功能；

解答：使用Python内置的ftplib模块中的FTP类；

2、需判断文件是否已下载；

解答：使用os模块中的path.exists方法；

3、需判断仅在指定时间段内执行下载任务；

解答：使用内置的time模块获取当前时间，并与设定的时间范围进行比较；

4、需考虑日期切换问题；

解答：使用内置的time模块获取当前日期，并与变量中记录的日期进行比较。

三、代码实现


#!/usr/bin/env python
# _*_ coding:utf-8 _*_

'''
@Time  : 2019-11-11 13:30
@Author : Peanut_C
@FileName: ftp_auto_download.py
'''


import time
from ftplib import FTP
import os


remote_path = "/xxx/yy/z/" # 远端目录
begin_time = 1500 # 任务开始时间
end_time = 1700 # 任务结束时间


today = time.strftime("%Y%m%d") # 当天日期
today_file = today + 'test.txt' # 得到当天日期的目标文件名
remote_file = remote_path + today_file # 远端文件名
local_file = '\\\\local\\' + today + '\\' + today_file # 本地文件名
log_file = 'C:\\\\log\\ftp_log.txt'


def ftp_connect():
  """用于FTP连接"""
  ftp_server = 'w.x.y.z' # ftp站点对应的IP地址
  username = 'ftpuser' # 用户名
  password = 'ftppass' # 密码
  ftp = FTP()
  ftp.set_debuglevel(0) # 较高的级别方便排查问题
  ftp.connect(ftp_server, 21)
  ftp.login(username, password)
  return ftp

def remote_file_exists():
  """用于FTP站点目标文件存在检测"""
  ftp = ftp_connect()
  ftp.cwd(remote_path) # 进入目标目录
  remote_file_names = ftp.nlst() # 获取文件列表
  ftp.quit()
  if today_file in remote_file_names:
    return True
  else:
    return False

def download_file():
  """用于目标文件下载"""
  ftp = ftp_connect()
  bufsize = 1024
  fp = open(local_file, 'wb')
  ftp.set_debuglevel(0) # 较高的级别方便排查问题
  ftp.retrbinary('RETR ' + remote_file, fp.write, bufsize)
  fp.close()
  ftp.quit()


while True:
  if int(time.strftime("%H%M")) in range(begin_time, end_time): # 判断是否在执行时间范围
    if int(time.strftime("%Y%m%d")) - int(today) == 0: # 判断是否跨日期
      while not os.path.exists(local_file): # 判断本地是否已有文件
        if remote_file_exists(): # 判断远端是否已有文件
          download_file()
          with open(log_file, 'a') as f:
            f.write('\n' + time.strftime("%Y/%m/%d %H:%M:%S") + " 今日文件已下载！")
          time.sleep(60) # 下载完毕静默1分钟
        else:
          time.sleep(180)
          break # 注意，此处跳出循环重新判断日期，避免周末或当天没文件时陷入内层循环
      else:
        time.sleep(180)
    else:
      """如果跨日期，则根据当前日期，更新各文件日期"""
      today = time.strftime("%Y%m%d") # 当天日期
      today_file = today + 'test.txt' # 得到当天日期的目标文件名
      remote_file = remote_path + today_file # 远端文件名
      local_file = '\\\\local\\' + today + '\\' + today_file # 本地文件名
      with open(log_file, 'a') as f:
        f.write('\n' + time.strftime("%Y/%m/%d %H:%M:%S") + " 任务启动, 文件日期已更新。")
  else:
    time.sleep(1800)