Python FTP文件定时自动下载实现过程解析
这篇文章主要介绍了PythonFTP文件定时自动下载实现过程解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
一、需求：
某数据公司每日15:00~17:00之间，在其FTP发布当日数据供下载，我方需及时下载当日数据至指定本地目录。
二、分析：
1、需实现FTP登陆、查询、下载功能；
解答：使用内置的ftplib模块中FTP类；
2、需判断文件是否下载；
解答：使用os模块中path.exists方法；
3、需判断在指定时间段内才执行下载任务；
解答：使用内置的time模块抓取当前时间，并与指定时间做比较；
4、需考虑日期切换问题；
解答：使用内置的time模块抓取当前日期，并与变量中的日期做比较。
三、代码实现
#!/usr/bin/envpython
#_*_coding:utf-8_*_
'''
@Time:2019-11-1113:30
@Author:Peanut_C
@FileName:ftp_auto_download.py
'''
importtime
fromftplibimportFTP
importos
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'
defftp_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)
returnftp
defremote_file_exists():
"""用于FTP站点目标文件存在检测"""
ftp=ftp_connect()
ftp.cwd(remote_path)#进入目标目录
remote_file_names=ftp.nlst()#获取文件列表
ftp.quit()
iftoday_fileinremote_file_names:
returnTrue
else:
returnFalse
defdownload_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()
whileTrue:
ifint(time.strftime("%H%M"))inrange(begin_time,end_time):#判断是否在执行时间范围
ifint(time.strftime("%Y%m%d"))-int(today)==0:#判断是否跨日期
whilenotos.path.exists(local_file):#判断本地是否已有文件
ifremote_file_exists():#判断远端是否已有文件
download_file()
withopen(log_file,'a')asf:
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#本地文件名
withopen(log_file,'a')asf:
f.write('\n'+time.strftime("%Y/%m/%d%H:%M:%S")+"任务启动,文件日期已更新。")
else:
time.sleep(1800)
四、运行情况
保存为pyw文件，任务在后台持续运行，不需要计划任务，省心省力。
不用下载标记，一则较为简洁，二则本地文件如果被人误删或移动可自动重新下载。
日志中，每天仅写入任务启动和文件已下载标志，并记录对应时间，如有需要可再添加。
希望能帮到有需要的朋友。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。