修改:租户桶生成文件生命周期规则

This commit is contained in:
yangyang01000846
2026-01-19 15:59:05 +08:00
parent c48a740d17
commit cc22f4fe38

View File

@@ -68,7 +68,18 @@ public class MinioService implements IMinioService {
} catch (Exception e) {
log.error("桶{}初始化失败", minioConfig.getSecretBusinessBucket(), e);
}
createBucketLifecycle(minioConfig.getSpdmBucket(),minioConfig.getLifecycleConfig());
// 设置各个桶标签
try {
List<Bucket> buckets = minioClient.listBuckets();
for (Bucket bucket : buckets) {
if(!Objects.isNull(bucket)
&&org.apache.commons.lang3.StringUtils.isNotBlank(bucket.name())) {
createBucketLifecycle(bucket.name(),minioConfig.getLifecycleConfig());
}
}
}catch (Exception ex){
log.error("data启动初始化桶的生命周期规则失败{}", ex.getMessage());
}
}
@@ -110,7 +121,7 @@ public class MinioService implements IMinioService {
if (!found) {
log.info("系统初始化:创建缺失的租户桶 -> {}", bucketName);
minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
// TODO: 如果需要,可以在这里设置生命周期策略 (Lifecycle Config)
createBucketLifecycle(bucketName,minioConfig.getLifecycleConfig());
}
existingBucketsCache.add(bucketName);
} catch (Exception e) {
@@ -150,6 +161,7 @@ public class MinioService implements IMinioService {
if (!found) {
log.info("运行时检测到新租户桶不存在,正在创建: {}", bucketName);
minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
createBucketLifecycle(bucketName,minioConfig.getLifecycleConfig());
}
existingBucketsCache.add(bucketName);
} catch (Exception e) {
@@ -545,6 +557,7 @@ public class MinioService implements IMinioService {
minioClient.makeBucket(MakeBucketArgs.builder()
.bucket(bucketName)
.build());
createBucketLifecycle(bucketName,minioConfig.getLifecycleConfig());
}
}