update

pool_predict.py

@@ -117,5 +117,5 @@ if __name__ == '__main__':
         log_.info('{} predict end...'.format(app_name))
     log_.info('flow pool predict end...')
     # 将日志上传到oss
-    log_cmd = "ossutil cp -r {} oss://{}/{}".format(log_.logname, config_.BUCKET_NAME, config_.OSS_FOLDER_LOGS)
+    log_cmd = "ossutil cp -r -f {} oss://{}/{}".format(log_.logname, config_.BUCKET_NAME, config_.OSS_FOLDER_LOGS)
     os.system(log_cmd)

rov_data_check.py

@@ -15,10 +15,10 @@ def rov_train_recall_pool_update():
     # 训练数据和预测数据都准备好时，更新模型，预测
     os.system('sh /data/rov-offline/rov_train_recall_pool_update.sh')
     # 将日志上传到oss
-    log_cmd = "ossutil cp -r {} oss://{}/{}".format(log_.logname, config_.BUCKET_NAME, config_.OSS_FOLDER_LOGS)
+    log_cmd = "ossutil cp -r -f {} oss://{}/{}".format(log_.logname, config_.BUCKET_NAME, config_.OSS_FOLDER_LOGS)
     os.system(log_cmd)
     # 将data上传到oss
-    data_cmd = "ossutil cp -r {} oss://{}/{}".format("/data/rov-offline/data",
+    data_cmd = "ossutil cp -r -f {} oss://{}/{}".format("/data/rov-offline/data",
                                                      config_.BUCKET_NAME, config_.OSS_FOLDER_DATA)
     os.system(data_cmd)