fastDFS

docker 部署fastDFS

docker pull delron/fastdfs

docker-compose.yml

version: '3'services:fastdfs_tracker:image: delron/fastdfs:latestcontainer_name: trackerhostname: trackernetwork_mode: hostports:- "22122:22122"volumes:- ./data/tracker:/var/fdfscommand: trackerrestart: unless-stoppedfastdfs_storage:image: delron/fastdfs:latestcontainer_name: storagehostname: storagenetwork_mode: hostports:- "8888:8888"- "23000:23000"environment:- TRACKER_SERVER=服务器ip:22122volumes:- ./data/storage:/var/fdfsdepends_on:- fastdfs_trackercommand: storagerestart: unless-stopped

注意修改docker-compose.yml中的服务器ip

python操作fastDFS

pip3 install fdfs-client-py3

fdfs_tracker.conf
connect_timeout=30
network_timeout=60
tracker_server = 127.0.0.1:22122
http.tracker_server_port = 8888

from fdfs_client.client import Fdfs_clientdef mkdir_p(path):Path(path).mkdir(parents=True, exist_ok=True)class FdfsClient:def __init__(self):tracker_conf_path = "./fdfs_tracker.conf"  # tracker配置文件的地址self.client = Fdfs_client(client=tracker_conf_path)def upload_by_filename(self, file_path):'''文件上传当有一个文件在本地磁盘上，并且知道文件的路径时，可以使用这个方法:param file: 文件路径:return:{'Group name': 'group1', 'Remote file_id': 'group1/M00/00/00/PAo80GdNlk0AAAABAwXgAHrGIgk207.iso','Status': 'Upload successed.', 'Local file name': '/home/wangxiuyan/06-vm/iso/xxxxxxxxx.iso','Uploaded size': '4.05GB', 'Storage IP': '60.10.60.208'}'''ret = self.client.upload_by_filename(file_path)print(ret)return retdef upload_by_buffer(self, file_buffer, file_name):'''文件上传当已经将文件读取到内存中（例如从网络下载的数据、从数据库获取的数据等），或者直接上传内存中的数据时，可以使用这个方法:param file_buffer: 文件二进制内容:param file_name: 文件名:return:'''ret = self.client.upload_by_buffer(file_buffer, file_name)print(ret)return retdef delete_file(self, file_id):'''删除文件:param file_id: 文件在fastDFS中的 Remote file_id:return:'''ret = self.client.delete_file(file_id)print(ret)return retdef download_to_file(self, save_path, file_id):'''下载文件:param save_path: 文件保存路径:param file_id: 文件在fastDFS中的 Remote file_id:return:'''res = self.client.download_to_file(save_path, file_id)print(res)return resdef list_all_groups(self):ret = self.client.list_all_groups()print(ret)return retdef get_meta_data(self, file_id):ret = self.client.get_meta_data(file_id)print(ret)return ret