iailab-module-data/iailab-module-data-biz/src/main/java/com/iailab/module/data/influxdb/common/config/InfluxDBInstance.java

@@ -1,5 +1,6 @@
package com.iailab.module.data.influxdb.common.config;

import com.iailab.framework.tenant.core.context.TenantContextHolder;
import com.influxdb.client.InfluxDBClient;
import com.influxdb.client.InfluxDBClientFactory;
import org.slf4j.Logger;
@@ -18,14 +19,16 @@
    @Value("${influx-db.org}")
    public String org;

    @Value("${influx-db.bucket}")
    public String bucket;
    /*@Value("${influx-db.bucket}")
    public String bucket;*/

    @Value("${influx-db.token}")
    public String token;

    @Value("${influx-db.url}")
    public String url;

    private final static String BUCKET_NAME = "bucket_";

    private Logger logger = LoggerFactory.getLogger(getClass());

@@ -43,5 +46,8 @@
        return client;
    }

    public String getBucket() {
        return BUCKET_NAME + TenantContextHolder.getRequiredTenantId();
    }

}