Hallo!
Ich möchte den InfluxDB Client nutzen, um Daten in eine Influx Datenbank zu schreiben:
github.com
Meine Upload Klasse sieht so aus:
Bei der Zeile:
writeApi.writePoints(bucket, org, uploadPayload);
erhalte ich in Eclipse den Fehler:
The type com.influxdb.exceptions.InfluxException cannot be resolved. It is indirectly referenced from required type com.influxdb.client.WriteApiBlocking
Es fehlt wohl die "com.influxdb.exceptions.InfluxException". Ich habe als Client die Version 7.1.0 von Maven geladen:
Da sehe ich aber keine entsprechendes .jar File
Kennt sich da jemand mit InfluxDB aus?
Danke!
Ich möchte den InfluxDB Client nutzen, um Daten in eine Influx Datenbank zu schreiben:
GitHub - influxdata/influxdb-client-java: InfluxDB 2 JVM Based Clients
InfluxDB 2 JVM Based Clients. Contribute to influxdata/influxdb-client-java development by creating an account on GitHub.
Meine Upload Klasse sieht so aus:
Java:
public class Upload implements Runnable {
private InfluxDBClient client = null;
private String bucket;
private String org;
private List<Point> points;
private List<Point> pointsOriginal;
private Logger logger = (Logger) LoggerFactory.getLogger(getClass());
private List<Point> uploadPayload = new ArrayList<>();
public Upload(InfluxDBClient client, String bucket, String org, List<Point> pointsOriginal, List<Point> points) {
this.bucket = bucket;
this.org = org;
this.client = client;
this.points = points;
this.pointsOriginal = pointsOriginal;
this.logger.setLevel(Level.INFO);
}
public void run() {
try {
logger.debug("create InfluxDB Data: " + points.toString());
ListIterator<Point> pointIterator = points.listIterator();
while (pointIterator.hasNext()) {
uploadPayload = new ArrayList<>();
for (int i = 0; i < 10000; i++) {
if (pointIterator.hasNext()) {
this.uploadPayload.add(pointIterator.next());
pointIterator.remove();
}
}
WriteApiBlocking writeApi = client.getWriteApiBlocking();
logger.debug("upload InfluxDB Data");
writeApi.writePoints(bucket, org, uploadPayload);
logger.debug("upload InfluxDB Data: " + uploadPayload.size() + " elements DONE");
}
} catch (Exception e) {
logger.error(e.getLocalizedMessage());
pointsOriginal.addAll(uploadPayload);
pointsOriginal.addAll(points);
}
}
}
Bei der Zeile:
writeApi.writePoints(bucket, org, uploadPayload);
erhalte ich in Eclipse den Fehler:
The type com.influxdb.exceptions.InfluxException cannot be resolved. It is indirectly referenced from required type com.influxdb.client.WriteApiBlocking
Es fehlt wohl die "com.influxdb.exceptions.InfluxException". Ich habe als Client die Version 7.1.0 von Maven geladen:
Da sehe ich aber keine entsprechendes .jar File
Kennt sich da jemand mit InfluxDB aus?
Danke!