|
@@ -241,7 +241,7 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
|
|
|
|
|
|
d_start_time = time.time()
|
|
|
if not local_exists:
|
|
|
- log("md5:%s path:%s not exists,start downloading"%(filemd5,objectPath[5:]))
|
|
|
+ log("md5:%s path:%s not exists,start downloading"%(filemd5,objectPath))
|
|
|
try:
|
|
|
download_succeed = downloadFile(self.bucket,objectPath,localpath)
|
|
|
except Exception as e:
|
|
@@ -436,6 +436,8 @@ class Dataflow_ActivteMQ_attachment(Dataflow_attachment):
|
|
|
list_not_in_md5.append(_filemd5)
|
|
|
_path = self.getAttachPath(_filemd5,_dochtmlcon)
|
|
|
if _path is not None:
|
|
|
+ if _path[0]=="/":
|
|
|
+ _path = _path[1:]
|
|
|
_filetype = _path.split(".")[-1]
|
|
|
_attach = {attachment_filemd5:_filemd5,
|
|
|
attachment_filetype:_filetype,
|