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;
@@ -27,6 +28,8 @@
    @Value("${influx-db.url}")
    public String url;

    private final static String BUCKET_NAME = "tenant_";

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

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

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

}