feat(client_libs): add Scala WriteAPI example (#4579)

* chore(client_libs): update Client versions

Author: bednar

src/writeData/clients/Java/description.md

@@ -8,14 +8,14 @@ Build with Maven
 <dependency>
   <groupId>com.influxdb</groupId>
   <artifactId>influxdb-client-java</artifactId>
-  <version>4.3.0</version>
+  <version>6.3.0</version>
 </dependency>
 ```
 
 Build with Gradle
 
 ```
 dependencies {
-  implementation "com.influxdb:influxdb-client-java:4.3.0"
+  implementation "com.influxdb:influxdb-client-java:6.3.0"
 }
 ```

src/writeData/clients/Kotlin/description.md

@@ -8,14 +8,14 @@ Build with Maven
 <dependency>
   <groupId>com.influxdb</groupId>
   <artifactId>influxdb-client-kotlin</artifactId>
-  <version>4.3.0</version>
+  <version>6.3.0</version>
 </dependency>
 ```
 
 Build with Gradle
 
 ```
 dependencies {
-  implementation "com.influxdb:influxdb-client-kotlin:4.3.0"
+  implementation "com.influxdb:influxdb-client-kotlin:6.3.0"
 }
 ```

src/writeData/clients/Scala/description.md

@@ -5,7 +5,7 @@ For more detailed and up to date information check out the [GitHub Repository](h
 Build with sbt
 
 ```
-libraryDependencies += "com.influxdb" % "influxdb-client-scala" % "4.3.0"
+libraryDependencies += "com.influxdb" % "influxdb-client-scala" % "6.3.0"
 ```
 
 Build with Maven
@@ -14,14 +14,14 @@ Build with Maven
 <dependency>
   <groupId>com.influxdb</groupId>
   <artifactId>influxdb-client-scala</artifactId>
-  <version>4.3.0</version>
+  <version>6.3.0</version>
 </dependency>
 ```
 
 Build with Gradle
 
 ```
 dependencies {
-  implementation "com.influxdb:influxdb-client-scala:4.3.0"
+  implementation "com.influxdb:influxdb-client-scala:6.3.0"
 }
 ```

src/writeData/clients/Scala/dispose.example

@@ -1 +1,2 @@
 client.close()
+system.terminate()

src/writeData/clients/Scala/execute.example

@@ -10,7 +10,3 @@ val sink = results
 
 // wait to finish
 Await.result(sink, Duration.Inf)
-
-client.close()
-system.terminate()
-

src/writeData/clients/Scala/executeFull.example

@@ -10,7 +10,7 @@ import scala.concurrent.duration.Duration
 
 object InfluxDB2ScalaExample {
 
-  implicit val system: ActorSystem = ActorSystem("it-tests")
+  implicit val system: ActorSystem = ActorSystem("examples")
 
   def main(args: Array[String]): Unit = {
 

src/writeData/clients/Scala/index.ts

@@ -3,6 +3,9 @@ import description from 'src/writeData/clients/Scala/description.md'
 import initialize from 'src/writeData/clients/Scala/initialize.example'
 import execute from 'src/writeData/clients/Scala/execute.example'
 import query from 'src/writeData/clients/Scala/query.example'
+import writeLP from 'src/writeData/clients/Scala/write.0.example'
+import writePoint from 'src/writeData/clients/Scala/write.1.example'
+import writePOJO from 'src/writeData/clients/Scala/write.2.example'
 import dispose from 'src/writeData/clients/Scala/dispose.example'
 import executeFull from 'src/writeData/clients/Scala/executeFull.example'
 
@@ -15,6 +18,20 @@ export default register =>
     initialize,
     execute,
     query,
+    write: [
+      {
+        title: 'Use InfluxDB Line Protocol to write data',
+        code: writeLP,
+      },
+      {
+        title: 'Use a Data Point to write data',
+        code: writePoint,
+      },
+      {
+        title: 'Use POJO and corresponding class to write data',
+        code: writePOJO,
+      },
+    ],
     dispose,
     executeFull,
   })

src/writeData/clients/Scala/initialize.example

@@ -1,24 +1,29 @@
 package example
 
 import akka.actor.ActorSystem
-import akka.stream.scaladsl.Sink
+import akka.stream.scaladsl.{Keep, Sink, Source}
+import com.influxdb.annotations.{Column, Measurement}
+import com.influxdb.client.domain.WritePrecision
 import com.influxdb.client.scala.InfluxDBClientScalaFactory
 import com.influxdb.query.FluxRecord
+import com.influxdb.client.write.Point
 
+import java.time.Instant
 import scala.concurrent.Await
 import scala.concurrent.duration.Duration
 
 object InfluxDB2ScalaExample {
 
-  implicit val system: ActorSystem = ActorSystem("it-tests")
+  implicit val system: ActorSystem = ActorSystem("examples")
 
   def main(args: Array[String]): Unit = {
 
     // You can generate an API token from the "API Tokens Tab" in the UI
     val token = sys.env.get("INFLUX_TOKEN")
     val org = "<%= org %>"
+    val bucket = "<%= bucket %>"
 
-    val client = InfluxDBClientScalaFactory.create("<%= server %>", token.toCharArray, org)
+    val client = InfluxDBClientScalaFactory.create("<%= server %>", token.get.toCharArray, org, bucket)
   }
 }
 

src/writeData/clients/Scala/write.0.example

@@ -0,0 +1,7 @@
+val record = "mem,host=host1 used_percent=23.43234543"
+
+val source = Source.single(record)
+val sink = client.getWriteScalaApi.writeRecord()
+val materialized = source.toMat(sink)(Keep.right)
+
+Await.result(materialized.run(), Duration.Inf)

src/writeData/clients/Scala/write.1.example

@@ -0,0 +1,11 @@
+val point = Point
+  .measurement("mem")
+  .addTag("host", "host1")
+  .addField("used_percent", 23.43234543)
+  .time(Instant.now(), WritePrecision.NS)
+
+val source = Source.single(point)
+val sink = client.getWriteScalaApi.writePoint()
+val materialized = source.toMat(sink)(Keep.right)
+
+Await.result(materialized.run(), Duration.Inf)