Tiny bit of code emitting to InfluxDB Time Series Database in Scala

readme.txt

Working jar not released, so using jitpack to build on the fly.

Be sure to create "mydb" first. e.g. CREATE DATABASE "mydb"

For pom.xml

<repository>
   <id>jitpack.io</id>
   <url>https://jitpack.io</url>
</repository>

<dependency>
   <groupId>com.github.influxdb</groupId>
   <artifactId>influxdb-java</artifactId>
   <version>ef90bf6865</version>
</dependency>

Influx1.scala

package influxdb

import org.influxdb._
import org.influxdb.dto._
import java.util.concurrent.TimeUnit

object Influx1 extends App {
  val influxDB = InfluxDBFactory.connect("http://localhost:8086", "root", "root");
    
  println(influxDB.describeDatabases())
  
  val batchPoints = BatchPoints.database("mydb").tag("async", "true").retentionPolicy("default").build();
  
  val point1 = Point.measurement("cpu")
                   // .time(System.currentTimeMillis(), TimeUnit.MILLISECONDS)
                    .tag("host", "serverB").tag("region", "us_south")
                    .field("value", 0.20)
                    .build();
  
  println(batchPoints)
  
  batchPoints.point(point1)
  influxDB.write(batchPoints)
  Thread.sleep(1000)
}