nellemann/svci
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

Set influx time precision to seconds.

Browse source
This commit is contained in:
Mark Nellemann 2022-12-10 11:20:45 +01:00
parent 3fc3a45f31
commit 766b2fa91f
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
build.gradle
View file

@ -24,8 +24,8 @@ dependencies {
implementation 'info.picocli:picocli:4.7.0' implementation 'info.picocli:picocli:4.7.0'
implementation 'org.influxdb:influxdb-java:2.23' implementation 'org.influxdb:influxdb-java:2.23'
//implementation 'com.influxdb:influxdb-client-java:6.7.0' //implementation 'com.influxdb:influxdb-client-java:6.7.0'
implementation 'org.slf4j:slf4j-api:2.0.4' implementation 'org.slf4j:slf4j-api:2.0.5'
implementation 'org.slf4j:slf4j-simple:2.0.4' implementation 'org.slf4j:slf4j-simple:2.0.5'
implementation 'com.squareup.okhttp3:okhttp:4.10.0' // Also used by InfluxDB Client implementation 'com.squareup.okhttp3:okhttp:4.10.0' // Also used by InfluxDB Client
//implementation "org.eclipse.jetty:jetty-client:9.4.49.v20220914" //implementation "org.eclipse.jetty:jetty-client:9.4.49.v20220914"
implementation 'com.fasterxml.jackson.core:jackson-databind:2.14.1' implementation 'com.fasterxml.jackson.core:jackson-databind:2.14.1'

2
src/main/java/biz/nellemann/svci/InfluxClient.java
View file

@ -107,7 +107,7 @@ public final class InfluxClient {
List<Point> listOfPoints = new ArrayList<>(); List<Point> listOfPoints = new ArrayList<>();
measurements.forEach( (m) -> { measurements.forEach( (m) -> {
Point.Builder builder = Point.measurement(measurement) Point.Builder builder = Point.measurement(measurement)
.time(timestamp.toEpochMilli(), TimeUnit.MILLISECONDS) .time(timestamp.getEpochSecond(), TimeUnit.SECONDS)
.tag(m.tags) .tag(m.tags)
.fields(m.fields); .fields(m.fields);
listOfPoints.add(builder.build()); listOfPoints.add(builder.build());