Merge branch 'dev/dev_xp' into dev/3.1_release_merge
# Conflicts: # src/main/java/com/ai/da/python/PythonService.java # src/main/java/com/ai/da/service/impl/GenerateServiceImpl.java
This commit is contained in:
@@ -908,6 +908,47 @@ public class MinioUtil {
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
* 将A桶中的对象复制到B桶中
|
||||
* @return
|
||||
*/
|
||||
public void copyObject(String sourceBucket, String sourceObject, String targetBucket, String targetObject) {
|
||||
// 检查目标桶是否存在
|
||||
boolean found;
|
||||
try {
|
||||
found = minioClient.bucketExists(BucketExistsArgs.builder()
|
||||
.bucket(targetBucket)
|
||||
.build());
|
||||
} catch (Exception e) {
|
||||
log.error("目标桶{},不存在", targetBucket);
|
||||
throw new BusinessException("Copy object failed");
|
||||
}
|
||||
|
||||
if (found) {
|
||||
// 复制对象
|
||||
try {
|
||||
minioClient.copyObject(
|
||||
CopyObjectArgs.builder()
|
||||
.bucket(targetBucket)
|
||||
.object(targetObject)
|
||||
.source(
|
||||
CopySource.builder()
|
||||
.bucket(sourceBucket)
|
||||
.object(sourceObject)
|
||||
.build()
|
||||
)
|
||||
.build()
|
||||
);
|
||||
} catch (Exception e) {
|
||||
log.error("对象复制失败");
|
||||
throw new BusinessException("Copy object failed");
|
||||
}
|
||||
log.info("对象复制成功");
|
||||
} else {
|
||||
log.error("目标桶{},不存在", targetBucket);
|
||||
throw new BusinessException("Copy object failed");
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user