influxdata / influxdata/influxdb-java

Influx db java client batch does not write to DB

Aperta
#378 20 commenti 0 reazioni 0 assegnatari Vedi su GitHub
help wanted kind/bug
Lingua principale
Java
Stelle
1.2k
Fork
469
Metriche di merge delle PR
Nessuna PR unita negli ultimi 30g

Descrizione

I am trying to write points to influxDB using their Java client.
Batch is important to me.

If I use the influxDB.enableBatch with influxDB.write(Point) no data is inserted.
If I use the BatchPoints and influxDB.write(batchPoints) - data is inserted successfully.

Both code samples are taken from: https://github.com/influxdata/influxdb-java/tree/influxdb-java-2.7

InfluxDB influxDB = InfluxDBFactory.connect(influxUrl, influxUser, influxPassword);
influxDB.setDatabase(dbName);
influxDB.setRetentionPolicy("autogen");

// Flush every 2000 Points, at least every 100ms
influxDB.enableBatch(2000, 100, TimeUnit.MILLISECONDS);
influxDB.write(Point.measurement("cpu")
.time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
.addField("idle", 90L)
.addField("user", 9L)
.addField("system", 1L)
.build());

Query query = new Query("SELECT idle FROM cpu", dbName);
QueryResult result = influxDB.query(query);

Returns nothing.


BatchPoints batchPoints = BatchPoints.database(dbName).tag("async", "true").build();
Point point1 = Point
.measurement("cpu")
.tag("atag", "test")
.addField("idle", 90L)
.addField("usertime", 9L)
.addField("system", 1L)
.build();
batchPoints.point(point1);
influxDB.write(batchPoints);
Query query = new Query("SELECT * FROM cpu ", dbName);
QueryResult result = influxDB.query(query);

This returns data successfully.

As mentioned, I need the first way to function.
How can I achieve that?

versions:
influxdb-1.3.6
influxdb-java:2.7

Thanks

Guida per i contributori

Nessuna guida per i contributori indicizzata per questo repository

Direzione di ricerca

Inizia con il percorso enableBatch del client Java e riproduci il primo esempio di codice con InfluxDB 1.3.6, quindi confronta il suo comportamento con quello dell'esempio funzionante di BatchPoints. Verifica la correzione confermando che un punto scritto tramite enableBatch venga restituito dalla query fornita dopo l'intervallo di flush del batch.

Scritto dal modello di indicizzazione a partire dal testo della issue.

Valutazione

Stack tecnologico
java
Ambito
database
Tipo di issue
Bug
Difficoltà
3/5
Tempo stimato
1-2 giorni
Stato di attività
Ferma
Chiarezza
Abbastanza chiara
Idoneità per principianti
35/100

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.