etl
/
cloud-etl-rule
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

11111

master
zhang chengzhi 2024-09-04 14:49:39 +08:00
parent 2fe22d4672
commit d0012fadf8
2 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cloud-rule-server/src/main/java/com/muyu/rule/server/DownloadOss.java
View File

@ -46,14 +46,11 @@ private static String serverPath ="home/source/";
// 获取存储桶信息 // 获取存储桶信息
ObjectListing objectListing = ossClient.listObjects(bucketName); ObjectListing objectListing = ossClient.listObjects(bucketName);
// 循环获取存储桶中的所有对象 // 循环获取存储桶中的所有对象
for (OSSObjectSummary objectSummary : objectListing.getObjectSummaries()) { for (OSSObjectSummary objectSummary : objectListing.getObjectSummaries()) {
String key = objectSummary.getKey(); String key = objectSummary.getKey();
downloadFile(ossClient, bucketName, key, serverPath); downloadFile(ossClient, bucketName, key, serverPath);
} }
// 关闭OSSClient // 关闭OSSClient
ossClient.shutdown(); ossClient.shutdown();
} }
@ -66,7 +63,6 @@ private void downloadFile(OSS ossClient, String bucketName, String key, String
if (!serverFile.getParentFile().exists()){ if (!serverFile.getParentFile().exists()){
serverFile.getParentFile().mkdirs(); serverFile.getParentFile().mkdirs();
} }
//下载文件到项目中 //下载文件到项目中
OSSObject ossObject = ossClient.getObject(new GetObjectRequest(bucketName, key)); OSSObject ossObject = ossClient.getObject(new GetObjectRequest(bucketName, key));
@ -81,7 +77,6 @@ private void downloadFile(OSS ossClient, String bucketName, String key, String
log.error("下载文件失败:"+key); log.error("下载文件失败:"+key);
e.printStackTrace(); e.printStackTrace();
} }
} }
} }

12
cloud-rule-server/src/main/java/com/muyu/rule/server/EngineConfig.java
View File

@ -35,16 +35,22 @@ public class EngineConfig {
*/ */
private String localTarget ="D:\\config\\engine\\target\\"; private String localTarget ="D:\\config\\engine\\target\\";
/**
* 服务器的源文件位置
*/
private static String serverPath ="home/source/";
/**
* 服务器的编译文件位置
*/
private static String ClassPath ="home/class/";
/** /**
* 服务器目录路径 * 服务器目录路径
* @return * @return
*/ */
//private String serverPath = "home/"; //private String serverPath = "home/";
private String serverPath = "home/";
// private String serverPath = "home/config/source/"; // private String serverPath = "home/config/source/";
/** /**