|
@@ -1,5 +1,6 @@
|
|
# -*- coding: utf-8 -*-
|
|
# -*- coding: utf-8 -*-
|
|
import os
|
|
import os
|
|
|
|
+import shutil
|
|
import time
|
|
import time
|
|
import oss2
|
|
import oss2
|
|
|
|
|
|
@@ -43,6 +44,15 @@ def parse_csv(data_bag, parse_prefix, local_parse_dir, local_delete_list):
|
|
oss_csv_object_key4 = parse_prefix + csv_file_name4 + '.csv'
|
|
oss_csv_object_key4 = parse_prefix + csv_file_name4 + '.csv'
|
|
bucket.put_object_from_file(oss_csv_object_key4, local_csv_file_path4)
|
|
bucket.put_object_from_file(oss_csv_object_key4, local_csv_file_path4)
|
|
|
|
|
|
|
|
+ # todo 临时将 ego_pji.csv 复制一个 EgoState_pji.csv,维豪和自豪没对齐
|
|
|
|
+ try:
|
|
|
|
+ shutil.copy(str(local_csv_dir) + '/' + str(csv_file_name2) + '.csv', str(local_csv_dir) + '/' + str('EgoState_pji') + '.csv')
|
|
|
|
+ print("文件复制成功")
|
|
|
|
+ except IOError as e:
|
|
|
|
+ print("无法复制文件。错误:", e)
|
|
|
|
+ except Exception as e:
|
|
|
|
+ print("发生错误:", e)
|
|
|
|
+
|
|
# 生成并上传csv之后,调用
|
|
# 生成并上传csv之后,调用
|
|
os.chdir(path2)
|
|
os.chdir(path2)
|
|
command1 = './pji_outdoor_real ' + str(local_csv_dir) + '/ ' + str(local_csv_dir) + '/ ' + str(
|
|
command1 = './pji_outdoor_real ' + str(local_csv_dir) + '/ ' + str(local_csv_dir) + '/ ' + str(
|