|
@@ -69,8 +69,6 @@ if __name__ == '__main__':
|
|
|
done5 = False
|
|
done5 = False
|
|
|
done6 = False
|
|
done6 = False
|
|
|
done7 = False
|
|
done7 = False
|
|
|
- done8 = False
|
|
|
|
|
- done9 = False
|
|
|
|
|
# print '检测是否文件完整：', prefix
|
|
# print '检测是否文件完整：', prefix
|
|
|
for obj2 in oss2.ObjectIterator(bucket, prefix=prefix):
|
|
for obj2 in oss2.ObjectIterator(bucket, prefix=prefix):
|
|
|
if '/ego_pji.csv' in str(obj2.key):
|
|
if '/ego_pji.csv' in str(obj2.key):
|
|
@@ -86,8 +84,8 @@ if __name__ == '__main__':
|
|
|
if '/trajectory_pji.csv' in str(obj2.key):
|
|
if '/trajectory_pji.csv' in str(obj2.key):
|
|
|
done6 = True
|
|
done6 = True
|
|
|
if '/report.pdf' in str(obj2.key):
|
|
if '/report.pdf' in str(obj2.key):
|
|
|
- done9 = True
|
|
|
|
|
- if not done1 or not done2 or not done3 or not done4 or not done5 or not done6 or not done7 or not done8 or not done9:
|
|
|
|
|
|
|
+ done7 = True
|
|
|
|
|
+ if not done1 or not done2 or not done3 or not done4 or not done5 or not done6 or not done7:
|
|
|
continue
|
|
continue
|
|
|
time.sleep(1)
|
|
time.sleep(1)
|
|
|
logging.info("发送： %s", str(obj1.key))
|
|
logging.info("发送： %s", str(obj1.key))
|
