4
4
import json
5
5
import os
6
6
import tempfile
7
+ from qiniu .compat import is_py2 , is_py3
7
8
8
9
9
10
class UploadProgressRecorder (object ):
@@ -27,8 +28,11 @@ def __init__(self, record_folder=tempfile.gettempdir()):
27
28
28
29
def get_upload_record (self , file_name , key ):
29
30
record_key = '{0}/{1}' .format (key , file_name )
31
+ if is_py2 :
32
+ record_file_name = hashlib .md5 (record_key ).hexdigest ()
33
+ else :
34
+ record_file_name = hashlib .md5 (record_key .encode ('utf-8' )).hexdigest ()
30
35
31
- record_file_name = hashlib .md5 (record_key .encode ('utf-8' )).hexdigest ()
32
36
upload_record_file_path = os .path .join (self .record_folder , record_file_name )
33
37
if not os .path .isfile (upload_record_file_path ):
34
38
return None
@@ -38,13 +42,21 @@ def get_upload_record(self, file_name, key):
38
42
39
43
def set_upload_record (self , file_name , key , data ):
40
44
record_key = '{0}/{1}' .format (key , file_name )
41
- record_file_name = hashlib .md5 (record_key .encode ('utf-8' )).hexdigest ()
45
+ if is_py2 :
46
+ record_file_name = hashlib .md5 (record_key ).hexdigest ()
47
+ else :
48
+ record_file_name = hashlib .md5 (record_key .encode ('utf-8' )).hexdigest ()
49
+
42
50
upload_record_file_path = os .path .join (self .record_folder , record_file_name )
43
51
with open (upload_record_file_path , 'w' ) as f :
44
52
json .dump (data , f )
45
53
46
54
def delete_upload_record (self , file_name , key ):
47
55
record_key = '{0}/{1}' .format (key , file_name )
48
- record_file_name = hashlib .md5 (record_key .encode ('utf-8' )).hexdigest ()
56
+ if is_py2 :
57
+ record_file_name = hashlib .md5 (record_key ).hexdigest ()
58
+ else :
59
+ record_file_name = hashlib .md5 (record_key .encode ('utf-8' )).hexdigest ()
60
+
49
61
upload_record_file_path = os .path .join (self .record_folder , record_file_name )
50
62
os .remove (upload_record_file_path )
0 commit comments