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) # 獲取文件的分片總數(shù)
  self.ext = os.path.basename(dat['path']).split('.').pop() # 獲取文件的后綴
  self.name = os.path.basename(dat['path']) # 獲取文件的名字

# 使用hashlib庫(kù)的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

 # 開(kāi)發(fā)那邊對(duì)md5的算法進(jìn)行了優(yōu)化，當(dāng)文件的大小小于1M時(shí)，直接通過(guò)getmd5方法去獲取文件的md5值;
 # 當(dāng)文件大于1M時(shí)，通過(guò)截取整個(gè)文件中的某幾個(gè)片段，然后拼接成一個(gè)文件，再去獲取其md5值，最后刪除這個(gè)文件
 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

def uploading(self, chunkIndex):
  MD5 = self.md5(self.path) # 整個(gè)文件的md5
  start = (chunkIndex - 1) * self.CHUNK_SIZE # 截取文件的起始位置
  end = min(self.size, start + self.CHUNK_SIZE)# 截取文件的結(jié)束位置
  f = open(self.path, 'rb')
  f.seek(start)
  data = f.read(end) # 待分片上傳的數(shù)據(jù)
  f.close()
  path1 = 'D:/copy_' + str(os.path.basename(self.path)) # 將該數(shù)據(jù)保存在本地
  f = open(path1, 'wb')
  f.write(data)
  f.close()
  chunk_md5 = self.md5(path1) # 讀取分片上傳數(shù)據(jù)的md5
  # 將所有的數(shù)據(jù)儲(chǔ)存在files字典當(dāng)中，利用requests的files傳輸數(shù)據(jù)
  # 使用requests files類(lèi)型時(shí)，要像下面一樣構(gòu)建參數(shù)，不然會(huì)有錯(cuò)誤
  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發(fā)送接口請(qǐng)求
  res = self.request.send('post', 'https://10.104.17.222/bank/elements/uploading', verify=False, files=files)
  os.remove(path1) # 刪除存在本地的分片文件
  return res.json()

chunkIndex = 1
 while chunkIndex <= totalchunk:
 res2 = upload.uploading(chunkIndex)
 chunkIndex += 1