ops / monitor-service · Commits

Go to a project

Authored by zhengyouwei
Commit bc29f341f21c76f9edeb9d6d52e9716bc9160389 1 parent 37edde67

influxdb to 2.4

Inline Side-by-side
Showing 2 changed files with 10 additions and 12 deletions
package com.monitor.influxdb;
import com.squareup.okhttp.OkHttpClient;
import okhttp3.OkHttpClient;
import org.influxdb.InfluxDB;
import org.influxdb.InfluxDBFactory;
import retrofit.client.OkClient;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
... ... @@ -34,14 +31,15 @@ public class InluxDBSingle {
influxDBModel.setIp(ipsArray[i]);
influxDBModel.setUser(usersArray[i]);
influxDBModel.setPwd(pwdsArray[i]);
OkHttpClient okHttpClient = new OkHttpClient();
okHttpClient.setConnectTimeout(Integer.valueOf(connectTimeOutArray[i]), TimeUnit.SECONDS);
okHttpClient.setReadTimeout(Integer.valueOf(readTimeOutArray[i]), TimeUnit.SECONDS);
okHttpClient.setWriteTimeout(Integer.valueOf(writeTimeOutArray[i]), TimeUnit.SECONDS);
OkHttpClient.Builder builder = new OkHttpClient.Builder();
builder.connectTimeout(Integer.valueOf(connectTimeOutArray[i]), TimeUnit.SECONDS);
builder.readTimeout(Integer.valueOf(readTimeOutArray[i]), TimeUnit.SECONDS);
builder.writeTimeout(Integer.valueOf(writeTimeOutArray[i]), TimeUnit.SECONDS);
InfluxDB influxDB = InfluxDBFactory.connect(ipsArray[i],
usersArray[i], pwdsArray[i],new OkClient(okHttpClient));
usersArray[i], pwdsArray[i],builder);
influxDB.enableBatch(100, 30, TimeUnit.SECONDS);
influxDBModel.setInfluxDB(influxDB);
map.put(namesArray[i], influxDBModel);
... ...
... ... @@ -19,7 +19,7 @@
<project-name>monitor-service</project-name>
<project-version>1.0-SNAPSHOT</project-version>
<json-version>2.4</json-version>
<db-influx-version>2.2</db-influx-version>
<db-influx-version>2.4</db-influx-version>
<java-gitlab-api-version>1.2.5</java-gitlab-api-version>
<org.yaml-version>1.9</org.yaml-version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
... ...