一、FTP基础知识
FTP（File Transfer Protocol）是一种传输文件的协议，基于客户机/服务器模式，通过可靠的TCP连接进行数据传输。FTP包括两个部分：FTP服务器和FTP客户端。FTP服务器是存储文件的计算机，而FTP客户端是连接到FTP服务器并下载或上传文件的计算机。FTP客户端通过使用FTP命令（例如PUT、GET、LS等）与FTP服务器建立通信。
FTP协议支持两种传输模式：ASCII模式和二进制模式。ASCII模式用于传输文本文件，而二进制模式适用于传输非文本文件（例如图像和音频文件）。除此之外，FTP还支持匿名登录和加密通讯。
二、FTP功能实现
1. 连接FTP服务器
import ftplib
# 连接FTP服务器
ftp = ftplib.FTP()
ftp.connect('ftp.example.com', port=21)
ftp.login('username', 'password')
在此代码片段中，我们使用Python内置的ftplib库连接FTP服务器。connect()命令用于连接服务器，其中'ftp.example.com'是FTP服务器的地址，21是FTP服务器的端口。login()函数用于登录FTP服务器，其中'username'和'password'是FTP服务器的登录凭据。
2. 下载文件
# 下载文件
ftp.retrbinary('RETR filename', open('filename', 'wb').write)
在此代码片段中，我们使用retrbinary()函数从FTP服务器下载文件。'RETR filename'是要下载的文件的名称，'filename'是要保存的本地文件的名称。在这个例子中，我们使用Python内置的open()函数打开本地文件，'wb'代表二进制写模式。
3. 上传文件
# 上传文件
with open('filename', 'rb') as file:
ftp.storbinary('STOR filename', file)
在此代码片段中，我们使用storbinary()函数将文件上传到FTP服务器。'STOR filename'是要上传的文件的名称。在这个例子中，我们使用Python内置的open()函数打开要上传的本地文件，'rb'代表二进制读模式。然后，我们使用with语句将文件传递给storbinary()函数。
4. 删除文件
# 删除文件
ftp.delete('filename')
在此代码片段中，我们使用delete()函数从FTP服务器上删除文件。'filename'是要删除的文件的名称。
三、FTP功能应用
1. 批量下载文件
假设我们需要从FTP服务器上下载多个文件，我们可以编写一个Python脚本批量下载这些文件。
import ftplib
# 连接FTP服务器
ftp = ftplib.FTP()
ftp.connect('ftp.example.com', port=21)
ftp.login('username', 'password')
# 下载多个文件
files = ['file1.txt', 'file2.txt', 'file3.txt']
for file in files:
ftp.retrbinary('RETR ' + file, open(file, 'wb').write)
# 关闭FTP连接
ftp.quit()
2. 自动化备份数据
我们可以编写一个Python脚本来自动备份FTP服务器上的数据。以下代码演示了如何备份FTP服务器上的文件并将其保存到本地文件夹中。
import ftplib
import datetime
# 连接FTP服务器
ftp = ftplib.FTP()
ftp.connect('ftp.example.com', port=21)
ftp.login('username', 'password')
# 文件备份
remote_directory = 'data/'
local_directory = 'backup/folder/'
files = ftp.nlst(remote_directory)
for file in files:
with open(local_directory + file, 'wb') as f:
ftp.retrbinary('RETR ' + remote_directory + file, f.write)
# 关闭FTP连接
ftp.quit()
# 文件压缩
import zipfile
file_name = 'backup-' + str(datetime.datetime.now().strftime('%Y-%m-%d')) + '.zip'
with zipfile.ZipFile(file_name, mode='w') as backup:
for foldername, subfolders, filenames in os.walk('backup'):
for filename in filenames:
backup.write(os.path.join(foldername, filename))
# 删除未压缩文件
shutil.rmtree('backup/folder/')
在此代码片段中，我们使用Python内置的datetime、os、shutil和zipfile库备份FTP服务器上的数据。首先，我们连接到FTP服务器，并使用nlst()函数获取需要备份的文件列表。然后，我们使用retrbinary()函数将每个文件下载到本地文件夹中。一旦备份完成，我们使用zipfile.ZipFile()创建一个压缩文件，将备份文件添加到其中。最后，我们删除未压缩的备份文件夹。
3. 监控FTP服务器上的文件变化
我们可以使用Python的watchdog库监控FTP服务器上的文件变化。在以下代码中，我们使用FTP连接对象和watchdog库的Observer类实现文件监控。
import ftplib
import os
import time
from watchdog.observers import Observer
from watchdog.events import FileSystemEventHandler
class FTPMonitor(FileSystemEventHandler):
def __init__(self, ftp):
super().__init__()
self.ftp = ftp
def on_created(self, event):
if event.is_directory:
return None
local_path = event.src_path
remote_path = 'data/' + os.path.basename(event.src_path)
with open(local_path, 'rb') as f:
self.ftp.storbinary('STOR ' + remote_path, f)
def on_modified(self, event):
self.on_created(event)
if __name__ == '__main__':
# 连接FTP服务器
ftp = ftplib.FTP()
ftp.connect('ftp.example.com', port=21)
ftp.login('username', 'password')
# 监控FTP服务器文件变化
folder_to_track = 'watch_folder'
observer = Observer()
event_handler = FTPMonitor(ftp)
observer.schedule(event_handler, folder_to_track, recursive=True)
observer.start()
try:
while True:
time.sleep(1)
except KeyboardInterrupt:
observer.stop()
observer.join()
# 关闭FTP连接
ftp.quit()
四、小结
FTP是一种广泛使用的文件传输协议，可帮助开发人员更轻松地传输文件。Python内置的ftplib库可用于连接FTP服务器并执行各种文件传输操作，例如下载、上传和删除文件。此外，Python还有许多其他库可用于FTP功能，包括datetime、os、shutil和watchdog。
