lukeye/doc-parser-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
Luke.Ye 2025-07-10 23:59:58 +08:00
parent 3cf63bb70c
commit b3f988dc17
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/com/knowledge/base/infrastructure/south/minio/MinioOSGatewayImpl.java
View File

@ -52,11 +52,11 @@ public class MinioOSGatewayImpl implements ObjectStorageGateway {
@Override @Override
public void ensureBucketExists(String bucket) throws Exception { public void ensureBucketExists(String bucket) throws Exception {
boolean exists = minioClient.bucketExists( boolean exists = localMinioClient.bucketExists(
BucketExistsArgs.builder().bucket(bucket).build() BucketExistsArgs.builder().bucket(bucket).build()
); );
if (!exists) { if (!exists) {
minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucket).build()); localMinioClient.makeBucket(MakeBucketArgs.builder().bucket(bucket).build());
log.info("已创建 bucket: {}", bucket); log.info("已创建 bucket: {}", bucket);
} }
} }
@ -84,7 +84,7 @@ public class MinioOSGatewayImpl implements ObjectStorageGateway {
return String.format("http://s3.wisdompulse.cn/%s/%s", bucket, objectPath); return String.format("http://s3.wisdompulse.cn/%s/%s", bucket, objectPath);
} else { } else {
// 生成预签名链接（最大 7 天） // 生成预签名链接（最大 7 天）
return minioClient.getPresignedObjectUrl( return localMinioClient.getPresignedObjectUrl(
GetPresignedObjectUrlArgs.builder() GetPresignedObjectUrlArgs.builder()
.method(Method.GET) .method(Method.GET)
.bucket(bucket) .bucket(bucket)
@ -103,7 +103,7 @@ public class MinioOSGatewayImpl implements ObjectStorageGateway {
} }
try { try {
Iterable<Result<DeleteError>> results = minioClient.removeObjects( Iterable<Result<DeleteError>> results = localMinioClient.removeObjects(
RemoveObjectsArgs.builder() RemoveObjectsArgs.builder()
.bucket(bucket) .bucket(bucket)
.objects(objectPaths.stream() .objects(objectPaths.stream()