|
@@ -32,7 +32,6 @@ def parse_csv(data_bag, parse_prefix, local_parse_dir, local_delete_list):
|
|
|
|
|
|
csv_file_name2 = 'ego_pji'
|
|
csv_file_name2 = 'ego_pji'
|
|
local_csv_file_path2 = str(local_csv_dir) + '/' + str(csv_file_name2) + '.csv'
|
|
local_csv_file_path2 = str(local_csv_dir) + '/' + str(csv_file_name2) + '.csv'
|
|
- local_delete_list.append(local_csv_file_path2)
|
|
|
|
oss_csv_object_key2 = parse_prefix + csv_file_name2 + '.csv'
|
|
oss_csv_object_key2 = parse_prefix + csv_file_name2 + '.csv'
|
|
bucket.put_object_from_file(oss_csv_object_key2, local_csv_file_path2)
|
|
bucket.put_object_from_file(oss_csv_object_key2, local_csv_file_path2)
|
|
|
|
|