From 48fb4a5dd568d3d02cfb607fe4010b448cd54c8b Mon Sep 17 00:00:00 2001 From: dengzedong <dengzedong@email> Date: 星期二, 14 一月 2025 09:40:21 +0800 Subject: [PATCH] 创建Bucket,增加设置过期时间 --- iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/influxdb/common/config/InfluxDBInstance.java | 6 +++++- 1 files changed, 5 insertions(+), 1 deletions(-) diff --git a/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/influxdb/common/config/InfluxDBInstance.java b/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/influxdb/common/config/InfluxDBInstance.java index f2d2075..e2dbb92 100644 --- a/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/influxdb/common/config/InfluxDBInstance.java +++ b/iailab-module-model/iailab-module-model-biz/src/main/java/com/iailab/module/model/influxdb/common/config/InfluxDBInstance.java @@ -4,6 +4,7 @@ import com.influxdb.client.InfluxDBClient; import com.influxdb.client.InfluxDBClientFactory; import com.influxdb.client.domain.Bucket; +import com.influxdb.client.domain.BucketRetentionRules; import com.influxdb.client.domain.Organization; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -40,6 +41,8 @@ private Logger logger = LoggerFactory.getLogger(getClass()); private InfluxDBClient client; + // bucket过期时间 + private Integer everySeconds = 3600 * 24 * 10; public InfluxDBClient getClient() { try { @@ -60,7 +63,8 @@ Bucket bucketByName = client.getBucketsApi().findBucketByName(bucketName); if (null == bucketByName) { Organization organization = client.getOrganizationsApi().findOrganizations().stream().filter(e -> e.getName().equals(org)).findFirst().orElseThrow(() -> new RuntimeException("influxdb:org不存在,org:" + org)); - client.getBucketsApi().createBucket(bucketName,organization); + // 创建Bucket,并设置过期时间 + client.getBucketsApi().createBucket(bucketName,new BucketRetentionRules().everySeconds(everySeconds),organization); }else { isExistBucket.add(bucketName); } -- Gitblit v1.9.3