首页 >后端开发 >Python教程 >python3写的简单本地文件上传服务器实例

python3写的简单本地文件上传服务器实例

不言原创: 2018-06-04 11:55:241622浏览

这篇文章主要介绍了关于python3写的简单本地文件上传服务器实例，有着一定的参考价值，现在分享给大家，有需要的朋友可以参考一下

python是个很好玩的东西？好吧我随口说的，反正因为各种原因（其实到底是啥我也不知道），简单的学习了下python，然后写了一个上传文件上服务器的小玩具练手。

大概功能是这样：

1、获取本地文件列表（包括文件夹）

2、检查服务器上是否存在，不存在直接上传，存在的话，文件夹无视，文件比较大小，大小不一致则覆盖，最后检查服务器上是否存在本地没有的文件，存在则删除

3、之后增加了忽略列表，忽略文件类型

4、然后增加了重启tomcat，但是这个功能未进行测试

大概就是这个样子，哦了，丢代码丢代码

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
import os 
import os.path 
import paramiko
import datetime
import re

# 配置属性
config = {
	#本地项目路径
	&#39;local_path&#39; : &#39;&#39;,
	# 服务器项目路径
	&#39;ssh_path&#39; : &#39;&#39;,
	# 项目名
	&#39;project_name&#39; : &#39;&#39;,
	# 忽视列表
	&#39;ignore_list&#39; : [],
	# ssh地址、端口、用户名、密码
	&#39;hostname&#39; : &#39;&#39;,
	&#39;port&#39; : 22,
	&#39;username&#39; : &#39;&#39;,
	&#39;password&#39; : &#39;&#39;,
	# 是否强制更新
	&#39;mandatory_update&#39; : False,
	# 更新完成后是否重启tomcat
	&#39;restart_tomcat&#39; : False,
	# tomcat bin地址
	&#39;tomcat_path&#39; : &#39;&#39;,
	# 被忽略的文件类型
	&#39;ignore_file_type_list&#39; : []
}

# 检查文件夹是否存在，不存在则创建
def check_folder(path):
	stdin, stdout, stderr = ssh.exec_command(&#39;find &#39; + path)
	result = stdout.read().decode(&#39;utf-8&#39;)
	if len(result) == 0 :
		print(&#39;目录 %s 不存在，创建目录&#39; % path)
		ssh.exec_command(&#39;mkdir &#39; + path)
		print(&#39;%s 创建成功&#39; % path)
		return 1
	else:
		print(&#39;目录 %s 已存在&#39; % path)
		return 0

# 检查文件是否存在，不存在直接上传，存在检查大小是否一样，不一样则上传
def check_file(local_path, ssh_path):
	# 检查文件是否存在，不存在直接上传
	stdin, stdout, stderr = ssh.exec_command(&#39;find &#39; + ssh_path)
	result = stdout.read().decode(&#39;utf-8&#39;)
	if len(result) == 0 :
		sftp.put(local_path,ssh_path)
		print(&#39;%s 上传成功&#39; % (ssh_path))
		return 1
	else:
		# 存在则比较文件大小
		# 本地文件大小
		lf_size = os.path.getsize(local_path)
		# 目标文件大小
		stdin, stdout, stderr = ssh.exec_command(&#39;du -b &#39; + ssh_path)
		result = stdout.read().decode(&#39;utf-8&#39;)
		tf_size = int(result.split(&#39;\t&#39;)[0])
		print(&#39;本地文件大小为：%s，远程文件大小为：%s&#39; % (lf_size, tf_size))
		if lf_size == tf_size:
			print(&#39;%s 大小与本地文件相同，不更新&#39; % (ssh_path))
			return 0
		else:
			sftp.put(local_path,ssh_path)
			print(&#39;%s 更新成功&#39; % (ssh_path))
			return 1

# 上传流程开始
print(&#39;上传开始&#39;)
begin = datetime.datetime.now()

# 文件夹列表
folder_list = []
# 文件列表
file_list = []
# ssh上文件列表
ssh_file_list = []

for parent,dirnames,filenames in os.walk(config[&#39;local_path&#39;]+config[&#39;project_name&#39;]): 
 #初始化文件夹列表
 for dirname in dirnames:
 	p = os.path.join(parent,dirname)
 	folder_list.append(p[p.find(config[&#39;project_name&#39;]):])
 #初始化文件列表
 for filename in filenames:
 	if config[&#39;ignore_list&#39;].count(filename) == 0:
 		p = os.path.join(parent,filename)
 		file_list.append(p[p.find(config[&#39;project_name&#39;]):])

print(&#39;共有文件夹%s个，文件%s个&#39; % (len(folder_list),len(file_list)))

# ssh控制台
ssh = paramiko.SSHClient()
ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
ssh.connect(hostname=config[&#39;hostname&#39;], port=config[&#39;port&#39;], username=config[&#39;username&#39;], password=config[&#39;password&#39;])
# ssh传输
transport = paramiko.Transport((config[&#39;hostname&#39;],config[&#39;port&#39;]))
transport.connect(username=config[&#39;username&#39;],password=config[&#39;password&#39;])
sftp = paramiko.SFTPClient.from_transport(transport)

# 检查根目录是否存在
root_path = config[&#39;ssh_path&#39;] + config[&#39;project_name&#39;]
stdin, stdout, stderr = ssh.exec_command(&#39;find &#39; + root_path)
result = stdout.read().decode(&#39;utf-8&#39;)
if len(result) == 0 :
	print(&#39;目录 %s 不存在，创建目录&#39; % root_path)
	ssh.exec_command(&#39;mkdir &#39; + root_path)
	print(&#39;%s 创建成功&#39; % root_path)
else:
	print(&#39;目录 %s 已存在，获取所有文件&#39; % root_path)
	ssh_file_list = re.split(&#39;\n&#39;,result)

# 检查文件夹
create_folder_num = 0
for item in folder_list:
	target_folder_path = config[&#39;ssh_path&#39;] + item
	create_folder_num = create_folder_num + check_folder(target_folder_path)

# 检查文件
update_file_num = 0
for item in file_list:
	if config[&#39;ignore_file_type_list&#39;].count(os.path.splitext(item)[1]) == 0:
		local_file_path = config[&#39;local_path&#39;] + item
		target_file_path = config[&#39;ssh_path&#39;] + item
		if config[&#39;mandatory_update&#39;]:
			sftp.put(local_file_path,target_file_path)
			print(&#39;%s 强制更新成功&#39; % (target_file_path))
			update_file_num = update_file_num + 1
		else:
			update_file_num = update_file_num + check_file(local_file_path, target_file_path)
	else:
		print(&#39;%s 在被忽略文件类型中，所以被忽略&#39; % item)

# 检查ssh是否有需要删除的文件
delete_file_num = 0
for item in ssh_file_list:
	temp = item[item.find(config[&#39;project_name&#39;]):]
	if folder_list.count(temp) == 0 and file_list.count(temp) == 0 and temp != config[&#39;project_name&#39;] and temp != &#39;&#39;:
		print(&#39;%s 在本地不存在，删除&#39; % item)
		ssh.exec_command(&#39;rm -rf &#39; + item)
		delete_file_num = delete_file_num + 1

end = datetime.datetime.now()
print(&#39;本次上传结束：创建文件夹%s个，更新文件%s个，删除文件%s个，耗时：%s&#39; % (create_folder_num, update_file_num, delete_file_num, end-begin))

if config[&#39;restart_tomcat&#39;]:
	print(&#39;关闭tomcat&#39;)
	ssh.exec_command(&#39;sh &#39; + config[&#39;tomcat_path&#39;] + &#39;shutdown.sh&#39;)
	print(&#39;启动tomcat&#39;)
	ssh.exec_command(&#39;sh &#39; + config[&#39;tomcat_path&#39;] + &#39;startup.sh&#39;)

# 关闭连接
sftp.close()
ssh.close()

最后加了个强制更新，即不管三七二十一只要不在忽略列表中直接上传覆盖，毕竟通过比较大小来更新文件有概率出问题，比如我把1改成2那么通过文件大小是无法对比出来的，如果之后有时间的话会琢磨下拉取git更新记录或者别的方案。

python3写的简单本地文件上传服务器实例

相关文章