背景和目的:
利用python request 编写脚本测试公司系统的文件上传接口。前端读取文件的大小然后文件分片传给后端,后端将每一片数据重新组合成文件。大概的过程是:前端将整个文件的md5、size(大小)、name(文件名)、ext(文件后缀)、totalchunk(分片总数)与分片文件的md5、chunk(分片数据),chunkindex(当前分片文件的下标)等传给后台,后台取得这些数据后,通过chunkindex将每一片数据重组,重组完后,进行md5校验,判断文件上传是否成功。我只需要去调用后台的接口,然后判断文件是否上传成功,并且上传没有错误,其他的文件校验就不用去深究。
开发前端使用的是vue,后台使用的是php,要利用python实现对这一接口的调用,那么就先要将前端数据给模拟出来,然后循环去调用接口,将文件分片上传,我的思路大概如下:
1.获取整个文件的大小、名字、后缀、分片总数,定义每片文件的大小:
def __init__(self,data): dat = json.loads(data) self.path = dat['path'] # 获取文件路径 self.CHUNK_SIZE = 1024*1024*2 # 定义每片文件的大小 self.size = os.path.getsize(dat['path']) # 获取文件的大小 self.totalchunk = math.ceil(self.size / self.CHUNK_SIZE) # 获取文件的分片总数 self.ext = os.path.basename(dat['path']).split('.').pop() # 获取文件的后缀 self.name = os.path.basename(dat['path']) # 获取文件的名字
2.获取文件的md5,查看了开发那边的md5算法,利用python实现过程如下:
# 使用hashlib库的md5方法获取指定文件的md5 def getmd5(self,path): m = hashlib.md5() with open(path, 'rb') as f: for line in f: m.update(line) md5code = m.hexdigest() return md5code # 开发那边对md5的算法进行了优化,当文件的大小小于1M时,直接通过getmd5方法去获取文件的md5值; # 当文件大于1M时,通过截取整个文件中的某几个片段,然后拼接成一个文件,再去获取其md5值,最后删除这个文件 def md5(self,path): if self.size < 1024 * 1024: return self.getmd5(path) f = open(path, 'rb') f.seek(0, 0) data = f.read(2012) f.seek(int(self.size / 2) - 1999, 0) data += f.read(1999) f.seek(-2010, 2) data += f.read(2010) f.close() path = 'D:/copy_' + str(os.path.basename(path)) f = open(path, 'wb') f.write(data) f.close() val = self.getmd5(path) os.remove(path) return val
3.调用文件上传的接口
def uploading(self, chunkIndex): MD5 = self.md5(self.path) # 整个文件的md5 start = (chunkIndex - 1) * self.CHUNK_SIZE # 截取文件的起始位置 end = min(self.size, start + self.CHUNK_SIZE)# 截取文件的结束位置 f = open(self.path, 'rb') f.seek(start) data = f.read(end) # 待分片上传的数据 f.close() path1 = 'D:/copy_' + str(os.path.basename(self.path)) # 将该数据保存在本地 f = open(path1, 'wb') f.write(data) f.close() chunk_md5 = self.md5(path1) # 读取分片上传数据的md5 # 将所有的数据储存在files字典当中,利用requests的files传输数据 # 使用requests files类型时,要像下面一样构建参数,不然会有错误 files={ 'chunk':('blob',data,'application/octet-stream'), 'name':(None,self.name), 'ext':(None,self.ext), 'index':(None,chunkIndex), 'total': (None,self.totalchunk), 'size': (None,self.size), 'chunk_md5': (None,chunk_md5), 'md5': (None,MD5), } # 使用requests发送接口请求 res = self.request.send('post', 'https://10.104.17.222/bank/elements/uploading', verify=False, files=files) os.remove(path1) # 删除存在本地的分片文件 return res.json()
4.循环调用文件上传的接口
chunkIndex = 1 while chunkIndex <= totalchunk: res2 = upload.uploading(chunkIndex) chunkIndex += 1
5.从服务器上去读取通过接口上传的文件的md5值,判断是否正确
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?
更新日志
- 小骆驼-《草原狼2(蓝光CD)》[原抓WAV+CUE]
- 群星《欢迎来到我身边 电影原声专辑》[320K/MP3][105.02MB]
- 群星《欢迎来到我身边 电影原声专辑》[FLAC/分轨][480.9MB]
- 雷婷《梦里蓝天HQⅡ》 2023头版限量编号低速原抓[WAV+CUE][463M]
- 群星《2024好听新歌42》AI调整音效【WAV分轨】
- 王思雨-《思念陪着鸿雁飞》WAV
- 王思雨《喜马拉雅HQ》头版限量编号[WAV+CUE]
- 李健《无时无刻》[WAV+CUE][590M]
- 陈奕迅《酝酿》[WAV分轨][502M]
- 卓依婷《化蝶》2CD[WAV+CUE][1.1G]
- 群星《吉他王(黑胶CD)》[WAV+CUE]
- 齐秦《穿乐(穿越)》[WAV+CUE]
- 发烧珍品《数位CD音响测试-动向效果(九)》【WAV+CUE】
- 邝美云《邝美云精装歌集》[DSF][1.6G]
- 吕方《爱一回伤一回》[WAV+CUE][454M]