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

11111

master
zhang chengzhi 2024-09-04 11:53:10 +08:00
parent 1eead15cc6
commit 27743db2b7
1 changed files with 11 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -43,27 +43,22 @@ private static String serverPath ="home/code/";
public void run(ApplicationArguments args) throws Exception { public void run(ApplicationArguments args) throws Exception {
log.info("开始从Oss下载规则引擎"); log.info("开始从Oss下载规则引擎");
OSS ossClient = new OSSClientBuilder().build(endPoint, accessKeyId, accessKeySecret); OSS ossClient = new OSSClientBuilder().build(endPoint, accessKeyId, accessKeySecret);
try {
//获取所有的oss存储的信息 // 获取存储桶信息
ObjectListing objectListing = ossClient.listObjects(bucketName); ObjectListing objectListing = ossClient.listObjects(bucketName);
// 循环获取存储桶中的所有对象
//循环获取存储中的所有对象
while (true) {
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);
} }
}
}finally { // 关闭OSSClient
ossClient.shutdown(); ossClient.shutdown();
}
} }
private static void downloadFile(OSS ossClient, String bucketName, String key, String serverPath){ private void downloadFile(OSS ossClient, String bucketName, String key, String serverPath){
//创建服务器项目容器的文件目录路径 //创建服务器项目容器的文件目录路径
File serverFile = new File(serverPath, key); File serverFile = new File(serverPath, key);